Type Members

1.  class DataflowGraphRegistry extends AnyRef

   Tracks the DataflowGraphs that have been registered.

   Tracks the DataflowGraphs that have been registered. DataflowGraphs are registered by the PipelinesHandler when CreateDataflowGraph is called, and the PipelinesHandler also supports attaching flows/datasets to a graph.

2.  class PipelineEventSender extends Logging with AutoCloseable

   Handles sending pipeline events to the client in a background thread.

   Handles sending pipeline events to the client in a background thread. This prevents pipeline execution from blocking on streaming events.