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	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, Permission permission)	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	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	Description
<T_NEW> SourceBuilder<C>.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<C>.Stream<T_NEW>	SourceBuilder.Stream.fillBufferFn(BiConsumerEx<? super C,? super SourceBuilder.SourceBuffer<T_NEW>> fillBufferFn)