Package | Description |
---|---|
com.hazelcast.cache.impl |
Hazelcast JSR-107 aka JCache implementation
|
com.hazelcast.cache.impl.journal | |
com.hazelcast.client.cache.impl |
Hazelcast JSR-107 aka JCache implementation client side
|
Modifier and Type | Method and Description |
---|---|
<T> ICompletableFuture<ReadResultSet<T>> |
CacheProxy.readFromEventJournal(long startSequence,
int minSize,
int maxSize,
int partitionId,
Predicate<? super EventJournalCacheEvent<K,V>> predicate,
Function<? super EventJournalCacheEvent<K,V>,? extends T> projection) |
<T> ICompletableFuture<ReadResultSet<T>> |
CacheProxy.readFromEventJournal(long startSequence,
int minSize,
int maxSize,
int partitionId,
Predicate<? super EventJournalCacheEvent<K,V>> predicate,
Function<? super EventJournalCacheEvent<K,V>,? extends T> projection) |
Modifier and Type | Class and Description |
---|---|
class |
DeserializingEventJournalCacheEvent<K,V> |
Modifier and Type | Field and Description |
---|---|
protected Predicate<? super EventJournalCacheEvent<K,V>> |
CacheEventJournalReadOperation.predicate |
protected Function<? super EventJournalCacheEvent<K,V>,? extends T> |
CacheEventJournalReadOperation.projection |
Modifier and Type | Method and Description |
---|---|
static <K,V> Function<EventJournalCacheEvent<K,V>,V> |
CacheEventJournalFunctions.cacheEventNewValue() |
static <K,V> Function<EventJournalCacheEvent<K,V>,Map.Entry<K,V>> |
CacheEventJournalFunctions.cacheEventToEntry() |
static <K,V> Predicate<EventJournalCacheEvent<K,V>> |
CacheEventJournalFunctions.cachePutEvents() |
Constructor and Description |
---|
CacheEventJournalReadOperation(String cacheName,
long startSequence,
int minSize,
int maxSize,
Predicate<? super EventJournalCacheEvent<K,V>> predicate,
Function<? super EventJournalCacheEvent<K,V>,? extends T> projection) |
CacheEventJournalReadOperation(String cacheName,
long startSequence,
int minSize,
int maxSize,
Predicate<? super EventJournalCacheEvent<K,V>> predicate,
Function<? super EventJournalCacheEvent<K,V>,? extends T> projection) |
Modifier and Type | Method and Description |
---|---|
<T> ICompletableFuture<ReadResultSet<T>> |
ClientCacheProxy.readFromEventJournal(long startSequence,
int minSize,
int maxSize,
int partitionId,
Predicate<? super EventJournalCacheEvent<K,V>> predicate,
Function<? super EventJournalCacheEvent<K,V>,? extends T> projection) |
<T> ICompletableFuture<ReadResultSet<T>> |
ClientCacheProxy.readFromEventJournal(long startSequence,
int minSize,
int maxSize,
int partitionId,
Predicate<? super EventJournalCacheEvent<K,V>> predicate,
Function<? super EventJournalCacheEvent<K,V>,? extends T> projection) |
Copyright © 2020 Hazelcast, Inc.. All Rights Reserved.