TransformHierarchy (Google Cloud Dataflow SDK 1.9.1 API)

Google Cloud Dataflow SDK for Java, version 1.9.1

Class TransformHierarchy

  • public class TransformHierarchy
    extends Object
    Captures information about a collection of transformations and their associated PValues.
    • Constructor Detail

      • TransformHierarchy

        public TransformHierarchy()
        Create a TransformHierarchy containing a root node.
    • Method Detail

      • getCurrent

        public TransformTreeNode getCurrent()
        Returns the last TransformTreeNode on the stack.
      • pushNode

        public void pushNode(TransformTreeNode current)
        Add a TransformTreeNode to the stack.
      • popNode

        public void popNode()
        Removes the last TransformTreeNode from the stack.
      • addInput

        public void addInput(TransformTreeNode node,
                             PInput input)
        Adds an input to the given node.

        This forces the producing node to be finished.