Uses of Class
org.apache.nemo.common.ir.vertex.transform.LatencymarkEmitTransform
-
Packages that use LatencymarkEmitTransform Package Description org.apache.nemo.common.ir.vertex.transform org.apache.nemo.compiler.frontend.beam.transform -
-
Uses of LatencymarkEmitTransform in org.apache.nemo.common.ir.vertex.transform
Subclasses of LatencymarkEmitTransform in org.apache.nemo.common.ir.vertex.transform Modifier and Type Class Description class
StreamTransform<T>
ATransform
relays input data from upstream vertex to downstream vertex promptly. -
Uses of LatencymarkEmitTransform in org.apache.nemo.compiler.frontend.beam.transform
Subclasses of LatencymarkEmitTransform in org.apache.nemo.compiler.frontend.beam.transform Modifier and Type Class Description class
CreateViewTransform<I,O>
This transforms emits materialized data for each window.class
FlattenTransform<T>
Flatten transform implementation.class
SideInputTransform<T>
Side input transform implementation.class
WindowFnTransform<T,W extends org.apache.beam.sdk.transforms.windowing.BoundedWindow>
Windowing transform implementation.
-