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

Class BigQueryDynamicReadDescriptor

  • All Implemented Interfaces:
    java.io.Serializable
    @DefaultSchema(org.apache.beam.sdk.schemas.AutoValueSchema.class)
public abstract class BigQueryDynamicReadDescriptor
extends java.lang.Object
implements java.io.Serializable
    Represents a BigQuery source description used for dynamic read.
    See Also:
    Serialized Form

    • Method Summary

      All Methods Static Methods Concrete Methods 
      Modifier and Type Method Description
      static BigQueryDynamicReadDescriptor create​(@Nullable java.lang.String query, @Nullable java.lang.String table, @Nullable java.lang.Boolean flattenResults, @Nullable java.lang.Boolean useLegacySql, @Nullable java.util.List<java.lang.String> selectedFields, @Nullable java.lang.String rowRestriction)  
      static BigQueryDynamicReadDescriptor query​(java.lang.String query, java.lang.Boolean flattenResults, java.lang.Boolean useLegacySql)  
      static BigQueryDynamicReadDescriptor table​(java.lang.String table, @Nullable java.util.List<java.lang.String> selectedFields, @Nullable java.lang.String rowRestriction)  

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • BigQueryDynamicReadDescriptor

        public BigQueryDynamicReadDescriptor()

    • Method Detail

      • create

        @SchemaCreate
public static BigQueryDynamicReadDescriptor create​(@Nullable java.lang.String query,
                                                   @Nullable java.lang.String table,
                                                   @Nullable java.lang.Boolean flattenResults,
                                                   @Nullable java.lang.Boolean useLegacySql,
                                                   @Nullable java.util.List<java.lang.String> selectedFields,
                                                   @Nullable java.lang.String rowRestriction)

      • query

        public static BigQueryDynamicReadDescriptor query​(java.lang.String query,
                                                  java.lang.Boolean flattenResults,
                                                  java.lang.Boolean useLegacySql)

      • table

        public static BigQueryDynamicReadDescriptor table​(java.lang.String table,
                                                  @Nullable java.util.List<java.lang.String> selectedFields,
                                                  @Nullable java.lang.String rowRestriction)