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	Description
static <C> SourceBuilder<C>.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<C>.Batch<T>	SourceBuilder.Batch.destroyFn(ConsumerEx<? super C> destroyFn)
SourceBuilder<C>.Batch<T>	SourceBuilder.Batch.distributed(int preferredLocalParallelism)
<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.
SourceBuilder<C>.Batch<T>	SourceBuilder.Batch.permission(Permission permission)