Interface OutputWriter

    • Method Detail

      • write

        void write​(Object element)
        Writes output element depending on the communication pattern of the edge.
        Parameters:
        element - the element to write.
      • writeWatermark

        void writeWatermark​(Watermark watermark)
        Writes watermarks to all edges.
        Parameters:
        watermark - watermark
      • getWrittenBytes

        Optional<Long> getWrittenBytes()
        Returns:
        the total written bytes.
      • close

        void close()