Uses of Interface
org.apache.nemo.common.ir.OutputCollector

Packages that use OutputCollector

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

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

Methods in org.apache.nemo.common.ir.vertex.transform that return OutputCollector

Modifier and Type	Method	Description
OutputCollector<O>	LatencymarkEmitTransform.getOutputCollector()	get OutputCollector.

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

Modifier and Type	Method	Description
void	LatencymarkEmitTransform.prepare(Transform.Context context, OutputCollector<O> oc)
void	MessageAggregatorTransform.prepare(Transform.Context context, OutputCollector<O> oc)
void	MessageGeneratorTransform.prepare(Transform.Context context, OutputCollector<Pair<K,V>> oc)
void	SignalTransform.prepare(Transform.Context context, OutputCollector<java.lang.Void> oc)
void	Transform.prepare(Transform.Context context, OutputCollector<O> outputCollector)	Prepare the transform.

Uses of OutputCollector in org.apache.nemo.common.test

Methods in org.apache.nemo.common.test with parameters of type OutputCollector

Modifier and Type	Method	Description
void	EmptyComponents.EmptyTransform.prepare(Transform.Context context, OutputCollector<O> outputCollector)

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

Classes in org.apache.nemo.compiler.frontend.beam.transform that implement OutputCollector

Modifier and Type	Class	Description
class	GBKTransform.GBKOutputCollector	Wrapper class for OutputCollector.

Methods in org.apache.nemo.compiler.frontend.beam.transform that return OutputCollector

Modifier and Type	Method	Description
OutputCollector<org.apache.beam.sdk.util.WindowedValue<OutputT>>	AbstractDoFnTransform.getOutputCollector()	Getter function for output collector.

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

Modifier and Type	Method	Description
void	AbstractDoFnTransform.prepare(Transform.Context context, OutputCollector<org.apache.beam.sdk.util.WindowedValue<OutputT>> oc)
void	CombineFnFinalTransform.prepare(Transform.Context context, OutputCollector<org.apache.beam.sdk.util.WindowedValue<org.apache.beam.sdk.values.KV<K,O>>> oc)
void	CombineFnPartialTransform.prepare(Transform.Context context, OutputCollector<org.apache.beam.sdk.util.WindowedValue<org.apache.beam.sdk.values.KV<K,A>>> oc)
void	GroupByKeyTransform.prepare(Transform.Context context, OutputCollector<org.apache.beam.sdk.util.WindowedValue<org.apache.beam.sdk.values.KV<java.lang.Object,java.util.List>>> oc)

Constructors in org.apache.nemo.compiler.frontend.beam.transform with parameters of type OutputCollector

Constructor	Description
GBKOutputCollector(OutputCollector oc)

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

Classes in org.apache.nemo.runtime.executor.datatransfer that implement OutputCollector

Modifier and Type	Class	Description
class	DataFetcherOutputCollector<O>	This collector receives data from DataFetcher and forwards it to the next operator.
class	OperatorVertexOutputCollector<O>	OutputCollector implementation.
class	OperatorWatermarkCollector	This class is used for collecting watermarks for an OperatorVertex.
class	RunTimeMessageOutputCollector<O>	OutputCollector for dynamic optimization data.

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

Constructor	Description
MultiInputWatermarkManager(int numEdges, OutputCollector<?> watermarkCollector)
SingleInputWatermarkManager(OutputCollector watermarkCollector)