Min.MinLongFn (Google Cloud Dataflow SDK 1.9.1 API)

Google Cloud Dataflow SDK for Java, version 1.9.1

Warning: Dataflow SDK 1.x for Java is unsupported as of October 16, 2018. After August 12, 2020, Dataflow will not run jobs using Dataflow 1.x and below. See Migrating from Dataflow SDK 1.x for Java for migration guidance.

Note: If you are using Cloud Dataflow SDK version 2.x, see the Apache Beam API reference documentation.

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>

  A CombineFn that computes the minimum of a collection of Longs, 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
    MinLongFn()

  • Method Summary

    All Methods Instance Methods Concrete Methods 

    Modifier and Type	Method and Description
    TypeVariable<?>	getAccumTVariable() Returns the TypeVariable of AccumT.
    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 the TypeVariable of InputT.
    TypeVariable<?>	getOutputTVariable() Returns the TypeVariable of OutputT.

    • 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

    • Methods inherited from class java.lang.Object

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

• • Constructor Detail

    • MinLongFn

      public MinLongFn()

  • Method Detail

    • getCounter

      public com.google.cloud.dataflow.sdk.util.common.Counter<Long> getCounter(String name)

      Specified by:

      getCounter in interface com.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 interface CombineFnBase.GlobalCombineFn<InputT,AccumT,OutputT>

    • getInputTVariable

      public TypeVariable<?> getInputTVariable()

      Returns the TypeVariable of InputT.

    • getAccumTVariable

      public TypeVariable<?> getAccumTVariable()

      Returns the TypeVariable of AccumT.

    • getOutputTVariable

      public TypeVariable<?> getOutputTVariable()

      Returns the TypeVariable of OutputT.