Uses of Interface
org.apache.nemo.common.ir.vertex.transform.Transform

Packages that use Transform

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

Uses of Transform in org.apache.nemo.common.ir.vertex

Methods in org.apache.nemo.common.ir.vertex that return Transform

Modifier and Type	Method	Description
Transform	OperatorVertex.getTransform()

Constructors in org.apache.nemo.common.ir.vertex with parameters of type Transform

Constructor	Description
OperatorVertex(Transform t)	Constructor of OperatorVertex.

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

Classes in org.apache.nemo.common.ir.vertex.transform that implement Transform

Modifier and Type	Class	Description
class	LatencymarkEmitTransform<I,O>	This transform emits LatencyMark.
class	MessageAggregatorTransform<K,V,O>	A Transform that aggregates statistics generated by the MessageGeneratorTransform.
class	MessageGeneratorTransform<I,K,V>	A Transform for the message generator vertex.
class	NoWatermarkEmitTransform<I,O>	This transform does not emit watermarks.
class	SignalTransform	This class evokes run-time pass when there's no need to transfer any run-time information.
class	StreamTransform<T>	A Transform relays input data from upstream vertex to downstream vertex promptly.

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

Classes in org.apache.nemo.common.test that implement Transform

Modifier and Type	Class	Description
static class	EmptyComponents.EmptyTransform<I,O>	An empty transform.

Fields in org.apache.nemo.common.test declared as Transform

Modifier and Type	Field	Description
static Transform	EmptyComponents.EMPTY_TRANSFORM

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

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

Modifier and Type	Class	Description
class	AbstractDoFnTransform<InputT,InterT,OutputT>	This is a base class for Beam DoFn Transforms.
class	CombineFnFinalTransform<K,A,O>	Accumulates all of the partially accumulated KVs(Key, Accum) into KVs(Key, Output).
class	CombineFnPartialTransform<K,I,A>	Partially accumulates the given KVs(Key, Input) into KVs(Key, Accum).
class	CreateViewTransform<I,O>	This transforms emits materialized data for each window.
class	DoFnTransform<InputT,OutputT>	DoFn transform implementation when there is no side input.
class	FlattenTransform<T>	Flatten transform implementation.
class	GBKTransform<K,InputT,OutputT>	This transform executes GroupByKey transformation and CombinePerKey transformation when input data is unbounded or is not in a global window.
class	GroupByKeyTransform<I>	Group Beam KVs.
class	PushBackDoFnTransform<InputT,OutputT>	DoFn transform implementation with push backs for side inputs.
class	SideInputTransform<T>	Side input transform implementation.
class	WindowFnTransform<T,W extends org.apache.beam.sdk.transforms.windowing.BoundedWindow>	Windowing transform implementation.