Uses of Class
com.hazelcast.jet.pipeline.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. 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 customSink
for the Pipeline API.