Package | Description |
---|---|
com.hazelcast.jet.core.processor |
Contains static utility classes with factories of Jet processors.
|
com.hazelcast.jet.pipeline |
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
|
Modifier and Type | Method and Description |
---|---|
static JournalInitialPosition |
JournalInitialPosition.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static JournalInitialPosition[] |
JournalInitialPosition.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
static <T,K,V> StreamSource<T> |
Sources.cacheJournal(String cacheName,
DistributedPredicate<? super EventJournalCacheEvent<K,V>> predicateFn,
DistributedFunction<? super EventJournalCacheEvent<K,V>,? extends T> projectionFn,
JournalInitialPosition initialPos)
Returns a source that will stream the
EventJournalCacheEvent
events of a Hazelcast ICache with the specified name. |
static <K,V> StreamSource<Map.Entry<K,V>> |
Sources.cacheJournal(String cacheName,
JournalInitialPosition initialPos)
Convenience for
Sources.cacheJournal(String, DistributedPredicate,
DistributedFunction, JournalInitialPosition)
which will pass only CREATED 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,
DistributedPredicate<? super EventJournalMapEvent<K,V>> predicateFn,
DistributedFunction<? super EventJournalMapEvent<K,V>,? extends T> projectionFn,
JournalInitialPosition initialPos)
Returns a source that will stream
EventJournalMapEvent s of 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, DistributedPredicate,
DistributedFunction, 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(String mapName,
DistributedPredicate<? super EventJournalMapEvent<K,V>> predicateFn,
DistributedFunction<? super EventJournalMapEvent<K,V>,? extends T> projectionFn,
JournalInitialPosition initialPos)
Returns a source that will stream
EventJournalMapEvent s of the
Hazelcast IMap with the specified name. |
static <K,V> StreamSource<Map.Entry<K,V>> |
Sources.mapJournal(String mapName,
JournalInitialPosition initialPos)
Convenience for
Sources.mapJournal(String, DistributedPredicate,
DistributedFunction, 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.remoteCacheJournal(String cacheName,
ClientConfig clientConfig,
DistributedPredicate<? super EventJournalCacheEvent<K,V>> predicateFn,
DistributedFunction<? super EventJournalCacheEvent<K,V>,? extends T> projectionFn,
JournalInitialPosition initialPos)
Returns a source that will stream the
EventJournalCacheEvent
events of the Hazelcast ICache with the specified name from a
remote cluster. |
static <K,V> StreamSource<Map.Entry<K,V>> |
Sources.remoteCacheJournal(String cacheName,
ClientConfig clientConfig,
JournalInitialPosition initialPos)
Convenience for
Sources.remoteCacheJournal(String, ClientConfig,
DistributedPredicate, DistributedFunction, JournalInitialPosition)
which will pass only
CREATED
and UPDATED
events and will project the event's key and new value
into a Map.Entry . |
static <T,K,V> StreamSource<T> |
Sources.remoteMapJournal(String mapName,
ClientConfig clientConfig,
DistributedPredicate<? super EventJournalMapEvent<K,V>> predicateFn,
DistributedFunction<? super EventJournalMapEvent<K,V>,? extends T> projectionFn,
JournalInitialPosition initialPos)
Returns a source that will stream the
EventJournalMapEvent
events of the Hazelcast IMap with the specified name from a
remote cluster. |
static <K,V> StreamSource<Map.Entry<K,V>> |
Sources.remoteMapJournal(String mapName,
ClientConfig clientConfig,
JournalInitialPosition initialPos)
Convenience for
Sources.remoteMapJournal(String, ClientConfig,
DistributedPredicate, DistributedFunction, JournalInitialPosition)
which will pass only ADDED
and UPDATED events and will
project the event's key and new value into a Map.Entry . |
Copyright © 2018 Hazelcast, Inc.. All rights reserved.