Class BlockOutputWriter

  • All Implemented Interfaces:
    OutputWriter

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

      • write

        public void write​(Object element)
        Description copied from interface: OutputWriter
        Writes output element depending on the communication pattern of the edge.
        Specified by:
        write in interface OutputWriter
        Parameters:
        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
        Parameters:
        watermark - watermark
      • close

        public void close()
        Notifies that all writes for a block is end. Further write about a committed block will throw an exception.
        Specified by:
        close in interface OutputWriter