Uses of Interface
org.apache.nemo.common.ir.vertex.transform.Transform.Context
-
Packages that use Transform.Context 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 -
-
Uses of Transform.Context in org.apache.nemo.common.ir.vertex.transform
Methods in org.apache.nemo.common.ir.vertex.transform with parameters of type Transform.Context 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 Transform.Context in org.apache.nemo.common.test
Methods in org.apache.nemo.common.test with parameters of type Transform.Context Modifier and Type Method Description void
EmptyComponents.EmptyTransform. prepare(Transform.Context context, OutputCollector<O> outputCollector)
-
Uses of Transform.Context in org.apache.nemo.compiler.frontend.beam.transform
Methods in org.apache.nemo.compiler.frontend.beam.transform with parameters of type Transform.Context 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)
-
Uses of Transform.Context in org.apache.nemo.runtime.executor
Classes in org.apache.nemo.runtime.executor that implement Transform.Context Modifier and Type Class Description class
TransformContextImpl
Transform Context Implementation.
-