Google Cloud Dataflow SDK for Java, version 1.9.1
com.google.cloud.dataflow.sdk.transforms
Class Min.MinLongFn
- java.lang.Object
-
- com.google.cloud.dataflow.sdk.transforms.Combine.CombineFn<V,Combine.Holder<V>,V>
-
- com.google.cloud.dataflow.sdk.transforms.Combine.BinaryCombineFn<T>
-
- com.google.cloud.dataflow.sdk.transforms.Min.MinFn<Long>
-
- com.google.cloud.dataflow.sdk.transforms.Min.MinLongFn
-
- All Implemented Interfaces:
- CombineFnBase.GlobalCombineFn<Long,Combine.Holder<Long>,Long>, HasDisplayData, com.google.cloud.dataflow.sdk.util.common.CounterProvider<Long>, Serializable
- Enclosing class:
- Min
public static class Min.MinLongFn extends Min.MinFn<Long> implements com.google.cloud.dataflow.sdk.util.common.CounterProvider<Long>
ACombineFn
that computes the minimum of a collection ofLong
s, useful as an argument toCombine.globally(com.google.cloud.dataflow.sdk.transforms.SerializableFunction<java.lang.Iterable<V>, V>)
orCombine.perKey(com.google.cloud.dataflow.sdk.transforms.SerializableFunction<java.lang.Iterable<V>, V>)
.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor and Description MinLongFn()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method and Description TypeVariable<?>
getAccumTVariable()
Returns theTypeVariable
ofAccumT
.com.google.cloud.dataflow.sdk.util.common.Counter<Long>
getCounter(String name)
String
getIncompatibleGlobalWindowErrorMessage()
Returns the error message for not supported default values in Combine.globally().TypeVariable<?>
getInputTVariable()
Returns theTypeVariable
ofInputT
.TypeVariable<?>
getOutputTVariable()
Returns theTypeVariable
ofOutputT
.-
Methods inherited from class com.google.cloud.dataflow.sdk.transforms.Min.MinFn
apply, identity, naturalOrder, naturalOrder, of, of, populateDisplayData
-
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, compact, defaultValue, getOutputType
-
-
-
-
Method Detail
-
getCounter
public com.google.cloud.dataflow.sdk.util.common.Counter<Long> getCounter(String name)
- Specified by:
getCounter
in interfacecom.google.cloud.dataflow.sdk.util.common.CounterProvider<Long>
-
getIncompatibleGlobalWindowErrorMessage
public String getIncompatibleGlobalWindowErrorMessage()
Description copied from interface:CombineFnBase.GlobalCombineFn
Returns the error message for not supported default values in Combine.globally().- Specified by:
getIncompatibleGlobalWindowErrorMessage
in interfaceCombineFnBase.GlobalCombineFn<InputT,AccumT,OutputT>
-
getInputTVariable
public TypeVariable<?> getInputTVariable()
Returns theTypeVariable
ofInputT
.
-
getAccumTVariable
public TypeVariable<?> getAccumTVariable()
Returns theTypeVariable
ofAccumT
.
-
getOutputTVariable
public TypeVariable<?> getOutputTVariable()
Returns theTypeVariable
ofOutputT
.
-
-