Package | Description |
---|---|
com.hazelcast.jet |
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
|
com.hazelcast.jet.core.processor |
Apache Kafka reader/writer support for Hazelcast Jet.
|
com.hazelcast.jet.function |
Serializable variants of functional interfaces from
java.util.function . |
com.hazelcast.jet.stream |
java.util.stream implementation using Hazelcast Jet
|
Modifier and Type | Method and Description |
---|---|
static <K,V,T> Source<T> |
Sources.cacheJournal(String cacheName,
DistributedPredicate<com.hazelcast.cache.journal.EventJournalCacheEvent<K,V>> predicateFn,
DistributedFunction<com.hazelcast.cache.journal.EventJournalCacheEvent<K,V>,T> projectionFn,
boolean startFromLatestSequence)
Returns a source that will stream the
EventJournalCacheEvent
events of the Hazelcast ICache with the specified name. |
ComputeStage<E> |
ComputeStage.filter(DistributedPredicate<E> filterFn)
Attaches to this stage a filtering stage, one which applies the provided
predicate function to each input item to decide whether to pass the item
to the output or to discard it.
|
static <K,V,T> Source<T> |
Sources.mapJournal(String mapName,
DistributedPredicate<com.hazelcast.map.journal.EventJournalMapEvent<K,V>> predicateFn,
DistributedFunction<com.hazelcast.map.journal.EventJournalMapEvent<K,V>,T> projectionFn,
boolean startFromLatestSequence)
Returns a source that will stream the
EventJournalMapEvent
events of the Hazelcast IMap with the specified name. |
ComputeStage<E> |
ComputeStage.peek(DistributedPredicate<? super E> shouldLogFn,
DistributedFunction<? super E,String> toStringFn)
Adds a peeking layer to this compute stage which logs its output.
|
static <K,V,T> Source<T> |
Sources.remoteCacheJournal(String cacheName,
com.hazelcast.client.config.ClientConfig clientConfig,
DistributedPredicate<com.hazelcast.cache.journal.EventJournalCacheEvent<K,V>> predicateFn,
DistributedFunction<com.hazelcast.cache.journal.EventJournalCacheEvent<K,V>,T> projectionFn,
boolean startFromLatestSequence)
Returns a source that will stream the
EventJournalCacheEvent
events of the Hazelcast ICache with the specified name from a
remote cluster. |
static <K,V,T> Source<T> |
Sources.remoteMapJournal(String mapName,
com.hazelcast.client.config.ClientConfig clientConfig,
DistributedPredicate<com.hazelcast.map.journal.EventJournalMapEvent<K,V>> predicateFn,
DistributedFunction<com.hazelcast.map.journal.EventJournalMapEvent<K,V>,T> projectionFn,
boolean startFromLatestSequence)
Returns a source that will stream the
EventJournalMapEvent
events of the Hazelcast IMap with the specified name from a
remote cluster. |
Modifier and Type | Method and Description |
---|---|
static <T> DistributedSupplier<Processor> |
Processors.filterP(DistributedPredicate<T> predicate)
Returns a supplier of processors for a vertex that emits the same items
it receives, but only those that pass the given predicate.
|
static <T> DistributedSupplier<Processor> |
DiagnosticProcessors.peekInputP(DistributedFunction<T,String> toStringFn,
DistributedPredicate<T> shouldLogFn,
DistributedSupplier<Processor> wrapped)
Same as
peekInput(toStringFn, shouldLogFn, metaSupplier) ,
but accepts a DistributedSupplier of processors instead of a
meta-supplier. |
static <T> ProcessorMetaSupplier |
DiagnosticProcessors.peekInputP(DistributedFunction<T,String> toStringFn,
DistributedPredicate<T> shouldLogFn,
ProcessorMetaSupplier wrapped)
Returns a meta-supplier that wraps the provided one and adds a logging
layer to each processor it creates.
|
static <T> ProcessorSupplier |
DiagnosticProcessors.peekInputP(DistributedFunction<T,String> toStringFn,
DistributedPredicate<T> shouldLogFn,
ProcessorSupplier wrapped)
Same as
peekInput(toStringFn, shouldLogFn, metaSupplier) ,
but accepts a ProcessorSupplier instead of a meta-supplier. |
static <T> DistributedSupplier<Processor> |
DiagnosticProcessors.peekOutputP(DistributedFunction<T,String> toStringFn,
DistributedPredicate<T> shouldLogFn,
DistributedSupplier<Processor> wrapped)
Same as
peekOutput(toStringFn, shouldLogFn, metaSupplier) ,
but accepts a DistributedSupplier of processors instead of a
meta-supplier. |
static <T> ProcessorMetaSupplier |
DiagnosticProcessors.peekOutputP(DistributedFunction<T,String> toStringFn,
DistributedPredicate<T> shouldLogFn,
ProcessorMetaSupplier wrapped)
Returns a meta-supplier that wraps the provided one and adds a logging
layer to each processor it creates.
|
static <T> ProcessorSupplier |
DiagnosticProcessors.peekOutputP(DistributedFunction<T,String> toStringFn,
DistributedPredicate<T> shouldLogFn,
ProcessorSupplier wrapped)
Same as
peekOutput(toStringFn, shouldLogFn, metaSupplier) ,
but accepts a ProcessorSupplier instead of a meta-supplier. |
static <K,V> DistributedSupplier<Processor> |
DiagnosticProcessors.peekSnapshotP(DistributedFunction<Map.Entry<K,V>,String> toStringFn,
DistributedPredicate<Map.Entry<K,V>> shouldLogFn,
DistributedSupplier<Processor> wrapped)
Same as
peekSnapshot(toStringFn, shouldLogFn, metaSupplier) ,
but accepts a DistributedSupplier of processors instead of a
meta-supplier. |
static <K,V> ProcessorMetaSupplier |
DiagnosticProcessors.peekSnapshotP(DistributedFunction<Map.Entry<K,V>,String> toStringFn,
DistributedPredicate<Map.Entry<K,V>> shouldLogFn,
ProcessorMetaSupplier wrapped)
Returns a meta-supplier that wraps the provided one and adds a logging
layer to each processor it creates.
|
static <K,V> ProcessorSupplier |
DiagnosticProcessors.peekSnapshotP(DistributedFunction<Map.Entry<K,V>,String> toStringFn,
DistributedPredicate<Map.Entry<K,V>> shouldLogFn,
ProcessorSupplier wrapped)
Same as
peekSnapshot(toStringFn, shouldLogFn, metaSupplier) ,
but accepts a ProcessorSupplier instead of a meta-supplier. |
static <K,V,T> ProcessorMetaSupplier |
SourceProcessors.streamCacheP(String cacheName,
DistributedPredicate<com.hazelcast.cache.journal.EventJournalCacheEvent<K,V>> predicate,
DistributedFunction<com.hazelcast.cache.journal.EventJournalCacheEvent<K,V>,T> projection,
boolean startFromLatestSequence)
Returns a supplier of processors for
Sources.cacheJournal(String, DistributedPredicate, DistributedFunction, boolean) . |
static <K,V,T> ProcessorMetaSupplier |
SourceProcessors.streamMapP(String mapName,
DistributedPredicate<com.hazelcast.map.journal.EventJournalMapEvent<K,V>> predicate,
DistributedFunction<com.hazelcast.map.journal.EventJournalMapEvent<K,V>,T> projection,
boolean startFromLatestSequence)
Returns a supplier of processors for
Sources.mapJournal(String, DistributedPredicate, DistributedFunction, boolean) . |
static <K,V,T> ProcessorMetaSupplier |
SourceProcessors.streamRemoteCacheP(String cacheName,
com.hazelcast.client.config.ClientConfig clientConfig,
DistributedPredicate<com.hazelcast.cache.journal.EventJournalCacheEvent<K,V>> predicate,
DistributedFunction<com.hazelcast.cache.journal.EventJournalCacheEvent<K,V>,T> projection,
boolean startFromLatestSequence)
Returns a supplier of processors for
Sources.remoteCacheJournal(
String, ClientConfig, DistributedPredicate, DistributedFunction, boolean
) . |
static <K,V,T> ProcessorMetaSupplier |
SourceProcessors.streamRemoteMapP(String mapName,
com.hazelcast.client.config.ClientConfig clientConfig,
DistributedPredicate<com.hazelcast.map.journal.EventJournalMapEvent<K,V>> predicate,
DistributedFunction<com.hazelcast.map.journal.EventJournalMapEvent<K,V>,T> projection,
boolean startFromLatestSequence)
Returns a supplier of processors for
Sources.remoteMapJournal(
String, ClientConfig, DistributedPredicate, DistributedFunction, boolean
) . |
Modifier and Type | Method and Description |
---|---|
static <T> DistributedPredicate<T> |
DistributedFunctions.alwaysFalse()
Return sa predicate that always evaluates to
false . |
static <T> DistributedPredicate<T> |
DistributedFunctions.alwaysTrue()
Returns a predicate that always evaluates to
true . |
default DistributedPredicate<T> |
DistributedPredicate.and(DistributedPredicate<? super T> other)
Returns a composed predicate that represents a short-circuiting logical
AND of this predicate and another.
|
static <T> DistributedPredicate<T> |
DistributedPredicate.isEqual(Object targetRef)
Returns a predicate that tests if two arguments are equal according
to
Objects.equals(Object, Object) . |
default DistributedPredicate<T> |
DistributedPredicate.negate()
Returns a predicate that represents the logical negation of this
predicate.
|
default DistributedPredicate<T> |
DistributedPredicate.or(DistributedPredicate<? super T> other)
Returns a composed predicate that represents a short-circuiting logical
OR of this predicate and another.
|
Modifier and Type | Method and Description |
---|---|
default DistributedPredicate<T> |
DistributedPredicate.and(DistributedPredicate<? super T> other)
Returns a composed predicate that represents a short-circuiting logical
AND of this predicate and another.
|
DistributedOptional<T> |
DistributedOptional.filter(DistributedPredicate<? super T> predicate)
If a value is present, and the value matches the given predicate,
return an
Optional describing the value, otherwise return an
empty Optional . |
default DistributedPredicate<T> |
DistributedPredicate.or(DistributedPredicate<? super T> other)
Returns a composed predicate that represents a short-circuiting logical
OR of this predicate and another.
|
Modifier and Type | Method and Description |
---|---|
default boolean |
DistributedStream.allMatch(DistributedPredicate<? super T> predicate)
Returns whether all elements of this stream match the provided predicate.
|
default boolean |
DistributedStream.anyMatch(DistributedPredicate<? super T> predicate)
Returns whether any elements of this stream match the provided
predicate.
|
default DistributedStream<T> |
DistributedStream.filter(DistributedPredicate<? super T> predicate)
Returns a stream consisting of the elements of this stream that match
the given predicate.
|
default boolean |
DistributedStream.noneMatch(DistributedPredicate<? super T> predicate)
Returns whether no elements of this stream match the provided predicate.
|
static <T> java.util.stream.Collector<T,?,Map<Boolean,List<T>>> |
DistributedCollectors.partitioningBy(DistributedPredicate<? super T> predicate)
Returns a
DistributedCollector which partitions the input elements according
to a DistributedPredicate , and organizes them into a
Map<Boolean, List<T>> . |
static <T,D,A> java.util.stream.Collector<T,?,Map<Boolean,D>> |
DistributedCollectors.partitioningBy(DistributedPredicate<? super T> predicate,
DistributedCollector<? super T,A,D> downstream)
Returns a
DistributedCollector which partitions the input elements according
to a DistributedPredicate , reduces the values in each partition according to
another DistributedCollector , and organizes them into a
Map<Boolean, D> whose values are the result of the downstream
reduction. |
Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.