public final class Util extends Object
public static <K,V> Map.Entry<K,V> entry(K k, V v)
Map.Entry
with the given key and value.public static <K,V> PredicateEx<EventJournalMapEvent<K,V>> mapPutEvents()
Sources.mapJournal(java.lang.String, com.hazelcast.jet.function.PredicateEx<? super com.hazelcast.map.journal.EventJournalMapEvent<K, V>>, com.hazelcast.jet.function.FunctionEx<? super com.hazelcast.map.journal.EventJournalMapEvent<K, V>, ? extends T>, com.hazelcast.jet.pipeline.JournalInitialPosition)
and
Sources.remoteMapJournal(java.lang.String, com.hazelcast.client.config.ClientConfig, com.hazelcast.jet.function.PredicateEx<? super com.hazelcast.map.journal.EventJournalMapEvent<K, V>>, com.hazelcast.jet.function.FunctionEx<? super com.hazelcast.map.journal.EventJournalMapEvent<K, V>, ? extends T>, com.hazelcast.jet.pipeline.JournalInitialPosition)
that passes only
ADDED
and UPDATED
events.public static <K,V> PredicateEx<EventJournalCacheEvent<K,V>> cachePutEvents()
Sources.cacheJournal(java.lang.String, com.hazelcast.jet.function.PredicateEx<? super com.hazelcast.cache.journal.EventJournalCacheEvent<K, V>>, com.hazelcast.jet.function.FunctionEx<? super com.hazelcast.cache.journal.EventJournalCacheEvent<K, V>, ? extends T>, com.hazelcast.jet.pipeline.JournalInitialPosition)
and
Sources.remoteCacheJournal(java.lang.String, com.hazelcast.client.config.ClientConfig, com.hazelcast.jet.function.PredicateEx<? super com.hazelcast.cache.journal.EventJournalCacheEvent<K, V>>, com.hazelcast.jet.function.FunctionEx<? super com.hazelcast.cache.journal.EventJournalCacheEvent<K, V>, ? extends T>, com.hazelcast.jet.pipeline.JournalInitialPosition)
that passes only
CREATED
and UPDATED
events.public static <K,V> FunctionEx<EventJournalMapEvent<K,V>,Map.Entry<K,V>> mapEventToEntry()
EventJournalMapEvent
to a
Map.Entry
using the event's new value as a value.Sources.mapJournal(java.lang.String, com.hazelcast.jet.function.PredicateEx<? super com.hazelcast.map.journal.EventJournalMapEvent<K, V>>, com.hazelcast.jet.function.FunctionEx<? super com.hazelcast.map.journal.EventJournalMapEvent<K, V>, ? extends T>, com.hazelcast.jet.pipeline.JournalInitialPosition)
,
Sources.remoteMapJournal(java.lang.String, com.hazelcast.client.config.ClientConfig, com.hazelcast.jet.function.PredicateEx<? super com.hazelcast.map.journal.EventJournalMapEvent<K, V>>, com.hazelcast.jet.function.FunctionEx<? super com.hazelcast.map.journal.EventJournalMapEvent<K, V>, ? extends T>, com.hazelcast.jet.pipeline.JournalInitialPosition)
public static <K,V> FunctionEx<EventJournalMapEvent<K,V>,V> mapEventNewValue()
EventJournalMapEvent
.Sources.mapJournal(java.lang.String, com.hazelcast.jet.function.PredicateEx<? super com.hazelcast.map.journal.EventJournalMapEvent<K, V>>, com.hazelcast.jet.function.FunctionEx<? super com.hazelcast.map.journal.EventJournalMapEvent<K, V>, ? extends T>, com.hazelcast.jet.pipeline.JournalInitialPosition)
,
Sources.remoteMapJournal(java.lang.String, com.hazelcast.client.config.ClientConfig, com.hazelcast.jet.function.PredicateEx<? super com.hazelcast.map.journal.EventJournalMapEvent<K, V>>, com.hazelcast.jet.function.FunctionEx<? super com.hazelcast.map.journal.EventJournalMapEvent<K, V>, ? extends T>, com.hazelcast.jet.pipeline.JournalInitialPosition)
public static <K,V> FunctionEx<EventJournalCacheEvent<K,V>,Map.Entry<K,V>> cacheEventToEntry()
EventJournalCacheEvent
to a
Map.Entry
using the event's new value as a value.Sources.cacheJournal(java.lang.String, com.hazelcast.jet.function.PredicateEx<? super com.hazelcast.cache.journal.EventJournalCacheEvent<K, V>>, com.hazelcast.jet.function.FunctionEx<? super com.hazelcast.cache.journal.EventJournalCacheEvent<K, V>, ? extends T>, com.hazelcast.jet.pipeline.JournalInitialPosition)
,
Sources.remoteCacheJournal(java.lang.String, com.hazelcast.client.config.ClientConfig, com.hazelcast.jet.function.PredicateEx<? super com.hazelcast.cache.journal.EventJournalCacheEvent<K, V>>, com.hazelcast.jet.function.FunctionEx<? super com.hazelcast.cache.journal.EventJournalCacheEvent<K, V>, ? extends T>, com.hazelcast.jet.pipeline.JournalInitialPosition)
public static <K,V> FunctionEx<EventJournalCacheEvent<K,V>,V> cacheEventNewValue()
EventJournalCacheEvent
.Sources.mapJournal(java.lang.String, com.hazelcast.jet.function.PredicateEx<? super com.hazelcast.map.journal.EventJournalMapEvent<K, V>>, com.hazelcast.jet.function.FunctionEx<? super com.hazelcast.map.journal.EventJournalMapEvent<K, V>, ? extends T>, com.hazelcast.jet.pipeline.JournalInitialPosition)
,
Sources.remoteMapJournal(java.lang.String, com.hazelcast.client.config.ClientConfig, com.hazelcast.jet.function.PredicateEx<? super com.hazelcast.map.journal.EventJournalMapEvent<K, V>>, com.hazelcast.jet.function.FunctionEx<? super com.hazelcast.map.journal.EventJournalMapEvent<K, V>, ? extends T>, com.hazelcast.jet.pipeline.JournalInitialPosition)
public static String idToString(long id)
long
job or execution ID to a string representation.
Currently it is an unsigned 16-digit hex number.public static long idFromString(String str)
idToString(long)
.
The method is lenient: if the string doesn't match the structure
output by idToString
or if the string is null, it will return
-1.
public static <T> CompletableFuture<T> toCompletableFuture(ICompletableFuture<T> future)
ICompletableFuture
into Java's standard
CompletableFuture
.future
- the future to wrapCompletableFuture
wrapping the given oneCopyright © 2019 Hazelcast, Inc.. All rights reserved.