Package | Description |
---|---|
com.hazelcast.client.proxy |
This package contains client side proxy implementations of the different Hazelcast data structures
and operation types
|
com.hazelcast.map.impl.journal | |
com.hazelcast.map.impl.proxy |
Contains map proxy implementation and support classes.
|
Modifier and Type | Method and Description |
---|---|
<T> ICompletableFuture<ReadResultSet<T>> |
ClientMapProxy.readFromEventJournal(long startSequence,
int minSize,
int maxSize,
int partitionId,
Predicate<? super EventJournalMapEvent<K,V>> predicate,
Function<? super EventJournalMapEvent<K,V>,? extends T> projection) |
<T> ICompletableFuture<ReadResultSet<T>> |
ClientMapProxy.readFromEventJournal(long startSequence,
int minSize,
int maxSize,
int partitionId,
Predicate<? super EventJournalMapEvent<K,V>> predicate,
Function<? super EventJournalMapEvent<K,V>,? extends T> projection) |
Modifier and Type | Class and Description |
---|---|
class |
DeserializingEventJournalMapEvent<K,V> |
Modifier and Type | Field and Description |
---|---|
protected Predicate<? super EventJournalMapEvent<K,V>> |
MapEventJournalReadOperation.predicate |
protected Function<? super EventJournalMapEvent<K,V>,? extends T> |
MapEventJournalReadOperation.projection |
Modifier and Type | Method and Description |
---|---|
static <K,V> Function<EventJournalMapEvent<K,V>,V> |
MapEventJournalFunctions.mapEventNewValue() |
static <K,V> Function<EventJournalMapEvent<K,V>,Map.Entry<K,V>> |
MapEventJournalFunctions.mapEventToEntry() |
static <K,V> Predicate<EventJournalMapEvent<K,V>> |
MapEventJournalFunctions.mapPutEvents() |
Constructor and Description |
---|
MapEventJournalReadOperation(String mapName,
long startSequence,
int minSize,
int maxSize,
Predicate<? super EventJournalMapEvent<K,V>> predicate,
Function<? super EventJournalMapEvent<K,V>,? extends T> projection) |
MapEventJournalReadOperation(String mapName,
long startSequence,
int minSize,
int maxSize,
Predicate<? super EventJournalMapEvent<K,V>> predicate,
Function<? super EventJournalMapEvent<K,V>,? extends T> projection) |
Modifier and Type | Method and Description |
---|---|
<T> ICompletableFuture<ReadResultSet<T>> |
MapProxyImpl.readFromEventJournal(long startSequence,
int minSize,
int maxSize,
int partitionId,
Predicate<? super EventJournalMapEvent<K,V>> predicate,
Function<? super EventJournalMapEvent<K,V>,? extends T> projection)
Reads from the event journal.
|
<T> ICompletableFuture<ReadResultSet<T>> |
MapProxyImpl.readFromEventJournal(long startSequence,
int minSize,
int maxSize,
int partitionId,
Predicate<? super EventJournalMapEvent<K,V>> predicate,
Function<? super EventJournalMapEvent<K,V>,? extends T> projection)
Reads from the event journal.
|
Copyright © 2020 Hazelcast, Inc.. All Rights Reserved.