Class AggregateNode.Grouping

  • Enclosing class:
    AggregateNode

    private class AggregateNode.Grouping
    extends java.lang.Object
    Internal class to track groupings.
    • Method Detail

      • send

        public void send​(Row row)
      • end

        public void end​(Sink sink)
                 throws java.lang.InterruptedException
        Throws:
        java.lang.InterruptedException