Uses of Class
org.apache.nemo.common.ir.vertex.transform.NoWatermarkEmitTransform
-
Packages that use NoWatermarkEmitTransform Package Description org.apache.nemo.common.ir.vertex.transform org.apache.nemo.common.test org.apache.nemo.compiler.frontend.beam.transform -
-
Uses of NoWatermarkEmitTransform in org.apache.nemo.common.ir.vertex.transform
Subclasses of NoWatermarkEmitTransform in org.apache.nemo.common.ir.vertex.transform Modifier and Type Class Description class
MessageAggregatorTransform<K,V,O>
ATransform
that aggregates statistics generated by theMessageGeneratorTransform
.class
MessageGeneratorTransform<I,K,V>
ATransform
for the message generator vertex.class
SignalTransform
This class evokes run-time pass when there's no need to transfer any run-time information. -
Uses of NoWatermarkEmitTransform in org.apache.nemo.common.test
Subclasses of NoWatermarkEmitTransform in org.apache.nemo.common.test Modifier and Type Class Description static class
EmptyComponents.EmptyTransform<I,O>
An empty transform. -
Uses of NoWatermarkEmitTransform in org.apache.nemo.compiler.frontend.beam.transform
Subclasses of NoWatermarkEmitTransform in org.apache.nemo.compiler.frontend.beam.transform Modifier and Type Class Description 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
GroupByKeyTransform<I>
Group Beam KVs.
-