Package | Description |
---|---|
org.infinispan |
This is the core of Infinispan, a distributed, transactional, highly scalable data grid
platform.
|
org.infinispan.cache.impl | |
org.infinispan.interceptors.compat | |
org.infinispan.interceptors.distribution | |
org.infinispan.stream.impl | |
org.infinispan.stream.impl.interceptor | |
org.infinispan.stream.impl.local | |
org.infinispan.stream.impl.tx |
Modifier and Type | Method and Description |
---|---|
CacheStream<R> |
CacheStream.disableRehashAware()
Disables tracking of rehash events that could occur to the underlying cache.
|
CacheStream<R> |
CacheStream.distributedBatchSize(int batchSize)
Controls how many keys are returned from a remote node when using a stream terminal operation with a distributed
cache to back this stream.
|
CacheStream<R> |
CacheStream.filterKeys(Set<?> keys)
Filters which entries are returned by only returning ones that map to the given key.
|
CacheStream<R> |
CacheStream.filterKeySegments(Set<Integer> segments)
Filters which entries are returned by what segment they are present in.
|
CacheStream<R> |
CacheStream.parallelDistribution()
This would enable sending requests to all other remote nodes when a terminal operator is performed.
|
CacheStream<E> |
CacheCollection.parallelStream() |
CacheStream<R> |
CacheStream.segmentCompletionListener(CacheStream.SegmentCompletionListener listener)
Allows registration of a segment completion listener that is notified when a segment has completed
processing.
|
CacheStream<R> |
CacheStream.sequentialDistribution()
This would disable sending requests to all other remote nodes compared to one at a time.
|
CacheStream<E> |
CacheCollection.stream() |
CacheStream<R> |
CacheStream.timeout(long timeout,
TimeUnit unit)
Sets a given time to wait for a remote operation to respond by.
|
Modifier and Type | Method and Description |
---|---|
CacheStream<Map.Entry<K,V>> |
SimpleCacheImpl.EntrySet.parallelStream() |
CacheStream<CacheEntry<K,V>> |
SimpleCacheImpl.CacheEntrySet.parallelStream() |
CacheStream<V> |
SimpleCacheImpl.Values.parallelStream() |
CacheStream<K> |
SimpleCacheImpl.KeySet.parallelStream() |
CacheStream<Map.Entry<K,V>> |
SimpleCacheImpl.EntrySet.stream() |
CacheStream<CacheEntry<K,V>> |
SimpleCacheImpl.CacheEntrySet.stream() |
CacheStream<V> |
SimpleCacheImpl.Values.stream() |
CacheStream<K> |
SimpleCacheImpl.KeySet.stream() |
Modifier and Type | Class and Description |
---|---|
class |
TypeConverterStream
Delegating stream that converts elements or CacheEntries.
|
Constructor and Description |
---|
TypeConverterStream(CacheStream<?> stream,
TypeConverter<Object,Object,Object,Object> converter,
InternalEntryFactory entryFactory) |
Modifier and Type | Method and Description |
---|---|
CacheStream<CacheEntry<K,V>> |
DistributionBulkInterceptor.BackingEntrySet.parallelStream() |
CacheStream<CacheEntry<K,V>> |
DistributionBulkInterceptor.TxBackingEntrySet.parallelStream() |
CacheStream<K> |
DistributionBulkInterceptor.BackingKeySet.parallelStream() |
CacheStream<CacheEntry<K,V>> |
DistributionBulkInterceptor.BackingEntrySet.stream() |
CacheStream<CacheEntry<K,V>> |
DistributionBulkInterceptor.TxBackingEntrySet.stream() |
CacheStream<K> |
DistributionBulkInterceptor.BackingKeySet.stream() |
Modifier and Type | Class and Description |
---|---|
class |
AbstractDelegatingCacheStream<R>
Delegate that forwards all the of the method calls to the underlying cache stream.
|
class |
DistributedCacheStream<R>
Implementation of
CacheStream that provides support for lazily distributing stream methods to appropriate
nodes |
Modifier and Type | Field and Description |
---|---|
protected CacheStream<?> |
AbstractDelegatingCacheStream.underlyingStream |
Modifier and Type | Field and Description |
---|---|
protected Supplier<CacheStream<CacheEntry>> |
AbstractCacheStream.supplier |
Modifier and Type | Method and Description |
---|---|
CacheStream<R> |
AbstractDelegatingCacheStream.disableRehashAware() |
CacheStream<R> |
DistributedCacheStream.disableRehashAware() |
CacheStream<R> |
AbstractDelegatingCacheStream.distributedBatchSize(int batchSize) |
CacheStream<R> |
DistributedCacheStream.distributedBatchSize(int batchSize) |
CacheStream<R> |
AbstractDelegatingCacheStream.filterKeys(Set<?> keys) |
CacheStream<R> |
DistributedCacheStream.filterKeys(Set<?> keys) |
CacheStream<R> |
AbstractDelegatingCacheStream.filterKeySegments(Set<Integer> segments) |
CacheStream<R> |
DistributedCacheStream.filterKeySegments(Set<Integer> segments) |
CacheStream<R> |
AbstractDelegatingCacheStream.parallelDistribution() |
CacheStream<R> |
DistributedCacheStream.parallelDistribution() |
abstract CacheStream<E> |
AbstractDelegatingCacheCollection.parallelStream() |
CacheStream<R> |
AbstractDelegatingCacheStream.segmentCompletionListener(CacheStream.SegmentCompletionListener listener) |
CacheStream<R> |
DistributedCacheStream.segmentCompletionListener(CacheStream.SegmentCompletionListener listener) |
CacheStream<R> |
AbstractDelegatingCacheStream.sequentialDistribution() |
CacheStream<R> |
DistributedCacheStream.sequentialDistribution() |
abstract CacheStream<E> |
AbstractDelegatingCacheCollection.stream() |
CacheStream<R> |
AbstractDelegatingCacheStream.timeout(long timeout,
TimeUnit unit) |
CacheStream<R> |
DistributedCacheStream.timeout(long timeout,
TimeUnit unit) |
Modifier and Type | Method and Description |
---|---|
protected static Supplier<CacheStream<CacheEntry>> |
DistributedCacheStream.supplierStreamCast(Supplier supplier) |
Constructor and Description |
---|
AbstractDelegatingCacheStream(CacheStream<R> stream) |
Constructor and Description |
---|
AbstractCacheStream(Address localAddress,
boolean parallel,
DistributionManager dm,
Supplier<CacheStream<CacheEntry>> supplier,
ClusterStreamManager<Object> csm,
boolean includeLoader,
int distributedBatchSize,
Executor executor,
ComponentRegistry registry) |
DistributedCacheStream(Address localAddress,
boolean parallel,
DistributionManager dm,
Supplier<CacheStream<CacheEntry<K,V>>> supplier,
ClusterStreamManager csm,
boolean includeLoader,
int distributedBatchSize,
Executor executor,
ComponentRegistry registry)
Standard constructor requiring all pertinent information to properly utilize a distributed cache stream
|
DistributedCacheStream(Address localAddress,
boolean parallel,
DistributionManager dm,
Supplier<CacheStream<CacheEntry<K,V>>> supplier,
ClusterStreamManager csm,
boolean includeLoader,
int distributedBatchSize,
Executor executor,
ComponentRegistry registry,
Function<? super CacheEntry<K,V>,R> function)
Constructor that also allows a simple map method to be inserted first to change to another type.
|
Modifier and Type | Method and Description |
---|---|
protected CacheStream<CacheEntry<K,V>> |
AbstractDelegatingEntryCacheSet.getStream(boolean parallel) |
protected CacheStream<K> |
AbstractDelegatingKeyCacheSet.getStream(boolean parallel) |
CacheStream<CacheEntry<K,V>> |
AbstractDelegatingEntryCacheSet.parallelStream() |
CacheStream<K> |
AbstractDelegatingKeyCacheSet.parallelStream() |
CacheStream<CacheEntry<K,V>> |
AbstractDelegatingEntryCacheSet.stream() |
CacheStream<K> |
AbstractDelegatingKeyCacheSet.stream() |
Modifier and Type | Class and Description |
---|---|
class |
LocalCacheStream<R>
CacheStream that is to be used locally.
|
Modifier and Type | Method and Description |
---|---|
CacheStream<R> |
LocalCacheStream.disableRehashAware() |
CacheStream<R> |
LocalCacheStream.distributedBatchSize(int batchSize) |
CacheStream<R> |
LocalCacheStream.filterKeys(Set<?> keys) |
CacheStream<R> |
LocalCacheStream.filterKeySegments(Set<Integer> segments) |
CacheStream<R> |
LocalCacheStream.parallelDistribution() |
CacheStream<V> |
ValueCacheCollection.parallelStream() |
CacheStream<R> |
LocalCacheStream.segmentCompletionListener(CacheStream.SegmentCompletionListener listener) |
CacheStream<R> |
LocalCacheStream.sequentialDistribution() |
CacheStream<V> |
ValueCacheCollection.stream() |
CacheStream<R> |
LocalCacheStream.timeout(long timeout,
TimeUnit unit) |
Modifier and Type | Class and Description |
---|---|
class |
TxDistributedCacheStream<R>
A distributed cache stream that also utilizes transactional awareness.
|
Constructor and Description |
---|
TxDistributedCacheStream(Address localAddress,
boolean parallel,
DistributionManager dm,
Supplier<CacheStream<CacheEntry<K,V>>> supplier,
TxClusterStreamManager<?> csm,
boolean includeLoader,
int distributedBatchSize,
Executor executor,
ComponentRegistry registry,
Function<? super CacheEntry<K,V>,R> function,
LocalTxInvocationContext ctx) |
TxDistributedCacheStream(Address localAddress,
boolean parallel,
DistributionManager dm,
Supplier<CacheStream<CacheEntry<K,V>>> supplier,
TxClusterStreamManager<?> csm,
boolean includeLoader,
int distributedBatchSize,
Executor executor,
ComponentRegistry registry,
LocalTxInvocationContext ctx) |
Copyright © 2023 JBoss, a division of Red Hat. All rights reserved.