Class Interpreter.ListSink

  • All Implemented Interfaces:
    Sink
    Enclosing class:
    Interpreter

    private static class Interpreter.ListSink
    extends java.lang.Object
    implements Sink
    Implementation of Sink using a ArrayDeque.
    • Field Summary

      Fields 
      Modifier and Type Field Description
      (package private) java.util.ArrayDeque<Row> list  
    • Constructor Summary

      Constructors 
      Modifier Constructor Description
      private ListSink​(java.util.ArrayDeque<Row> list)  
    • Field Detail

      • list

        final java.util.ArrayDeque<Row> list
    • Constructor Detail

      • ListSink

        private ListSink​(java.util.ArrayDeque<Row> list)
    • Method Detail

      • send

        public void send​(Row row)
                  throws java.lang.InterruptedException
        Specified by:
        send in interface Sink
        Throws:
        java.lang.InterruptedException
      • end

        public void end()
                 throws java.lang.InterruptedException
        Specified by:
        end in interface Sink
        Throws:
        java.lang.InterruptedException
      • setSourceEnumerable

        public void setSourceEnumerable​(Enumerable<Row> enumerable)
                                 throws java.lang.InterruptedException
        Description copied from interface: Sink
        This method is temporary. It will be removed without notice.
        Specified by:
        setSourceEnumerable in interface Sink
        Throws:
        java.lang.InterruptedException