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> DistributedPredicate<EventJournalMapEvent<K,V>> mapPutEvents()
Sources.mapJournal(java.lang.String, com.hazelcast.jet.function.DistributedPredicate<? super com.hazelcast.map.journal.EventJournalMapEvent<K, V>>, com.hazelcast.jet.function.DistributedFunction<? 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.DistributedPredicate<? super com.hazelcast.map.journal.EventJournalMapEvent<K, V>>, com.hazelcast.jet.function.DistributedFunction<? 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> DistributedPredicate<EventJournalCacheEvent<K,V>> cachePutEvents()
Sources.cacheJournal(java.lang.String, com.hazelcast.jet.function.DistributedPredicate<? super com.hazelcast.cache.journal.EventJournalCacheEvent<K, V>>, com.hazelcast.jet.function.DistributedFunction<? 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.DistributedPredicate<? super com.hazelcast.cache.journal.EventJournalCacheEvent<K, V>>, com.hazelcast.jet.function.DistributedFunction<? 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> DistributedFunction<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.DistributedPredicate<? super com.hazelcast.map.journal.EventJournalMapEvent<K, V>>, com.hazelcast.jet.function.DistributedFunction<? 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.DistributedPredicate<? super com.hazelcast.map.journal.EventJournalMapEvent<K, V>>, com.hazelcast.jet.function.DistributedFunction<? super com.hazelcast.map.journal.EventJournalMapEvent<K, V>, ? extends T>, com.hazelcast.jet.pipeline.JournalInitialPosition)
public static <K,V> DistributedFunction<EventJournalMapEvent<K,V>,V> mapEventNewValue()
EventJournalMapEvent
.Sources.mapJournal(java.lang.String, com.hazelcast.jet.function.DistributedPredicate<? super com.hazelcast.map.journal.EventJournalMapEvent<K, V>>, com.hazelcast.jet.function.DistributedFunction<? 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.DistributedPredicate<? super com.hazelcast.map.journal.EventJournalMapEvent<K, V>>, com.hazelcast.jet.function.DistributedFunction<? super com.hazelcast.map.journal.EventJournalMapEvent<K, V>, ? extends T>, com.hazelcast.jet.pipeline.JournalInitialPosition)
public static <K,V> DistributedFunction<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.DistributedPredicate<? super com.hazelcast.cache.journal.EventJournalCacheEvent<K, V>>, com.hazelcast.jet.function.DistributedFunction<? 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.DistributedPredicate<? super com.hazelcast.cache.journal.EventJournalCacheEvent<K, V>>, com.hazelcast.jet.function.DistributedFunction<? super com.hazelcast.cache.journal.EventJournalCacheEvent<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.Copyright © 2018 Hazelcast, Inc.. All rights reserved.