| 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 
 | 
| com.hazelcast.client.proxy | 
 This package contains client side proxy implementations of the different Hazelcast data structures
 and operation types 
 | 
| com.hazelcast.internal.journal | 
 This package contains supporting classes for data structure specific event journals. 
 | 
| com.hazelcast.internal.util.concurrent | 
 Concurrent queues etc. 
 | 
| com.hazelcast.map.impl.journal | |
| com.hazelcast.map.impl.proxy | 
 Contains map proxy implementation and support classes. 
 | 
| com.hazelcast.ringbuffer.impl | 
 Contains the  
Ringbuffer implementation classes. | 
| com.hazelcast.util.collection | 
 The Agrona project backport: collections. 
 | 
| 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,
                    Projection<? super EventJournalCacheEvent<K,V>,? extends T> projection)  | 
| Modifier and Type | Field and Description | 
|---|---|
protected Predicate<? super EventJournalCacheEvent<K,V>> | 
CacheEventJournalReadOperation.predicate  | 
| Constructor and Description | 
|---|
CacheEventJournalReadOperation(String cacheName,
                              long startSequence,
                              int minSize,
                              int maxSize,
                              Predicate<? super EventJournalCacheEvent<K,V>> predicate,
                              Projection<? 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,
                    Projection<? super EventJournalCacheEvent<K,V>,? extends T> projection)  | 
| 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,
                    Projection<? super EventJournalMapEvent<K,V>,? extends T> projection)  | 
| Modifier and Type | Method and Description | 
|---|---|
<T> ICompletableFuture<ReadResultSet<T>> | 
EventJournalReader.readFromEventJournal(long startSequence,
                    int minSize,
                    int maxSize,
                    int partitionId,
                    Predicate<? super E> predicate,
                    Projection<? super E,? extends T> projection)
Reads from the event journal. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
int | 
ConcurrentConveyor.drain(int queueIndex,
     Predicate<? super E> itemHandler)
Drains a batch of items from the queue at the supplied index to the
 supplied  
itemHandler. | 
int | 
OneToOneConcurrentArrayQueue.drain(Predicate<? super E> itemHandler)  | 
int | 
Pipe.drain(Predicate<? super E> itemHandler)
Drains the items available in the pipe to the supplied item handler. 
 | 
int | 
ManyToOneConcurrentArrayQueue.drain(Predicate<? super E> itemHandler)  | 
| Modifier and Type | Field and Description | 
|---|---|
protected Predicate<? super EventJournalMapEvent<K,V>> | 
MapEventJournalReadOperation.predicate  | 
| Constructor and Description | 
|---|
MapEventJournalReadOperation(String mapName,
                            long startSequence,
                            int minSize,
                            int maxSize,
                            Predicate<? super EventJournalMapEvent<K,V>> predicate,
                            Projection<? 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,
                    Projection<? super EventJournalMapEvent<K,V>,? extends T> projection)
Reads from the event journal. 
 | 
| Constructor and Description | 
|---|
ReadResultSetImpl(int minSize,
                 int maxSize,
                 SerializationService serializationService,
                 Predicate<? super O> predicate,
                 Projection<? super O,E> projection)  | 
| Constructor and Description | 
|---|
MapDelegatingSet(Map<?,?> delegate,
                Supplier<Iterator<V>> iterator,
                Predicate contains)  | 
Copyright © 2018 Hazelcast, Inc.. All Rights Reserved.