Uses of Class
com.hazelcast.jet.pipeline.SourceBuilder.Batch

Packages that use SourceBuilder.Batch

Package	Description
com.hazelcast.jet.pipeline	The Pipeline API is Jet's high-level API to build and execute distributed computation jobs.

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

Methods in com.hazelcast.jet.pipeline that return SourceBuilder.Batch

Modifier and Type	Method and Description
static <C> SourceBuilder.Batch<Void>	SourceBuilder.batch(String name, FunctionEx<? super Processor.Context,? extends C> createFn) Returns a fluent-API builder with which you can create a batch source for a Jet pipeline.
SourceBuilder.Batch<T>	SourceBuilder.Batch.destroyFn(ConsumerEx<? super C> destroyFn)
SourceBuilder.Batch<T>	SourceBuilder.Batch.distributed(int preferredLocalParallelism)
<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.