Uses of Class
com.hazelcast.jet.core.WatermarkGenerationParams

Packages that use WatermarkGenerationParams

Package	Description
com.hazelcast.jet.core	Jet's Core API.
com.hazelcast.jet.core.processor	Contains static utility classes with factories of Jet processors.
com.hazelcast.jet.kafka	Apache Kafka reader/writer support for Hazelcast Jet.
com.hazelcast.jet.pipeline	The Pipeline API is Jet's high-level API to build and execute distributed computation jobs.

Uses of WatermarkGenerationParams in com.hazelcast.jet.core

Methods in com.hazelcast.jet.core that return WatermarkGenerationParams

Modifier and Type	Method and Description
static <T> WatermarkGenerationParams<T>	WatermarkGenerationParams.noWatermarks() Returns watermark generation parameters that result in no watermarks being emitted.
WatermarkGenerationParams<T>	WatermarkGenerationParams.withEmitPolicy(WatermarkEmissionPolicy emitPolicy) Returns new instance with emit policy replaced with the given argument.
static <T> WatermarkGenerationParams<T>	WatermarkGenerationParams.wmGenParams(DistributedToLongFunction<? super T> timestampFn, DistributedObjLongBiFunction<? super T,?> wrapFn, DistributedSupplier<? extends WatermarkPolicy> newWmPolicyFn, WatermarkEmissionPolicy wmEmitPolicy, long idleTimeoutMillis) Creates and returns new watermark generation parameters.
static <T> WatermarkGenerationParams<T>	WatermarkGenerationParams.wmGenParams(DistributedToLongFunction<? super T> timestampFn, DistributedSupplier<? extends WatermarkPolicy> wmPolicy, WatermarkEmissionPolicy wmEmitPolicy, long idleTimeoutMillis) Creates and returns a watermark generation parameters object.

Constructors in com.hazelcast.jet.core with parameters of type WatermarkGenerationParams

Constructor and Description
WatermarkSourceUtil(WatermarkGenerationParams<? super T> params) A constructor.

Uses of WatermarkGenerationParams in com.hazelcast.jet.core.processor

Methods in com.hazelcast.jet.core.processor with parameters of type WatermarkGenerationParams

Modifier and Type	Method and Description
static <S,T> ProcessorMetaSupplier	SourceProcessors.convenientTimestampedSourceP(DistributedFunction<? super Processor.Context,? extends S> createFn, DistributedBiConsumer<? super S,? super SourceBuilder.TimestampedSourceBuffer<T>> fillBufferFn, WatermarkGenerationParams<? super com.hazelcast.jet.impl.JetEvent<T>> wmParams, DistributedConsumer<? super S> destroyFn, int preferredLocalParallelism) Returns a supplier of processors for a source that the user can create using the SourceBuilder.
static <T> DistributedSupplier<Processor>	Processors.insertWatermarksP(WatermarkGenerationParams<? super T> wmGenParams) Returns a supplier of processors for a vertex that inserts watermark items into the stream.
static <T,K,V> ProcessorMetaSupplier	SourceProcessors.streamCacheP(String cacheName, DistributedPredicate<? super EventJournalCacheEvent<K,V>> predicateFn, DistributedFunction<? super EventJournalCacheEvent<K,V>,? extends T> projectionFn, JournalInitialPosition initialPos, WatermarkGenerationParams<? super T> wmGenParams) Returns a supplier of processors for Sources.cacheJournal(String, DistributedPredicate, DistributedFunction, JournalInitialPosition).
static <K,V> ProcessorMetaSupplier	SourceProcessors.streamCacheP(String cacheName, JournalInitialPosition initialPos, WatermarkGenerationParams<? super Map.Entry<K,V>> wmGenParams) Returns a supplier of processors for Sources.cacheJournal(String, JournalInitialPosition).
static <T,K,V> ProcessorMetaSupplier	SourceProcessors.streamMapP(String mapName, DistributedPredicate<? super EventJournalMapEvent<K,V>> predicateFn, DistributedFunction<? super EventJournalMapEvent<K,V>,? extends T> projectionFn, JournalInitialPosition initialPos, WatermarkGenerationParams<? super T> wmGenParams) Returns a supplier of processors for Sources.mapJournal(String, DistributedPredicate, DistributedFunction, JournalInitialPosition).
static <K,V> ProcessorMetaSupplier	SourceProcessors.streamMapP(String mapName, JournalInitialPosition initialPos, WatermarkGenerationParams<? super Map.Entry<K,V>> wmGenParams) Returns a supplier of processors for Sources.mapJournal(String, JournalInitialPosition) )}.
static <T,K,V> ProcessorMetaSupplier	SourceProcessors.streamRemoteCacheP(String cacheName, ClientConfig clientConfig, DistributedPredicate<? super EventJournalCacheEvent<K,V>> predicateFn, DistributedFunction<? super EventJournalCacheEvent<K,V>,? extends T> projectionFn, JournalInitialPosition initialPos, WatermarkGenerationParams<? super T> wmGenParams) Returns a supplier of processors for Sources.remoteCacheJournal(String, ClientConfig, DistributedPredicate, DistributedFunction, JournalInitialPosition).
static <K,V> ProcessorMetaSupplier	SourceProcessors.streamRemoteCacheP(String cacheName, ClientConfig clientConfig, JournalInitialPosition initialPos, WatermarkGenerationParams<? super Map.Entry<K,V>> wmGenParams) Returns a supplier of processors for Sources.remoteCacheJournal(String, ClientConfig, JournalInitialPosition).
static <T,K,V> ProcessorMetaSupplier	SourceProcessors.streamRemoteMapP(String mapName, ClientConfig clientConfig, DistributedPredicate<? super EventJournalMapEvent<K,V>> predicateFn, DistributedFunction<? super EventJournalMapEvent<K,V>,? extends T> projectionFn, JournalInitialPosition initialPos, WatermarkGenerationParams<? super T> wmGenParams) Returns a supplier of processors for Sources.remoteMapJournal(String, ClientConfig, DistributedPredicate, DistributedFunction, JournalInitialPosition).
static <K,V> ProcessorMetaSupplier	SourceProcessors.streamRemoteMapP(String mapName, ClientConfig clientConfig, JournalInitialPosition initialPos, WatermarkGenerationParams<? super Map.Entry<K,V>> wmGenParams) Returns a supplier of processors for Sources.remoteMapJournal(String, ClientConfig, JournalInitialPosition).

Uses of WatermarkGenerationParams in com.hazelcast.jet.kafka

Methods in com.hazelcast.jet.kafka with parameters of type WatermarkGenerationParams

Modifier and Type	Method and Description
static <K,V,T> ProcessorMetaSupplier	KafkaProcessors.streamKafkaP(Properties properties, DistributedFunction<? super org.apache.kafka.clients.consumer.ConsumerRecord<K,V>,? extends T> projectionFn, WatermarkGenerationParams<? super T> wmGenParams, String... topics) Returns a supplier of processors for KafkaSources.kafka(Properties, DistributedFunction, String...).

Uses of WatermarkGenerationParams in com.hazelcast.jet.pipeline

Method parameters in com.hazelcast.jet.pipeline with type arguments of type WatermarkGenerationParams

Modifier and Type	Method and Description
static <T> StreamSource<T>	Sources.streamFromProcessorWithWatermarks(String sourceName, Function<WatermarkGenerationParams<? super T>,ProcessorMetaSupplier> metaSupplierFn) Returns an unbounded (event stream) source that will use the supplied function to create processor meta-suppliers as required by the Core API.