| Package | Description | 
|---|---|
| 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. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
IMap<Object,Object> | 
ConsoleApp.getMap()  | 
| Modifier and Type | Method and Description | 
|---|---|
<K,V> IMap<K,V> | 
HazelcastInstance.getMap(String name)
Creates or returns the distributed map instance with the specified name. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
<K,V> IMap<K,V> | 
JetInstance.getMap(String name)
Deprecated. 
 
since 5.0
 Use  
HazelcastInstance.getMap(String) instead. | 
| Modifier and Type | Method and 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 an  
IMap. | 
| Modifier and Type | Method and Description | 
|---|---|
static <K,V> ServiceFactory<?,IMap<K,V>> | 
ServiceFactories.iMapService(String mapName)
Returns a factory that provides an  
IMap as the service. | 
| Modifier and Type | Method and Description | 
|---|---|
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 Hazelcast  
IMap and emits them as Map.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 Hazelcast  
IMap. | 
static <K,V> Sink<Map.Entry<K,V>> | 
Sinks.map(IMap<? super K,? super V> map)
Returns a sink that puts  
Map.Entrys it receives into the given
 Hazelcast IMap. | 
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 Hazelcast  
IMap. | 
static <K,V> StreamSource<Map.Entry<K,V>> | 
Sources.mapJournal(IMap<? extends K,? extends V> map,
          JournalInitialPosition initialPos)
Convenience for  
Sources.mapJournal(IMap, JournalInitialPosition, FunctionEx, PredicateEx)
 which will pass only ADDED and UPDATED
 events and will project the event's key and new value into a Map.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 stream  
EventJournalMapEvents of the
 given Hazelcast IMap. | 
default <V,R> StreamStage<R> | 
StreamStageWithKey.mapUsingIMap(IMap<K,V> iMap,
            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 <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
 supplied  
IMap using the grouping key is performed
 and the result of the lookup is merged with the item and emitted. | 
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 <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 supplied
  
IMap 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)  | 
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 create  
EntryProcessors it submits to a Hazelcast IMap 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 Hazelcast  
IMap. | 
static <K,V> Sink<Map.Entry<K,V>> | 
Sinks.mapWithMerging(IMap<? super K,V> map,
              BinaryOperatorEx<V> mergeFn)
Convenience for  
Sinks.mapWithMerging(IMap, FunctionEx, FunctionEx,
 BinaryOperatorEx) with Map.Entry as input item. | 
static <K,V,E extends Map.Entry<K,V>> | 
Sinks.mapWithUpdating(IMap<? super K,? super V> map,
               BiFunctionEx<? super V,? super E,? extends V> updateFn)
Convenience for  
Sinks.mapWithUpdating(IMap, FunctionEx,
 BiFunctionEx) with Map.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 Hazelcast  
IMap. | 
| Modifier and Type | Method and Description | 
|---|---|
IMap<Object,Object> | 
HazelcastCache.getNativeCache()  | 
| Constructor and Description | 
|---|
HazelcastCache(IMap<Object,Object> map)  | 
Copyright © 2022 Hazelcast, Inc.. All rights reserved.