CombineFns.ComposeCombineFnBuilder (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, you can use unsupported SDKs temporarily while you upgrade your pipelines. For more information, see Using an unsupported SDK.

For information on migrating from the 1.x SDK, see Migrating from Dataflow SDK 1.x for Java.

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 CombineFns.ComposeCombineFnBuilder

• java.lang.Object
• • com.google.cloud.dataflow.sdk.transforms.CombineFns.ComposeCombineFnBuilder

• Enclosing class:

  CombineFns

  ---

  
  

  public static class CombineFns.ComposeCombineFnBuilder
  extends Object

  A builder class to construct a composed CombineFnBase.GlobalCombineFn.

• • Constructor Summary

    Constructors 

    Constructor and Description
    ComposeCombineFnBuilder()

  • Method Summary

    All Methods Instance Methods Concrete Methods 

    Modifier and Type	Method and Description
    <DataT,InputT,OutputT> CombineFns.ComposedCombineFn<DataT>	with(SimpleFunction<DataT,InputT> extractInputFn, Combine.CombineFn<InputT,?,OutputT> combineFn, TupleTag<OutputT> outputTag) Returns a CombineFns.ComposedCombineFn that can take additional GlobalCombineFns and apply them as a single combine function.
    <DataT,InputT,OutputT> CombineFns.ComposedCombineFnWithContext<DataT>	with(SimpleFunction<DataT,InputT> extractInputFn, CombineWithContext.CombineFnWithContext<InputT,?,OutputT> combineFnWithContext, TupleTag<OutputT> outputTag) Returns a CombineFns.ComposedCombineFnWithContext that can take additional GlobalCombineFns and apply them as a single combine function.

    • Methods inherited from class java.lang.Object

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

• • Constructor Detail

    • ComposeCombineFnBuilder

      public ComposeCombineFnBuilder()

  • Method Detail

    • with

      public <DataT,InputT,OutputT> CombineFns.ComposedCombineFn<DataT> with(SimpleFunction<DataT,InputT> extractInputFn,
                                                                             Combine.CombineFn<InputT,?,OutputT> combineFn,
                                                                             TupleTag<OutputT> outputTag)

      Returns a CombineFns.ComposedCombineFn that can take additional GlobalCombineFns and apply them as a single combine function.

      The CombineFns.ComposedCombineFn extracts inputs from DataT with the extractInputFn and combines them with the combineFn, and then it outputs each combined value with a TupleTag to a CombineFns.CoCombineResult.

    • with

      public <DataT,InputT,OutputT> CombineFns.ComposedCombineFnWithContext<DataT> with(SimpleFunction<DataT,InputT> extractInputFn,
                                                                                        CombineWithContext.CombineFnWithContext<InputT,?,OutputT> combineFnWithContext,
                                                                                        TupleTag<OutputT> outputTag)

      Returns a CombineFns.ComposedCombineFnWithContext that can take additional GlobalCombineFns and apply them as a single combine function.

      The CombineFns.ComposedCombineFnWithContext extracts inputs from DataT with the extractInputFn and combines them with the combineFnWithContext, and then it outputs each combined value with a TupleTag to a CombineFns.CoCombineResult.