Interface OutputWriter

    • Method Detail

      • write

        void write​(java.lang.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
      • writeLatencymark

        void writeLatencymark​(LatencyMark latencymark)
        Writes latencymark to all edges. It does not consider buffered time in windows. transfer to the next task immediately.
        Parameters:
        latencymark - latencymark
      • getWrittenBytes

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

        void close()