Uses of Interface
com.hazelcast.map.IMap
Package | Description |
---|---|
com.hazelcast.client.console |
This package contains ClientConsoleApp
|
com.hazelcast.console |
This package contains classes related to ConsoleApp
|
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.cdc |
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.
|
com.hazelcast.jet.pipeline |
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
|
com.hazelcast.spring.cache |
Contains Hazelcast cache classes related to Spring.
|
-
Uses of IMap in com.hazelcast.client.console
-
Uses of IMap in com.hazelcast.console
-
Uses of IMap in com.hazelcast.core
Methods in com.hazelcast.core that return IMap Modifier and Type Method Description <K, V> IMap<K,V>
HazelcastInstance. getMap(String name)
Creates or returns the distributed map instance with the specified name. -
Uses of IMap in com.hazelcast.jet
Methods in com.hazelcast.jet that return IMap Modifier and Type Method Description <K, V> IMap<K,V>
JetInstance. getMap(String name)
Returns the distributed map instance with the specified name. -
Uses of IMap in com.hazelcast.jet.cdc
Methods in com.hazelcast.jet.cdc with parameters of type IMap Modifier and Type Method Description static <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 IMap Modifier and Type Method Description static <K, V> ServiceFactory<?,IMap<K,V>>
ServiceFactories. iMapService(String mapName)
Returns a factory that provides anIMap
as the service.Methods in com.hazelcast.jet.pipeline with parameters of type IMap Modifier and Type Method Description static <K, V> Sink<Map.Entry<K,V>>
Sinks. map(IMap<? super K,? super V> map)
Returns 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>>
Sources. map(IMap<? extends K,? extends V> map)
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
.static <K, V> Sink<Map.Entry<K,V>>
Sinks. mapWithMerging(IMap<? super K,V> map, BinaryOperatorEx<V> mergeFn)
Convenience forSinks.mapWithMerging(IMap, FunctionEx, FunctionEx, BinaryOperatorEx)
withMap.Entry
as input item.static <K, V, E extends Map.Entry<K, V>>
Sink<E>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
Methods in com.hazelcast.spring.cache that return IMap Modifier and Type Method Description IMap<Object,Object>
HazelcastCache. getNativeCache()
Constructors in com.hazelcast.spring.cache with parameters of type IMap Constructor Description HazelcastCache(IMap<Object,Object> map)