Uses of Interface
com.hazelcast.map.IMap
Packages that use 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
Methods in com.hazelcast.console that return IMap -
Uses of IMap in com.hazelcast.core
Methods in com.hazelcast.core that return IMap -
Uses of IMap in com.hazelcast.jet
Methods in com.hazelcast.jet that return IMap -
Uses of IMap in com.hazelcast.jet.cdc
Methods in com.hazelcast.jet.cdc with parameters of type IMapModifier 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
Methods in com.hazelcast.jet.pipeline that return types with arguments of type IMapModifier and TypeMethodDescriptionstatic <K,V> ServiceFactory<?, IMap<K, V>> ServiceFactories.iMapService(String mapName) Returns a factory that provides anIMapas the service.Methods in com.hazelcast.jet.pipeline with parameters of type IMapModifier and TypeMethodDescriptionReturns a sink that putsMap.Entrys 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 HazelcastIMapand 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 onlyADDEDandUPDATEDevents 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 streamEventJournalMapEvents 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 suppliedIMapis 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 suppliedIMapusing 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 createEntryProcessors it submits to a HazelcastIMapwith 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.Entryas 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.Entryas 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
Methods in com.hazelcast.spring.cache that return IMapConstructors in com.hazelcast.spring.cache with parameters of type IMap
HazelcastInstance.getMap(String)instead.