com.hazelcast.jet

Interface Stage

All Known Subinterfaces:

ComputeStage<E>, SinkStage

public interface Stage

The basic element of a Jet 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.

Method Summary

Modifier and Type	Method and Description
Pipeline	getPipeline() Returns the Pipeline this stage belongs to.

Method Detail

getPipeline

Pipeline getPipeline()

Returns the Pipeline this stage belongs to.