public interface IndexQuery<V>
extends net.openhft.chronicle.wire.Marshallable
Modifier and Type | Field and Description |
---|---|
static int |
FROM_END
send the snapshot that is collected from all the data in the current roll cycle
if you have just restarted, no data will be return until internally all the data in the
current roll cycle has been read and added to the internal map
|
static int |
FROM_START
replay data from the start of the current roll cycle, e.g.
|
Modifier and Type | Method and Description |
---|---|
boolean |
bootstrap() |
static <V> IndexQuery<V> |
create(@NotNull String eventName,
@NotNull Class<V> valueClass,
@NotNull String select,
long from,
boolean bootstrap)
Creates and returns a new IndexQuery for the provided parameters.
|
String |
eventName()
Returns the evenName for this IndexQuery.
|
Predicate<V> |
filter()
Returns the filter Predicate for this IndexQuery.
|
long |
fromIndex()
Returns the fromIndex for this IndexQuery.
|
$equals, $fieldInfoMap, $fieldInfos, $hashCode, $toString, className, copyFrom, copyTo, deepCopy, fromFile, fromFile, fromFileAsMap, fromFileAsMap, fromHexString, fromString, fromString, fromString, getField, getLongField, mergeToMap, readMarshallable, reset, setField, setLongField, streamFromFile, streamFromFile, writeMarshallable
static final int FROM_END
static final int FROM_START
boolean bootstrap()
true
the latest update for the roll cycle ( for example day ) , is provided, the latest update is determined using the
KeyedMarshallable
, if false, not snapshot is returnlong fromIndex()
Only messages with an index that are equal or greater than the fromIndex will appear in the stream of messages. There are two special values for the fromIndex:
Predicate<V> filter()
Only messages that passes the filter Predicate will appear in the stream of messages.
String eventName()
Only messages that has a topic that matched the eventName appear in the stream of messages.
static <V> IndexQuery<V> create(@NotNull @NotNull String eventName, @NotNull @NotNull Class<V> valueClass, @NotNull @NotNull String select, long from, boolean bootstrap)
V
- value typeeventName
- to subscribe to (e.g. topic)valueClass
- for the index query (e.g. message)select
- textual representation of a java predicate code body. The variable to test against is named value
.from
- index to start from or FROM_START
or FROM_END
bootstrap
- if messages should beCopyright © 2021. All rights reserved.