Uses of Interface
com.hazelcast.replicatedmap.ReplicatedMap
Package | Description |
---|---|
com.hazelcast.core |
Provides core API interfaces/classes.
|
com.hazelcast.jet |
Hazelcast Jet is a distributed computation engine running on top of
Hazelcast IMDG technology.
|
com.hazelcast.jet.pipeline |
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
|
-
Uses of ReplicatedMap in com.hazelcast.core
Methods in com.hazelcast.core that return ReplicatedMap Modifier and Type Method Description <K, V> ReplicatedMap<K,V>
HazelcastInstance. getReplicatedMap(String name)
Creates or returns the replicated map instance with the specified name. -
Uses of ReplicatedMap in com.hazelcast.jet
Methods in com.hazelcast.jet that return ReplicatedMap Modifier and Type Method Description <K, V> ReplicatedMap<K,V>
JetInstance. getReplicatedMap(String name)
Returns the replicated map instance with the specified name. -
Uses of ReplicatedMap in com.hazelcast.jet.pipeline
Methods in com.hazelcast.jet.pipeline that return types with arguments of type ReplicatedMap Modifier and Type Method Description static <K, V> ServiceFactory<?,ReplicatedMap<K,V>>
ServiceFactories. replicatedMapService(String mapName)
Returns a factory that provides aReplicatedMap
as the service object.Methods in com.hazelcast.jet.pipeline with parameters of type ReplicatedMap Modifier and Type Method Description default <K, V, R> BatchStage<R>
BatchStage. mapUsingReplicatedMap(ReplicatedMap<K,V> replicatedMap, FunctionEx<? super T,? extends K> lookupKeyFn, BiFunctionEx<? super T,? super V,? extends R> mapFn)
default <K, V, R> GeneralStage<R>
GeneralStage. mapUsingReplicatedMap(ReplicatedMap<K,V> replicatedMap, FunctionEx<? super T,? extends K> lookupKeyFn, BiFunctionEx<? super T,? super V,? extends R> mapFn)
Attaches a mapping stage where for each item a lookup in the suppliedReplicatedMap
is performed and the result of the lookup is merged with the item and emitted.default <K, V, R> StreamStage<R>
StreamStage. mapUsingReplicatedMap(ReplicatedMap<K,V> replicatedMap, FunctionEx<? super T,? extends K> lookupKeyFn, BiFunctionEx<? super T,? super V,? extends R> mapFn)