org.apache.beam.sdk.util.construction.graph

Interface PipelineNode

All Known Implementing Classes:

PipelineNode.PCollectionNode, PipelineNode.PTransformNode

public interface PipelineNode

A graph node which contains some pipeline element.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	PipelineNode.PCollectionNode A PipelineNode which contains a RunnerApi.PCollection.
static class	PipelineNode.PTransformNode A PipelineNode which contains a RunnerApi.PTransform.

Method Summary

Modifier and Type	Method and Description
java.lang.String	getId()
static PipelineNode.PCollectionNode	pCollection(java.lang.String id, org.apache.beam.model.pipeline.v1.RunnerApi.PCollection collection)
static PipelineNode.PTransformNode	pTransform(java.lang.String id, org.apache.beam.model.pipeline.v1.RunnerApi.PTransform transform)

Method Detail

pTransform

static PipelineNode.PTransformNode pTransform(java.lang.String id,
                                              org.apache.beam.model.pipeline.v1.RunnerApi.PTransform transform)

pCollection

static PipelineNode.PCollectionNode pCollection(java.lang.String id,
                                                org.apache.beam.model.pipeline.v1.RunnerApi.PCollection collection)

getId

java.lang.String getId()