Uses of Class
org.apache.nemo.common.punctuation.Watermark

Packages that use Watermark

Package	Description
org.apache.nemo.common.ir
org.apache.nemo.common.ir.vertex.transform
org.apache.nemo.common.punctuation
org.apache.nemo.compiler.frontend.beam.transform
org.apache.nemo.runtime.executor.datatransfer

Uses of Watermark in org.apache.nemo.common.ir

Methods in org.apache.nemo.common.ir with parameters of type Watermark

Modifier and Type	Method	Description
void	OutputCollector.emitWatermark(Watermark watermark)	Emit watermark to downstream vertices.

Uses of Watermark in org.apache.nemo.common.ir.vertex.transform

Methods in org.apache.nemo.common.ir.vertex.transform with parameters of type Watermark

Modifier and Type	Method	Description
void	NoWatermarkEmitTransform.onWatermark(Watermark watermark)
void	StreamTransform.onWatermark(Watermark watermark)
void	Transform.onWatermark(Watermark watermark)	On watermark received.

Uses of Watermark in org.apache.nemo.common.punctuation

Methods in org.apache.nemo.common.punctuation with parameters of type Watermark

Modifier and Type	Method	Description
int	Watermark.compareTo(Watermark o)

Uses of Watermark in org.apache.nemo.compiler.frontend.beam.transform

Methods in org.apache.nemo.compiler.frontend.beam.transform with parameters of type Watermark

Modifier and Type	Method	Description
void	GBKTransform.GBKOutputCollector.emitWatermark(Watermark watermark)	Emit watermark.
void	CreateViewTransform.onWatermark(Watermark inputWatermark)
void	DoFnTransform.onWatermark(Watermark watermark)
void	FlattenTransform.onWatermark(Watermark watermark)
void	GBKTransform.onWatermark(Watermark watermark)	Trigger timers that need to be fired at watermark and emit output watermark.
void	PushBackDoFnTransform.onWatermark(Watermark watermark)
void	SideInputTransform.onWatermark(Watermark watermark)
void	WindowFnTransform.onWatermark(Watermark watermark)

Uses of Watermark in org.apache.nemo.runtime.executor.datatransfer

Methods in org.apache.nemo.runtime.executor.datatransfer that return Watermark

Modifier and Type	Method	Description
Watermark	WatermarkWithIndex.getWatermark()

Methods in org.apache.nemo.runtime.executor.datatransfer with parameters of type Watermark

Modifier and Type	Method	Description
void	DataFetcherOutputCollector.emitWatermark(Watermark watermark)
void	OperatorVertexOutputCollector.emitWatermark(Watermark watermark)
void	OperatorWatermarkCollector.emitWatermark(Watermark watermark)
void	RunTimeMessageOutputCollector.emitWatermark(Watermark watermark)
void	InputWatermarkManager.trackAndEmitWatermarks(int edgeIndex, Watermark watermark)	This tracks the minimum input watermark among multiple input streams.
void	MultiInputWatermarkManager.trackAndEmitWatermarks(int edgeIndex, Watermark watermark)
void	SingleInputWatermarkManager.trackAndEmitWatermarks(int edgeIndex, Watermark watermark)	This just forwards watermarks to the next operator because it has one data stream.
void	BlockOutputWriter.writeWatermark(Watermark watermark)
void	OutputWriter.writeWatermark(Watermark watermark)	Writes watermarks to all edges.
void	PipeOutputWriter.writeWatermark(Watermark watermark)

Constructors in org.apache.nemo.runtime.executor.datatransfer with parameters of type Watermark

Constructor	Description
WatermarkWithIndex(Watermark watermark, int index)