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

Packages that use SourceBuilder.SourceBuffer

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.SourceBuffer in com.hazelcast.jet.core.processor

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

Modifier and Type

Method and Description

static <C,T,S> ProcessorMetaSupplier

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

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

Subinterfaces of SourceBuilder.SourceBuffer in com.hazelcast.jet.pipeline

Modifier and Type	Interface and Description
static interface	SourceBuilder.TimestampedSourceBuffer<T> The buffer object that the fillBufferFn gets on each call.

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

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