Uses of Class
com.hazelcast.jet.pipeline.SinkBuilder

Packages that use SinkBuilder

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

Uses of SinkBuilder in com.hazelcast.jet.pipeline

Methods in com.hazelcast.jet.pipeline that return SinkBuilder

Modifier and Type	Method	Description
SinkBuilder<C,T>	SinkBuilder.destroyFn(ConsumerEx<? super C> destroyFn)	Sets the function that will destroy the context object and perform any cleanup.
SinkBuilder<C,T>	SinkBuilder.flushFn(ConsumerEx<? super C> flushFn)	Sets the function that implements the sink's flushing behavior.
SinkBuilder<C,T>	SinkBuilder.permission(Permission permission)	Sets the the permission required to use this sink when the security is enabled.
SinkBuilder<C,T>	SinkBuilder.preferredLocalParallelism(int preferredLocalParallelism)	Sets the local parallelism of the sink.
<T_NEW> SinkBuilder<C,T_NEW>	SinkBuilder.receiveFn(BiConsumerEx<? super C,? super T_NEW> receiveFn)	Sets the function Jet will call upon receiving an item.
static <C> SinkBuilder<C,Void>	SinkBuilder.sinkBuilder(String name, FunctionEx<Processor.Context,? extends C> createFn)	Returns a builder object that offers a step-by-step fluent API to build a custom Sink for the Pipeline API.