Interface OutputWriter
-
- All Known Implementing Classes:
BlockOutputWriter
,PipeOutputWriter
public interface OutputWriter
Represents the output data transfer from a task.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
close()
java.util.Optional<java.lang.Long>
getWrittenBytes()
void
write(java.lang.Object element)
Writes output element depending on the communication pattern of the edge.void
writeLatencymark(LatencyMark latencymark)
Writes latencymark to all edges.void
writeWatermark(Watermark watermark)
Writes watermarks to all edges.
-
-
-
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()
-
-