com.google.cloud.dataflow.sdk.transforms

Class Min.MinFn<NumT extends Comparable<NumT>>

java.lang.Object

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

com.google.cloud.dataflow.sdk.transforms.Combine.BinaryCombineFn<NumT>

com.google.cloud.dataflow.sdk.transforms.Min.MinFn<NumT>

Type Parameters:

NumT - the type of the Numbers being compared

All Implemented Interfaces:

Serializable

Direct Known Subclasses:

Min.MinDoubleFn, Min.MinIntegerFn, Min.MinLongFn

Enclosing class:

Min

public static class Min.MinFn<NumT extends Comparable<NumT>>
extends Combine.BinaryCombineFn<NumT>

A CombineFn that computes the minimum of a collection of elements of type N, useful as an argument to Combine.globally(com.google.cloud.dataflow.sdk.transforms.SerializableFunction<java.lang.Iterable<V>, V>) or Combine.perKey(com.google.cloud.dataflow.sdk.transforms.SerializableFunction<java.lang.Iterable<V>, V>).

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
MinFn(NumT initialValue) Constructs a combining function that computes the minimum over a collection of values of type N, given the largest value of type N, which is the identity value for the minimum operation over Ns.

Method Summary

Modifier and Type	Method and Description
NumT	apply(NumT a, NumT b) Applies the binary operation to the two operands, returning the result.
NumT	identity() Returns the value that should be used for the combine of the empty set.

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

addInput, createAccumulator, extractOutput, getAccumulatorCoder, getDefaultOutputCoder, mergeAccumulators

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

apply, asKeyedFn, getOutputType

Methods inherited from class java.lang.Object

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

Constructor Detail

MinFn

public MinFn(NumT initialValue)

Constructs a combining function that computes the minimum over a collection of values of type N, given the largest value of type N, which is the identity value for the minimum operation over Ns.

Method Detail

apply

public NumT apply(NumT a,
                  NumT b)

Description copied from class: Combine.BinaryCombineFn

Applies the binary operation to the two operands, returning the result.

Specified by:

apply in class Combine.BinaryCombineFn<NumT extends Comparable<NumT>>

identity

public NumT identity()

Description copied from class: Combine.BinaryCombineFn

Returns the value that should be used for the combine of the empty set.

Overrides:

identity in class Combine.BinaryCombineFn<NumT extends Comparable<NumT>>