Class CombineFnPartialTransform<K,I,A>
- java.lang.Object
-
- org.apache.nemo.common.ir.vertex.transform.NoWatermarkEmitTransform<org.apache.beam.sdk.util.WindowedValue<org.apache.beam.sdk.values.KV<K,I>>,org.apache.beam.sdk.util.WindowedValue<org.apache.beam.sdk.values.KV<K,A>>>
-
- org.apache.nemo.compiler.frontend.beam.transform.CombineFnPartialTransform<K,I,A>
-
- Type Parameters:
K
- Key type.I
- Input type.A
- Accum type.
- All Implemented Interfaces:
java.io.Serializable
,Transform<org.apache.beam.sdk.util.WindowedValue<org.apache.beam.sdk.values.KV<K,I>>,org.apache.beam.sdk.util.WindowedValue<org.apache.beam.sdk.values.KV<K,A>>>
public final class CombineFnPartialTransform<K,I,A> extends NoWatermarkEmitTransform<org.apache.beam.sdk.util.WindowedValue<org.apache.beam.sdk.values.KV<K,I>>,org.apache.beam.sdk.util.WindowedValue<org.apache.beam.sdk.values.KV<K,A>>>
Partially accumulates the given KVs(Key, Input) into KVs(Key, Accum). (Currently supports batch-style global windows only) TODO #263: Partial Combining for Beam Streaming TODO #264: Partial Combining with Beam SideInputs- See Also:
- Serialized Form
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.apache.nemo.common.ir.vertex.transform.Transform
Transform.Context
-
-
Constructor Summary
Constructors Constructor Description CombineFnPartialTransform(org.apache.beam.sdk.transforms.CombineFnBase.GlobalCombineFn<I,A,?> combineFn)
Constructor.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
Close the transform.void
onData(org.apache.beam.sdk.util.WindowedValue<org.apache.beam.sdk.values.KV<K,I>> element)
On data received.void
prepare(Transform.Context context, OutputCollector<org.apache.beam.sdk.util.WindowedValue<org.apache.beam.sdk.values.KV<K,A>>> oc)
Prepare the transform.java.lang.String
toString()
-
Methods inherited from class org.apache.nemo.common.ir.vertex.transform.NoWatermarkEmitTransform
onLatencymark, onWatermark
-
-
-
-
Method Detail
-
prepare
public void prepare(Transform.Context context, OutputCollector<org.apache.beam.sdk.util.WindowedValue<org.apache.beam.sdk.values.KV<K,A>>> oc)
Description copied from interface:Transform
Prepare the transform.- Parameters:
context
- of the transform.oc
- that collects outputs.
-
onData
public void onData(org.apache.beam.sdk.util.WindowedValue<org.apache.beam.sdk.values.KV<K,I>> element)
Description copied from interface:Transform
On data received.- Parameters:
element
- data received.
-
close
public void close()
Description copied from interface:Transform
Close the transform.
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-