Package | Description |
---|---|
com.hazelcast.console |
This package contains classes related to ConsoleApp
|
com.hazelcast.core |
Provides core API interfaces/classes.
|
com.hazelcast.instance |
This package contains Hazelcast Instance functionality.
|
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.
|
com.hazelcast.mapreduce |
This package contains the MapReduce API definition for Hazelcast.
All map reduce operations running in a distributed manner inside the active Hazelcast cluster. |
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> |
HazelcastInstanceProxy.getMap(String name) |
<K,V> IMap<K,V> |
HazelcastInstanceImpl.getMap(String name) |
Modifier and Type | Interface and Description |
---|---|
interface |
IMapJet<K,V>
A distributed, in-memory concurrent map implementation.
|
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<? super K,? super V> predicate,
FunctionEx<? super Map.Entry<K,V>,? extends T> projection)
Convenience for
Sources.map(IMap, Predicate, Projection) which uses a
FunctionEx as the projection function. |
static <T,K,V> BatchSource<T> |
Sources.map(IMap<? extends K,? extends V> map,
Predicate<? super K,? super 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.Entry s it receives into the 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, PredicateEx,
FunctionEx, JournalInitialPosition)
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,
PredicateEx<? super EventJournalMapEvent<K,V>> predicateFn,
FunctionEx<? super EventJournalMapEvent<K,V>,? extends T> projectionFn,
JournalInitialPosition initialPos)
Returns a source that will stream
EventJournalMapEvent s 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> 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 <V,R> BatchStage<R> |
BatchStageWithKey.mapUsingIMap(IMap<K,V> iMap,
BiFunctionEx<? super T,? super V,? extends R> mapFn) |
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 <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> BatchStage<R> |
BatchStage.mapUsingIMap(IMap<K,V> iMap,
FunctionEx<? super T,? extends K> lookupKeyFn,
BiFunctionEx<? super T,? super V,? extends R> mapFn) |
static <T,K,V> Sink<T> |
Sinks.mapWithEntryProcessor(IMap<? super K,? super V> map,
FunctionEx<? super T,? extends K> toKeyFn,
FunctionEx<? super T,? extends EntryProcessor<K,V>> toEntryProcessorFn)
Returns a sink that uses the items it receives to create
EntryProcessor s 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 |
---|---|
static <K,V> KeyValueSource<K,V> |
KeyValueSource.fromMap(IMap<? super K,? extends V> map)
Deprecated.
A helper method to build a KeyValueSource implementation based on the specified
IMap |
Copyright © 2019 Hazelcast, Inc.. All rights reserved.