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.
|
Modifier and Type | Method and Description |
---|---|
<K,V> ReplicatedMap<K,V> |
HazelcastInstance.getReplicatedMap(String name)
Creates or returns the replicated map instance with the specified name.
|
Modifier and Type | Method and Description |
---|---|
<K,V> ReplicatedMap<K,V> |
JetInstance.getReplicatedMap(String name)
Deprecated.
since 5.0
Use
HazelcastInstance.getReplicatedMap(String) instead. |
Modifier and Type | Method and Description |
---|---|
static <K,V> ServiceFactory<?,ReplicatedMap<K,V>> |
ServiceFactories.replicatedMapService(String mapName)
Returns a factory that provides a
ReplicatedMap as the service
object. |
Modifier and Type | Method and 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 supplied
ReplicatedMap 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) |
Copyright © 2021 Hazelcast, Inc.. All rights reserved.