public interface ExecutableGraph<ExecutableT,CollectionT>
Similar to QueryablePipeline
. This exists primarily for legacy reasons, as an adapter
interface between the 'native' and 'portable' execution models that the DirectRunner supports.
Modifier and Type | Method and Description |
---|---|
java.util.Collection<ExecutableT> |
getExecutables() |
java.util.Collection<ExecutableT> |
getPerElementConsumers(CollectionT pCollection) |
java.util.Collection<CollectionT> |
getPerElementInputs(ExecutableT transform) |
java.util.Collection<CollectionT> |
getProduced(ExecutableT producer) |
ExecutableT |
getProducer(CollectionT collection) |
java.util.Collection<ExecutableT> |
getRootTransforms() |
java.util.Collection<ExecutableT> getRootTransforms()
java.util.Collection<ExecutableT> getExecutables()
ExecutableT getProducer(CollectionT collection)
java.util.Collection<CollectionT> getProduced(ExecutableT producer)
java.util.Collection<CollectionT> getPerElementInputs(ExecutableT transform)
java.util.Collection<ExecutableT> getPerElementConsumers(CollectionT pCollection)