Package org.apache.beam.runners.direct

Interface ExecutableGraph<ExecutableT,CollectionT>

public interface ExecutableGraph<ExecutableT,CollectionT>

The interface that enables querying of a graph of independently executable stages and the inputs and outputs of those stages.

Similar to QueryablePipeline. This exists primarily for legacy reasons, as an adapter interface between the 'native' and 'portable' execution models that the DirectRunner supports.

Method Summary

Modifier and Type	Method	Description
Collection<ExecutableT>	getExecutables()
Collection<ExecutableT>	getPerElementConsumers(CollectionT pCollection)
Collection<CollectionT>	getPerElementInputs(ExecutableT transform)
Collection<CollectionT>	getProduced(ExecutableT producer)
ExecutableT	getProducer(CollectionT collection)
Collection<ExecutableT>	getRootTransforms()

Method Details

getRootTransforms

Collection<ExecutableT> getRootTransforms()

getExecutables

Collection<ExecutableT> getExecutables()

getProducer

ExecutableT getProducer(CollectionT collection)

getProduced

Collection<CollectionT> getProduced(ExecutableT producer)

getPerElementInputs

Collection<CollectionT> getPerElementInputs(ExecutableT transform)

getPerElementConsumers

Collection<ExecutableT> getPerElementConsumers(CollectionT pCollection)