Package org.apache.beam.runners.twister2.translators.functions

package org.apache.beam.runners.twister2.translators.functions

Internal implementation of the Beam runner for Twister2.

Related Packages

Package	Description
org.apache.beam.runners.twister2.translators	Internal implementation of the Beam runner for Twister2.
org.apache.beam.runners.twister2.translators.functions.internal	Internal implementation of the Beam runner for Twister2.
org.apache.beam.runners.twister2.translators.batch	Internal implementation of the Beam runner for Twister2.
org.apache.beam.runners.twister2.translators.streaming	Internal implementation of the Beam runner for Twister2.

Classes

Class	Description
AssignWindowsFunction<T>	Assign Windows function.
ByteToElemFunction<V>	ByteToWindow function.
ByteToWindowFunction<K,V>	ByteToWindow function.
ByteToWindowFunctionPrimitive<K,V>	ByteToWindow function.
DoFnFunction<OutputT,InputT>	DoFn function.
ElemToBytesFunction<V>	Map to tuple function.
GroupByWindowFunction<K,V,W extends BoundedWindow>	GroupBy window function.
ImpulseSource	A SourceFunc which executes the impulse transform contract.
MapToTupleFunction<K,V>	Map to tuple function.
OutputTagFilter<OutputT,InputT>	Output tag filter.
Twister2SinkFunction<T>	Sink Function that collects results.