com.google.cloud.dataflow.sdk.transforms

Class Max.MaxFn<N extends java.lang.Comparable<N>>

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<N>

com.google.cloud.dataflow.sdk.transforms.Max.MaxFn<N>

Type Parameters:

N - the type of the Numbers being compared

All Implemented Interfaces:

java.io.Serializable

Direct Known Subclasses:

Max.MaxDoubleFn, Max.MaxIntegerFn, Max.MaxLongFn

Enclosing class:

Max

public static class Max.MaxFn<N extends java.lang.Comparable<N>>
extends Combine.BinaryCombineFn<N>

A CombineFn that computes the maximum of a set 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
Max.MaxFn(N initialValue) Constructs a combining function that computes the maximum over a collection of values of type N, given the smallest value of type N, which is the identity value for the maximum operation over Ns.

Method Summary

Methods

Modifier and Type	Method and Description
N	apply(N a, N b) Applies the binary operation to the two operands, returning the result.
N	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

Methods inherited from class java.lang.Object

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

Constructor Detail

Max.MaxFn

public Max.MaxFn(N initialValue)

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

Method Detail

apply

public N apply(N a,
      N 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<N extends java.lang.Comparable<N>>

identity

public N 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<N extends java.lang.Comparable<N>>