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

Packages that use LatencyMark

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

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

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

Modifier and Type	Method	Description
void	OutputCollector.emitLatencymark(LatencyMark latencymark)	Emit latencymark to downstream vertices.

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

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

Modifier and Type	Method	Description
void	LatencymarkEmitTransform.onLatencymark(LatencyMark latencymark)
void	NoWatermarkEmitTransform.onLatencymark(LatencyMark latencymark)
void	Transform.onLatencymark(LatencyMark latencymark)	On latencymark received.

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

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

Modifier and Type	Method	Description
void	GBKTransform.GBKOutputCollector.emitLatencymark(LatencyMark latencymark)	Emit latencymark.
void	AbstractDoFnTransform.onLatencymark(LatencyMark latencymark)	On latencymark received.

Uses of LatencyMark in org.apache.nemo.runtime.common.metric

Methods in org.apache.nemo.runtime.common.metric that return LatencyMark

Modifier and Type	Method	Description
LatencyMark	LatencyMetric.getLatencymark()	Get the recorded latency mark.

Constructors in org.apache.nemo.runtime.common.metric with parameters of type LatencyMark

Constructor	Description
LatencyMetric(LatencyMark latencymark, long timestamp)	Constructor with the latencymark and timestamp.

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

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

Modifier and Type	Method	Description
void	DataFetcherOutputCollector.emitLatencymark(LatencyMark latencymark)
void	OperatorVertexOutputCollector.emitLatencymark(LatencyMark latencymark)
void	OperatorWatermarkCollector.emitLatencymark(LatencyMark latencymakr)
void	RunTimeMessageOutputCollector.emitLatencymark(LatencyMark latencymark)
void	BlockOutputWriter.writeLatencymark(LatencyMark latencymark)
void	OutputWriter.writeLatencymark(LatencyMark latencymark)	Writes latencymark to all edges.
void	PipeOutputWriter.writeLatencymark(LatencyMark latencymark)