Uses of Interface
com.hazelcast.jet.pipeline.SourceBuilder.TimestampedSourceBuffer
Package
Description
Contains static utility classes with factories of Jet processors.
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
Modifier and TypeMethodDescriptionstatic <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 theSourceBuilder
. -
Uses of SourceBuilder.TimestampedSourceBuffer in com.hazelcast.jet.pipeline
Modifier and TypeMethodDescription<T_NEW> SourceBuilder<C>.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.