Package | Description |
---|---|
com.hazelcast.jet.pipeline |
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
|
Modifier and Type | Method and 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.
|
Copyright © 2022 Hazelcast, Inc.. All rights reserved.