Uses of Interface
com.hazelcast.jet.pipeline.SinkStage
Packages that use SinkStage
Package
Description
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 SinkStageModifier and TypeMethodDescriptionSinkStage.setLocalParallelism
(int localParallelism) 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.