CombineFnPartialTransform (Nemo Project 0.4 API)

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

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

CombineFnPartialTransform

public CombineFnPartialTransform(org.apache.beam.sdk.transforms.CombineFnBase.GlobalCombineFn<I,A,?> combineFn)

Constructor.

Parameters:: combineFn - combine function.

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 class java.lang.Object