org.apache.beam.runners.jet

Class DAGBuilder

java.lang.Object

org.apache.beam.runners.jet.DAGBuilder

public class DAGBuilder
extends java.lang.Object

Utility class for wiring up Jet DAGs based on Beam pipelines.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	DAGBuilder.WiringListener Listener that can be registered with a DAGBuilder in order to be notified when edges are being registered.

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait