| 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.util.concurrent | Concurrent queues etc. | 
| com.hazelcast.journal | This package contains supporting classes for data structure specific event journals. | 
| com.hazelcast.map.impl.journal | |
| com.hazelcast.map.impl.proxy | Contains map proxy implementation and support classes. | 
| com.hazelcast.ringbuffer.impl | Contains the  Ringbufferimplementation 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>,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>,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>,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>,T> projection) | 
| 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 | Method and Description | 
|---|---|
| <T> ICompletableFuture<ReadResultSet<T>> | EventJournalReader. readFromEventJournal(long startSequence,
                    int minSize,
                    int maxSize,
                    int partitionId,
                    Predicate<? super E> predicate,
                    Projection<? super E,T> projection)Reads from the event journal. | 
| 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>,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>,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.