Package org.apache.beam.sdk.io.gcp.bigquery

Class MergeSchemaCombineFn

  • All Implemented Interfaces:
    java.io.Serializable, org.apache.beam.sdk.transforms.CombineFnBase.GlobalCombineFn<com.google.cloud.bigquery.storage.v1.TableSchema,​com.google.cloud.bigquery.storage.v1.TableSchema,​com.google.cloud.bigquery.storage.v1.TableSchema>, org.apache.beam.sdk.transforms.display.HasDisplayData
    public class MergeSchemaCombineFn
extends org.apache.beam.sdk.transforms.Combine.CombineFn<com.google.cloud.bigquery.storage.v1.TableSchema,​com.google.cloud.bigquery.storage.v1.TableSchema,​com.google.cloud.bigquery.storage.v1.TableSchema>
    A CombineFn to merge TableSchemas.
    See Also:
    Serialized Form

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      com.google.cloud.bigquery.storage.v1.TableSchema addInput​(com.google.cloud.bigquery.storage.v1.TableSchema accumulator, com.google.cloud.bigquery.storage.v1.TableSchema input)  
      com.google.cloud.bigquery.storage.v1.TableSchema createAccumulator()  
      com.google.cloud.bigquery.storage.v1.TableSchema extractOutput​(com.google.cloud.bigquery.storage.v1.TableSchema accumulator)  
      java.lang.reflect.TypeVariable<?> getAccumTVariable()  
      org.apache.beam.sdk.coders.Coder<com.google.cloud.bigquery.storage.v1.TableSchema> getAccumulatorCoder​(org.apache.beam.sdk.coders.CoderRegistry registry, org.apache.beam.sdk.coders.Coder<com.google.cloud.bigquery.storage.v1.TableSchema> inputCoder)  
      org.apache.beam.sdk.coders.Coder<com.google.cloud.bigquery.storage.v1.TableSchema> getDefaultOutputCoder​(org.apache.beam.sdk.coders.CoderRegistry registry, org.apache.beam.sdk.coders.Coder<com.google.cloud.bigquery.storage.v1.TableSchema> inputCoder)  
      java.lang.String getIncompatibleGlobalWindowErrorMessage()  
      java.lang.reflect.TypeVariable<?> getInputTVariable()  
      java.lang.reflect.TypeVariable<?> getOutputTVariable()  
      com.google.cloud.bigquery.storage.v1.TableSchema mergeAccumulators​(java.lang.Iterable<com.google.cloud.bigquery.storage.v1.TableSchema> accumulators)  
      void populateDisplayData​(org.apache.beam.sdk.transforms.display.DisplayData.Builder arg0)  

      • Methods inherited from class org.apache.beam.sdk.transforms.Combine.CombineFn

        apply, compact, defaultValue, getInputType, getOutputType

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • MergeSchemaCombineFn

        public MergeSchemaCombineFn()

    • Method Detail

      • createAccumulator

        public com.google.cloud.bigquery.storage.v1.TableSchema createAccumulator()
        Specified by:
        createAccumulator in class org.apache.beam.sdk.transforms.Combine.CombineFn<com.google.cloud.bigquery.storage.v1.TableSchema,​com.google.cloud.bigquery.storage.v1.TableSchema,​com.google.cloud.bigquery.storage.v1.TableSchema>

      • addInput

        public com.google.cloud.bigquery.storage.v1.TableSchema addInput​(com.google.cloud.bigquery.storage.v1.TableSchema accumulator,
                                                                 com.google.cloud.bigquery.storage.v1.TableSchema input)
        Specified by:
        addInput in class org.apache.beam.sdk.transforms.Combine.CombineFn<com.google.cloud.bigquery.storage.v1.TableSchema,​com.google.cloud.bigquery.storage.v1.TableSchema,​com.google.cloud.bigquery.storage.v1.TableSchema>

      • getAccumulatorCoder

        public org.apache.beam.sdk.coders.Coder<com.google.cloud.bigquery.storage.v1.TableSchema> getAccumulatorCoder​(org.apache.beam.sdk.coders.CoderRegistry registry,
                                                                                                              org.apache.beam.sdk.coders.Coder<com.google.cloud.bigquery.storage.v1.TableSchema> inputCoder)
        Specified by:
        getAccumulatorCoder in interface org.apache.beam.sdk.transforms.CombineFnBase.GlobalCombineFn<com.google.cloud.bigquery.storage.v1.TableSchema,​com.google.cloud.bigquery.storage.v1.TableSchema,​com.google.cloud.bigquery.storage.v1.TableSchema>

      • getDefaultOutputCoder

        public org.apache.beam.sdk.coders.Coder<com.google.cloud.bigquery.storage.v1.TableSchema> getDefaultOutputCoder​(org.apache.beam.sdk.coders.CoderRegistry registry,
                                                                                                                org.apache.beam.sdk.coders.Coder<com.google.cloud.bigquery.storage.v1.TableSchema> inputCoder)
                                                                                                         throws org.apache.beam.sdk.coders.CannotProvideCoderException
        Specified by:
        getDefaultOutputCoder in interface org.apache.beam.sdk.transforms.CombineFnBase.GlobalCombineFn<com.google.cloud.bigquery.storage.v1.TableSchema,​com.google.cloud.bigquery.storage.v1.TableSchema,​com.google.cloud.bigquery.storage.v1.TableSchema>
        Throws:
        org.apache.beam.sdk.coders.CannotProvideCoderException

      • mergeAccumulators

        public com.google.cloud.bigquery.storage.v1.TableSchema mergeAccumulators​(java.lang.Iterable<com.google.cloud.bigquery.storage.v1.TableSchema> accumulators)
        Specified by:
        mergeAccumulators in class org.apache.beam.sdk.transforms.Combine.CombineFn<com.google.cloud.bigquery.storage.v1.TableSchema,​com.google.cloud.bigquery.storage.v1.TableSchema,​com.google.cloud.bigquery.storage.v1.TableSchema>

      • extractOutput

        public com.google.cloud.bigquery.storage.v1.TableSchema extractOutput​(com.google.cloud.bigquery.storage.v1.TableSchema accumulator)
        Specified by:
        extractOutput in class org.apache.beam.sdk.transforms.Combine.CombineFn<com.google.cloud.bigquery.storage.v1.TableSchema,​com.google.cloud.bigquery.storage.v1.TableSchema,​com.google.cloud.bigquery.storage.v1.TableSchema>

      • getIncompatibleGlobalWindowErrorMessage

        public java.lang.String getIncompatibleGlobalWindowErrorMessage()
        Specified by:
        getIncompatibleGlobalWindowErrorMessage in interface org.apache.beam.sdk.transforms.CombineFnBase.GlobalCombineFn<InputT extends java.lang.Object,​AccumT extends java.lang.Object,​OutputT extends java.lang.Object>

      • getInputTVariable

        public java.lang.reflect.TypeVariable<?> getInputTVariable()

      • getAccumTVariable

        public java.lang.reflect.TypeVariable<?> getAccumTVariable()

      • getOutputTVariable

        public java.lang.reflect.TypeVariable<?> getOutputTVariable()

      • populateDisplayData

        public void populateDisplayData​(org.apache.beam.sdk.transforms.display.DisplayData.Builder arg0)
        Specified by:
        populateDisplayData in interface org.apache.beam.sdk.transforms.display.HasDisplayData