Uses of Interface
com.hazelcast.jet.pipeline.SourceBuilder.TimestampedSourceBuffer

Packages that use SourceBuilder.TimestampedSourceBuffer

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.

Uses of SourceBuilder.TimestampedSourceBuffer in com.hazelcast.jet.core.processor

Method parameters in com.hazelcast.jet.core.processor with type arguments of type SourceBuilder.TimestampedSourceBuffer

Modifier and Type

Method and Description

static <C,T,S> ProcessorMetaSupplier

SourceProcessors.convenientTimestampedSourceP(FunctionEx<? super Processor.Context,? extends C> createFn, BiConsumerEx<? super C,? super SourceBuilder.TimestampedSourceBuffer<T>> fillBufferFn, EventTimePolicy<? super T> eventTimePolicy, FunctionEx<? super C,? extends S> createSnapshotFn, BiConsumerEx<? super C,? super List<S>> restoreSnapshotFn, ConsumerEx<? super C> destroyFn, int preferredLocalParallelism) Returns a supplier of processors for a source that the user can create using the SourceBuilder.

Uses of SourceBuilder.TimestampedSourceBuffer in com.hazelcast.jet.pipeline

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

Modifier and Type	Method and Description
<T_NEW> SourceBuilder.TimestampedStream<T_NEW>	SourceBuilder.TimestampedStream.fillBufferFn(BiConsumerEx<? super C,? super SourceBuilder.TimestampedSourceBuffer<T_NEW>> fillBufferFn) Sets the function that Jet will call whenever it needs more data from your source.