Uses of Interface
com.hazelcast.jet.pipeline.SinkStage

Packages that use SinkStage

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

Uses of SinkStage in com.hazelcast.jet.pipeline

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

Modifier and Type	Method	Description
SinkStage	SinkStage.setLocalParallelism(int localParallelism)
SinkStage	SinkStage.setName(String name)
SinkStage	GeneralStage.writeTo(Sink<? super T> sink)	Attaches a sink stage, one that accepts data but doesn't emit any.
<T> SinkStage	Pipeline.writeTo(Sink<? super T> sink, GeneralStage<? extends T> stage0, GeneralStage<? extends T> stage1, GeneralStage<? extends T>... moreStages)	Attaches the supplied sink to two or more pipeline stages.