Class PipeOutputWriter

  • All Implemented Interfaces:

    public final class PipeOutputWriter
    extends java.lang.Object
    implements OutputWriter
    Represents the output data transfer from a task.
    • Method Detail

      • write

        public void write​(java.lang.Object element)
        Writes output element.
        Specified by:
        write in interface OutputWriter
        element - the element to write.
      • writeWatermark

        public void writeWatermark​(Watermark watermark)
        Description copied from interface: OutputWriter
        Writes watermarks to all edges.
        Specified by:
        writeWatermark in interface OutputWriter
        watermark - watermark
      • writeLatencymark

        public void writeLatencymark​(LatencyMark latencymark)
        Description copied from interface: OutputWriter
        Writes latencymark to all edges. It does not consider buffered time in windows. transfer to the next task immediately.
        Specified by:
        writeLatencymark in interface OutputWriter
        latencymark - latencymark
      • getWrittenBytes

        public java.util.Optional<java.lang.Long> getWrittenBytes()
        Specified by:
        getWrittenBytes in interface OutputWriter
        the total written bytes.