Uses of Interface
com.hazelcast.map.IMap
Package
Description
This package contains classes related to ConsoleApp
Provides core API interfaces/classes.
Hazelcast Jet is a distributed computation engine running on top of
Hazelcast IMDG technology.
Contains source/sink connectors that deal with Change Data Capture (CDC)
events from various databases as well as a generic connector for Debezium
CDC sources.
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
Contains Hazelcast cache classes related to Spring.
-
Uses of IMap in com.hazelcast.console
-
Uses of IMap in com.hazelcast.core
-
Uses of IMap in com.hazelcast.jet
-
Uses of IMap in com.hazelcast.jet.cdc
Modifier and TypeMethodDescriptionstatic <K,
V> Sink<ChangeRecord> CdcSinks.map
(IMap<? super K, ? super V> map, FunctionEx<? super ChangeRecord, ? extends K> keyFn, FunctionEx<? super ChangeRecord, ? extends V> valueFn) Returns a sink that applies the changes described by a Change Data Capture (CDC) stream to anIMap
. -
Uses of IMap in com.hazelcast.jet.pipeline
Modifier and TypeMethodDescriptionstatic <K,
V> ServiceFactory<?, IMap<K, V>> ServiceFactories.iMapService
(String mapName) Returns a factory that provides anIMap
as the service.Modifier and TypeMethodDescriptionReturns a sink that putsMap.Entry
s it receives into the given HazelcastIMap
.static <T,
K, V> Sink<T> Sinks.map
(IMap<? super K, ? super V> map, FunctionEx<? super T, ? extends K> toKeyFn, FunctionEx<? super T, ? extends V> toValueFn) Returns a sink that uses the supplied functions to extract the key and value with which to put to given HazelcastIMap
.static <K,
V> BatchSource<Map.Entry<K, V>> Returns a source that fetches entries from the given HazelcastIMap
and emits them asMap.Entry
.static <T,
K, V> BatchSource<T> Sources.map
(IMap<? extends K, ? extends V> map, Predicate<K, V> predicate, Projection<? super Map.Entry<K, V>, ? extends T> projection) Returns a source that fetches entries from the given HazelcastIMap
.static <K,
V> StreamSource<Map.Entry<K, V>> Sources.mapJournal
(IMap<? extends K, ? extends V> map, JournalInitialPosition initialPos) Convenience forSources.mapJournal(IMap, JournalInitialPosition, FunctionEx, PredicateEx)
which will pass onlyADDED
andUPDATED
events and will project the event's key and new value into aMap.Entry
.static <T,
K, V> StreamSource<T> Sources.mapJournal
(IMap<? extends K, ? extends V> map, JournalInitialPosition initialPos, FunctionEx<? super EventJournalMapEvent<K, V>, ? extends T> projectionFn, PredicateEx<? super EventJournalMapEvent<K, V>> predicateFn) Returns a source that will streamEventJournalMapEvent
s of the given HazelcastIMap
.default <K,
V, R> BatchStage<R> BatchStage.mapUsingIMap
(IMap<K, V> iMap, FunctionEx<? super T, ? extends K> lookupKeyFn, BiFunctionEx<? super T, ? super V, ? extends R> mapFn) default <V,
R> BatchStage<R> BatchStageWithKey.mapUsingIMap
(IMap<K, V> iMap, BiFunctionEx<? super T, ? super V, ? extends R> mapFn) default <K,
V, R> GeneralStage<R> GeneralStage.mapUsingIMap
(IMap<K, V> iMap, 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 suppliedIMap
is performed and the result of the lookup is merged with the item and emitted.default <V,
R> GeneralStage<R> GeneralStageWithKey.mapUsingIMap
(IMap<K, V> iMap, BiFunctionEx<? super T, ? super V, ? extends R> mapFn) Attaches a mapping stage where for each item a lookup in the suppliedIMap
using the grouping key is performed and the result of the lookup is merged with the item and emitted.default <K,
V, R> StreamStage<R> StreamStage.mapUsingIMap
(IMap<K, V> iMap, FunctionEx<? super T, ? extends K> lookupKeyFn, BiFunctionEx<? super T, ? super V, ? extends R> mapFn) default <V,
R> StreamStage<R> StreamStageWithKey.mapUsingIMap
(IMap<K, V> iMap, BiFunctionEx<? super T, ? super V, ? extends R> mapFn) 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 createEntryProcessor
s it submits to a HazelcastIMap
with the specified name.static <T,
K, V> Sink<T> Sinks.mapWithMerging
(IMap<? super K, ? super V> map, FunctionEx<? super T, ? extends K> toKeyFn, FunctionEx<? super T, ? extends V> toValueFn, BinaryOperatorEx<V> mergeFn) Returns a sink that uses the supplied functions to extract the key and value with which to update a HazelcastIMap
.Sinks.mapWithMerging
(IMap<? super K, V> map, BinaryOperatorEx<V> mergeFn) Convenience forSinks.mapWithMerging(IMap, FunctionEx, FunctionEx, BinaryOperatorEx)
withMap.Entry
as input item.Sinks.mapWithUpdating
(IMap<? super K, ? super V> map, BiFunctionEx<? super V, ? super E, ? extends V> updateFn) Convenience forSinks.mapWithUpdating(IMap, FunctionEx, BiFunctionEx)
withMap.Entry
as the input item.static <T,
K, V> Sink<T> Sinks.mapWithUpdating
(IMap<? super K, ? super V> map, FunctionEx<? super T, ? extends K> toKeyFn, BiFunctionEx<? super V, ? super T, ? extends V> updateFn) Returns a sink that uses the supplied key-extracting and value-updating functions to update a HazelcastIMap
. -
Uses of IMap in com.hazelcast.spring.cache
HazelcastInstance.getMap(String)
instead.