Uses of Interface
com.hazelcast.replicatedmap.ReplicatedMap
Package
Description
Provides core API interfaces/classes.
Hazelcast Jet is a distributed computation engine running on top of
Hazelcast IMDG technology.
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
-
Uses of ReplicatedMap in com.hazelcast.core
Modifier and TypeMethodDescription<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
Modifier and TypeMethodDescription<K,
V> ReplicatedMap<K, V> JetInstance.getReplicatedMap
(String name) Deprecated. -
Uses of ReplicatedMap in com.hazelcast.jet.pipeline
Modifier and TypeMethodDescriptionstatic <K,
V> ServiceFactory<?, ReplicatedMap<K, V>> ServiceFactories.replicatedMapService
(String mapName) Returns a factory that provides aReplicatedMap
as the service object.Modifier and TypeMethodDescriptiondefault <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)
HazelcastInstance.getReplicatedMap(String)
instead.