public interface Stage
pipeline
.
To build a pipeline, start with Pipeline.drawFrom(Source)
to
get the initial ComputeStage
and then use its methods to attach
further downstream stages. Terminate the pipeline by calling ComputeStage.drainTo(Sink)
, which will attach a SinkStage
.Modifier and Type | Method and Description |
---|---|
Pipeline |
getPipeline()
Returns the
Pipeline this stage belongs to. |
Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.