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 |
Contains implementation specific classes of
com.hazelcast.map package. |
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 |
This package contains classes to support the inner workings of Hazelcast
as well as some backports of newer Java features / data structures to
support older Java versions in a clean and nice way.
|
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,
Function<? super EventJournalCacheEvent<K,V>,? extends T> projection) |
Modifier and Type | Field and Description |
---|---|
protected Predicate<? super EventJournalCacheEvent<K,V>> |
CacheEventJournalReadOperation.predicate |
Modifier and Type | Method and Description |
---|---|
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) |
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) |
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) |
Modifier and Type | Method and Description |
---|---|
<T> ICompletableFuture<ReadResultSet<T>> |
EventJournalReader.readFromEventJournal(long startSequence,
int minSize,
int maxSize,
int partitionId,
Predicate<? super E> predicate,
Function<? 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 | Method and Description |
---|---|
void |
MapServiceContext.removeRecordStoresFromPartitionMatchingWith(Predicate<RecordStore> predicate,
int partitionId,
boolean onShutdown,
boolean onRecordStoreDestroy)
Removes all record stores inside the supplied partition ID matching with
the supplied predicate.
|
Modifier and Type | Field and Description |
---|---|
protected Predicate<? super EventJournalMapEvent<K,V>> |
MapEventJournalReadOperation.predicate |
Modifier and Type | Method and Description |
---|---|
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) |
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.
|
Constructor and Description |
---|
ReadResultSetImpl(int minSize,
int maxSize,
SerializationService serializationService,
Predicate<? super O> predicate,
Projection<? super O,E> projection) |
Modifier and Type | Method and Description |
---|---|
static <E> int |
QueueUtil.drainQueue(Queue<E> queue,
int elementsToDrain,
Predicate<E> drainedCountFilter)
Drains the provided queue by the count provided in
elementsToDrain . |
static <E> int |
QueueUtil.drainQueue(Queue<E> queue,
Predicate<E> drainedCountFilter)
Drains the provided queue by the size of the queue as it is known
upfront draining.
|
Constructor and Description |
---|
MapDelegatingSet(Map<?,?> delegate,
Supplier<Iterator<V>> iterator,
Predicate contains) |
Copyright © 2020 Hazelcast, Inc.. All Rights Reserved.