Class TraversalBuilder$


  • public class TraversalBuilder$
    extends java.lang.Object
    INTERNAL API
    • Field Detail

      • MODULE$

        public static final TraversalBuilder$ MODULE$
        Static reference to the singleton instance of this Scala object.
    • Constructor Detail

      • TraversalBuilder$

        public TraversalBuilder$()
    • Method Detail

      • initShape

        public void initShape​(Shape shape)
        INTERNAL API

        Assign ports their id, which is their position inside the Shape. This is used both by the GraphInterpreter and the layout system here.

        Parameters:
        shape - (undocumented)
      • empty

        public TraversalBuilder empty​(Attributes attributes)
        INTERNAL API
        Parameters:
        attributes - (undocumented)
        Returns:
        (undocumented)
      • empty$default$1

        public Attributes empty$default$1()
      • atomic

        public TraversalBuilder atomic​(StreamLayout.AtomicModule<Shape,​java.lang.Object> module,
                                       Attributes attributes)
        INTERNAL API

        Create a generic traversal builder starting from an atomic module.

        Parameters:
        module - (undocumented)
        attributes - (undocumented)
        Returns:
        (undocumented)
      • printTraversal

        public void printTraversal​(Traversal t,
                                   int indent)
        INTERNAL API
        Parameters:
        t - (undocumented)
        indent - (undocumented)
      • printTraversal$default$2

        public int printTraversal$default$2()
      • printWiring

        public int printWiring​(Traversal t,
                               int baseSlot)
        INTERNAL API
        Parameters:
        t - (undocumented)
        baseSlot - (undocumented)
        Returns:
        (undocumented)
      • printWiring$default$2

        public int printWiring$default$2()
      • getSingleSource

        public <A> OptionVal<GraphStages.SingleSource<A>> getSingleSource​(Graph<SourceShape<A>,​?> graph)
        Try to find SingleSource or wrapped such. This is used as a performance optimization in FlattenMerge and possibly other places.
        Parameters:
        graph - (undocumented)
        Returns:
        (undocumented)