Package | Description |
---|---|
com.hazelcast.jet.core.processor |
Contains static utility classes with factories of Jet processors.
|
com.hazelcast.jet.pipeline |
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
|
com.hazelcast.map |
Contains Hazelcast map module classes.
|
Modifier and Type | Method and Description |
---|---|
static <T,K,V,R> ProcessorMetaSupplier |
SinkProcessors.updateMapP(int maxParallelAsyncOps,
String mapName,
FunctionEx<? super T,? extends K> toKeyFn,
FunctionEx<? super T,? extends EntryProcessor<K,V,R>> toEntryProcessorFn)
Returns a supplier of processors for
Sinks.mapWithEntryProcessor(int, String, FunctionEx, FunctionEx) . |
static <T,K,V,R> ProcessorMetaSupplier |
SinkProcessors.updateMapP(String mapName,
FunctionEx<? super T,? extends K> toKeyFn,
FunctionEx<? super T,? extends EntryProcessor<K,V,R>> toEntryProcessorFn)
Returns a supplier of processors for
Sinks.mapWithEntryProcessor(String, FunctionEx, FunctionEx) . |
static <T,K,V,R> ProcessorMetaSupplier |
SinkProcessors.updateRemoteMapP(String mapName,
ClientConfig clientConfig,
FunctionEx<? super T,? extends K> toKeyFn,
FunctionEx<? super T,? extends EntryProcessor<K,V,R>> toEntryProcessorFn)
Returns a supplier of processors for
Sinks.remoteMapWithEntryProcessor(String, ClientConfig, FunctionEx,
FunctionEx) . |
Modifier and Type | Method and Description |
---|---|
static <T,K,V,R> Sink<T> |
Sinks.mapWithEntryProcessor(IMap<? super K,? super V> map,
FunctionEx<? super T,? extends K> toKeyFn,
FunctionEx<? super T,? extends EntryProcessor<K,V,R>> toEntryProcessorFn)
Returns a sink that uses the items it receives to create
EntryProcessor s it submits to a Hazelcast IMap with the
specified name. |
static <E,K,V,R> Sink<E> |
Sinks.mapWithEntryProcessor(int maxParallelAsyncOps,
String mapName,
FunctionEx<? super E,? extends K> toKeyFn,
FunctionEx<? super E,? extends EntryProcessor<K,V,R>> toEntryProcessorFn)
Returns a sink that uses the items it receives to create
EntryProcessor s it submits to a Hazelcast IMap with the
specified name. |
static <E,K,V,R> Sink<E> |
Sinks.mapWithEntryProcessor(String mapName,
FunctionEx<? super E,? extends K> toKeyFn,
FunctionEx<? super E,? extends EntryProcessor<K,V,R>> toEntryProcessorFn)
Convenience for
Sinks.mapWithEntryProcessor(int, String, FunctionEx, FunctionEx)
when the maximum number of async operations is not specified. |
static <E,K,V,R> Sink<E> |
Sinks.remoteMapWithEntryProcessor(String mapName,
ClientConfig clientConfig,
FunctionEx<? super E,? extends K> toKeyFn,
FunctionEx<? super E,? extends EntryProcessor<K,V,R>> toEntryProcessorFn)
Returns a sink equivalent to
Sinks.mapWithEntryProcessor(java.lang.String, com.hazelcast.function.FunctionEx<? super E, ? extends K>, com.hazelcast.function.FunctionEx<? super E, ? extends com.hazelcast.map.EntryProcessor<K, V, R>>) , but for a map
in a remote Hazelcast cluster identified by the supplied ClientConfig . |
Modifier and Type | Method and Description |
---|---|
default EntryProcessor<K,V,R> |
EntryProcessor.getBackupProcessor()
Get the entry processor to be applied to backup entries.
|
Modifier and Type | Method and Description |
---|---|
<R> Map<K,R> |
IMap.executeOnEntries(EntryProcessor<K,V,R> entryProcessor)
Applies the user defined
EntryProcessor to the all entries in the map. |
<R> Map<K,R> |
IMap.executeOnEntries(EntryProcessor<K,V,R> entryProcessor,
Predicate<K,V> predicate)
Applies the user defined
EntryProcessor to the entries in the map which satisfy provided predicate. |
<R> R |
IMap.executeOnKey(K key,
EntryProcessor<K,V,R> entryProcessor)
Applies the user defined
EntryProcessor to the entry mapped by the key . |
<R> Map<K,R> |
IMap.executeOnKeys(Set<K> keys,
EntryProcessor<K,V,R> entryProcessor)
Applies the user defined
EntryProcessor to the entries mapped by the collection of keys. |
<R> CompletionStage<R> |
IMap.submitToKey(K key,
EntryProcessor<K,V,R> entryProcessor)
Applies the user defined
EntryProcessor to the entry mapped by the key . |
<R> CompletionStage<Map<K,R>> |
IMap.submitToKeys(Set<K> keys,
EntryProcessor<K,V,R> entryProcessor)
|
Copyright © 2022 Hazelcast, Inc.. All rights reserved.