com.google.cloud.dataflow.sdk.transforms

Class Combine.SimpleCombineFn<V>

java.lang.Object

com.google.cloud.dataflow.sdk.transforms.Combine.CombineFn<V,List<V>,V>

com.google.cloud.dataflow.sdk.transforms.Combine.IterableCombineFn<V>

com.google.cloud.dataflow.sdk.transforms.Combine.SimpleCombineFn<V>

All Implemented Interfaces:

Serializable

Enclosing class:

Combine

Deprecated.

@Deprecated
public static class Combine.SimpleCombineFn<V>
extends Combine.IterableCombineFn<V>

Converts a SerializableFunction from Iterable<V>s to Vs into a simple Combine.CombineFn over Vs.

@deprecated Use Combine.IterableCombineFn or the more space efficient Combine.BinaryCombineFn instead (which avoids buffering values).

See Also:

Serialized Form

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	SimpleCombineFn(SerializableFunction<Iterable<V>,V> combiner) Deprecated.

Method Summary

Modifier and Type	Method and Description
static <V> Combine.SimpleCombineFn<V>	of(SerializableFunction<Iterable<V>,V> combiner) Deprecated.

Methods inherited from class com.google.cloud.dataflow.sdk.transforms.Combine.IterableCombineFn

addInput, createAccumulator, extractOutput, mergeAccumulators, of

Methods inherited from class com.google.cloud.dataflow.sdk.transforms.Combine.CombineFn

apply, asKeyedFn, getAccumulatorCoder, getDefaultOutputCoder, getOutputType

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SimpleCombineFn

protected SimpleCombineFn(SerializableFunction<Iterable<V>,V> combiner)

Deprecated.

Method Detail

of

@Deprecated
public static <V> Combine.SimpleCombineFn<V> of(SerializableFunction<Iterable<V>,V> combiner)

Deprecated.

Returns a CombineFn that uses the given SerializableFunction to combine values.