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

Package Hierarchies:

• All Packages

Class Hierarchy

• java.lang.Object
  • org.apache.beam.sdk.io.gcp.bigquery.AvroWriteRequest<T>
  • org.apache.beam.sdk.io.gcp.bigquery.BeamRowToStorageApiProto
  • org.apache.beam.sdk.io.gcp.bigquery.BigQueryCoderProviderRegistrar (implements org.apache.beam.sdk.coders.CoderProviderRegistrar)
  • org.apache.beam.sdk.io.gcp.bigquery.BigQueryDlqProvider (implements org.apache.beam.sdk.schemas.io.GenericDlqProvider)
  • org.apache.beam.sdk.io.gcp.bigquery.BigQueryHelpers
  • org.apache.beam.sdk.io.gcp.bigquery.BigQueryInsertError
  • org.apache.beam.sdk.io.gcp.bigquery.BigQueryIO
  • org.apache.beam.sdk.io.gcp.bigquery.BigQuerySchemaIOProvider (implements org.apache.beam.sdk.schemas.io.SchemaIOProvider)
  • org.apache.beam.sdk.io.gcp.bigquery.BigQuerySchemaTransformReadConfiguration
  • org.apache.beam.sdk.io.gcp.bigquery.BigQuerySchemaTransformReadConfiguration.Builder
  • org.apache.beam.sdk.io.gcp.bigquery.BigQuerySchemaTransformWriteConfiguration
  • org.apache.beam.sdk.io.gcp.bigquery.BigQuerySchemaTransformWriteConfiguration.Builder
  • org.apache.beam.sdk.io.gcp.bigquery.BigQueryStorageApiInsertError
  • org.apache.beam.sdk.io.gcp.bigquery.BigQueryUtils
  • org.apache.beam.sdk.io.gcp.bigquery.BigQueryUtils.ConversionOptions (implements java.io.Serializable)
  • org.apache.beam.sdk.io.gcp.bigquery.BigQueryUtils.ConversionOptions.Builder
  • org.apache.beam.sdk.io.gcp.bigquery.BigQueryUtils.SchemaConversionOptions (implements java.io.Serializable)
  • org.apache.beam.sdk.io.gcp.bigquery.BigQueryUtils.SchemaConversionOptions.Builder
  • org.apache.beam.sdk.io.gcp.bigquery.CivilTimeEncoder
  • org.apache.beam.sdk.coders.Coder<T> (implements java.io.Serializable)
    • org.apache.beam.sdk.coders.StructuredCoder<T>
      • org.apache.beam.sdk.coders.AtomicCoder<T>
        • org.apache.beam.sdk.io.gcp.bigquery.BigQueryInsertErrorCoder
        • org.apache.beam.sdk.io.gcp.bigquery.BigQueryStorageApiInsertErrorCoder
        • org.apache.beam.sdk.io.gcp.bigquery.TableDestinationCoder
        • org.apache.beam.sdk.io.gcp.bigquery.TableDestinationCoderV2
        • org.apache.beam.sdk.io.gcp.bigquery.TableDestinationCoderV3
        • org.apache.beam.sdk.io.gcp.bigquery.TableRowJsonCoder
  • org.apache.beam.sdk.io.gcp.bigquery.CreateTableHelpers
  • org.apache.beam.sdk.transforms.DoFn<InputT,OutputT> (implements org.apache.beam.sdk.transforms.display.HasDisplayData, java.io.Serializable)
    • org.apache.beam.sdk.io.gcp.bigquery.StorageApiConvertMessages.ConvertMessagesDoFn<DestinationT,ElementT>
    • org.apache.beam.sdk.io.gcp.bigquery.StorageApiFlushAndFinalizeDoFn
    • org.apache.beam.sdk.io.gcp.bigquery.UpdateSchemaDestination<DestinationT>
  • org.apache.beam.sdk.io.gcp.bigquery.DynamicDestinations<T,DestinationT> (implements java.io.Serializable)
    • org.apache.beam.sdk.io.gcp.bigquery.StorageApiDynamicDestinationsTableRow<T,DestinationT>
  • org.apache.beam.sdk.io.gcp.bigquery.InsertRetryPolicy (implements java.io.Serializable)
  • org.apache.beam.sdk.io.gcp.bigquery.InsertRetryPolicy.Context
  • org.apache.beam.sdk.transforms.PTransform<InputT,OutputT> (implements org.apache.beam.sdk.transforms.display.HasDisplayData, java.io.Serializable)
    • org.apache.beam.sdk.io.gcp.bigquery.BigQueryIO.Read
    • org.apache.beam.sdk.io.gcp.bigquery.BigQueryIO.TypedRead<T> (implements org.apache.beam.sdk.schemas.ProjectionProducer<T>)
    • org.apache.beam.sdk.io.gcp.bigquery.BigQueryIO.Write<T>
    • org.apache.beam.sdk.io.gcp.bigquery.CreateTableDestinations<DestinationT,ElementT>
    • org.apache.beam.sdk.io.gcp.bigquery.CreateTables<DestinationT,ElementT>
    • org.apache.beam.sdk.io.gcp.bigquery.PrepareWrite<InputT,DestinationT,OutputT>
    • org.apache.beam.sdk.io.gcp.bigquery.ReifyAsIterable<T>
    • org.apache.beam.sdk.io.gcp.bigquery.StorageApiConvertMessages<DestinationT,ElementT>
    • org.apache.beam.sdk.io.gcp.bigquery.StorageApiLoads<DestinationT,ElementT>
    • org.apache.beam.sdk.io.gcp.bigquery.StorageApiWriteRecordsInconsistent<DestinationT,ElementT>
    • org.apache.beam.sdk.io.gcp.bigquery.StorageApiWritesShardedRecords<DestinationT,ElementT>
    • org.apache.beam.sdk.io.gcp.bigquery.StorageApiWriteUnshardedRecords<DestinationT,ElementT>
    • org.apache.beam.sdk.io.gcp.bigquery.StreamingInserts<DestinationT,ElementT>
    • org.apache.beam.sdk.io.gcp.bigquery.StreamingWriteTables<ElementT>
  • org.apache.beam.sdk.io.gcp.bigquery.SchemaAndRecord
  • org.apache.beam.sdk.io.Source<T> (implements org.apache.beam.sdk.transforms.display.HasDisplayData, java.io.Serializable)
    • org.apache.beam.sdk.io.BoundedSource<T>
      • org.apache.beam.sdk.io.gcp.bigquery.BigQueryStorageTableSource<T>
  • org.apache.beam.sdk.io.gcp.bigquery.StorageApiWritePayload
  • org.apache.beam.sdk.io.gcp.bigquery.TableDestination (implements java.io.Serializable)
  • org.apache.beam.sdk.io.gcp.bigquery.TableRowToStorageApiProto
  • org.apache.beam.sdk.io.gcp.bigquery.TableSchemaCache
  • org.apache.beam.sdk.io.gcp.bigquery.TestBigQuery (implements org.junit.rules.TestRule)
  • org.apache.beam.sdk.io.gcp.bigquery.TestBigQuery.RowsAssertion
  • java.lang.Throwable (implements java.io.Serializable)
    • java.lang.Exception
      • java.lang.RuntimeException
        • org.apache.beam.sdk.io.gcp.bigquery.BigQuerySchemaRetrievalException
      • org.apache.beam.sdk.io.gcp.bigquery.TableRowToStorageApiProto.SchemaConversionException
        • org.apache.beam.sdk.io.gcp.bigquery.TableRowToStorageApiProto.SchemaDoesntMatchException
        • org.apache.beam.sdk.io.gcp.bigquery.TableRowToStorageApiProto.SchemaTooNarrowException
  • org.apache.beam.sdk.schemas.transforms.TypedSchemaTransformProvider<ConfigT> (implements org.apache.beam.sdk.schemas.transforms.SchemaTransformProvider)
    • org.apache.beam.sdk.io.gcp.bigquery.BigQuerySchemaTransformReadProvider
    • org.apache.beam.sdk.io.gcp.bigquery.BigQuerySchemaTransformWriteProvider
  • org.apache.beam.sdk.io.gcp.bigquery.WriteResult (implements org.apache.beam.sdk.values.POutput)

Interface Hierarchy

• java.lang.AutoCloseable
  • org.apache.beam.sdk.io.gcp.bigquery.BigQueryServices.DatasetService
  • org.apache.beam.sdk.io.gcp.bigquery.BigQueryServices.JobService
  • org.apache.beam.sdk.io.gcp.bigquery.BigQueryServices.StorageClient
  • org.apache.beam.sdk.io.gcp.bigquery.BigQueryServices.StreamAppendClient
• org.apache.beam.sdk.transforms.display.HasDisplayData
  • org.apache.beam.sdk.options.PipelineOptions
    • org.apache.beam.sdk.options.ApplicationNameOptions
      • org.apache.beam.sdk.io.gcp.bigquery.BigQueryOptions (also extends org.apache.beam.sdk.extensions.gcp.options.GcpOptions, org.apache.beam.sdk.options.PipelineOptions, org.apache.beam.sdk.options.StreamingOptions)
        • org.apache.beam.sdk.io.gcp.bigquery.TestBigQueryOptions (also extends org.apache.beam.sdk.extensions.gcp.options.GcpOptions, org.apache.beam.sdk.testing.TestPipelineOptions)
      • org.apache.beam.sdk.options.StreamingOptions (also extends org.apache.beam.sdk.options.PipelineOptions)
        • org.apache.beam.sdk.io.gcp.bigquery.BigQueryOptions (also extends org.apache.beam.sdk.options.ApplicationNameOptions, org.apache.beam.sdk.extensions.gcp.options.GcpOptions, org.apache.beam.sdk.options.PipelineOptions)
          • org.apache.beam.sdk.io.gcp.bigquery.TestBigQueryOptions (also extends org.apache.beam.sdk.extensions.gcp.options.GcpOptions, org.apache.beam.sdk.testing.TestPipelineOptions)
    • org.apache.beam.sdk.io.gcp.bigquery.BigQueryOptions (also extends org.apache.beam.sdk.options.ApplicationNameOptions, org.apache.beam.sdk.extensions.gcp.options.GcpOptions, org.apache.beam.sdk.options.StreamingOptions)
      • org.apache.beam.sdk.io.gcp.bigquery.TestBigQueryOptions (also extends org.apache.beam.sdk.extensions.gcp.options.GcpOptions, org.apache.beam.sdk.testing.TestPipelineOptions)
    • org.apache.beam.sdk.extensions.gcp.options.GcpOptions (also extends org.apache.beam.sdk.extensions.gcp.options.GoogleApiDebugOptions)
      • org.apache.beam.sdk.io.gcp.bigquery.BigQueryOptions (also extends org.apache.beam.sdk.options.ApplicationNameOptions, org.apache.beam.sdk.options.PipelineOptions, org.apache.beam.sdk.options.StreamingOptions)
        • org.apache.beam.sdk.io.gcp.bigquery.TestBigQueryOptions (also extends org.apache.beam.sdk.extensions.gcp.options.GcpOptions, org.apache.beam.sdk.testing.TestPipelineOptions)
      • org.apache.beam.sdk.io.gcp.bigquery.TestBigQueryOptions (also extends org.apache.beam.sdk.io.gcp.bigquery.BigQueryOptions, org.apache.beam.sdk.testing.TestPipelineOptions)
    • org.apache.beam.sdk.extensions.gcp.options.GoogleApiDebugOptions
      • org.apache.beam.sdk.extensions.gcp.options.GcpOptions (also extends org.apache.beam.sdk.options.PipelineOptions)
        • org.apache.beam.sdk.io.gcp.bigquery.BigQueryOptions (also extends org.apache.beam.sdk.options.ApplicationNameOptions, org.apache.beam.sdk.options.PipelineOptions, org.apache.beam.sdk.options.StreamingOptions)
          • org.apache.beam.sdk.io.gcp.bigquery.TestBigQueryOptions (also extends org.apache.beam.sdk.extensions.gcp.options.GcpOptions, org.apache.beam.sdk.testing.TestPipelineOptions)
        • org.apache.beam.sdk.io.gcp.bigquery.TestBigQueryOptions (also extends org.apache.beam.sdk.io.gcp.bigquery.BigQueryOptions, org.apache.beam.sdk.testing.TestPipelineOptions)
    • org.apache.beam.sdk.options.StreamingOptions (also extends org.apache.beam.sdk.options.ApplicationNameOptions)
      • org.apache.beam.sdk.io.gcp.bigquery.BigQueryOptions (also extends org.apache.beam.sdk.options.ApplicationNameOptions, org.apache.beam.sdk.extensions.gcp.options.GcpOptions, org.apache.beam.sdk.options.PipelineOptions)
        • org.apache.beam.sdk.io.gcp.bigquery.TestBigQueryOptions (also extends org.apache.beam.sdk.extensions.gcp.options.GcpOptions, org.apache.beam.sdk.testing.TestPipelineOptions)
    • org.apache.beam.sdk.testing.TestPipelineOptions
      • org.apache.beam.sdk.io.gcp.bigquery.TestBigQueryOptions (also extends org.apache.beam.sdk.io.gcp.bigquery.BigQueryOptions, org.apache.beam.sdk.extensions.gcp.options.GcpOptions)
• java.lang.Iterable<T>
  • org.apache.beam.sdk.io.gcp.bigquery.BigQueryServices.BigQueryServerStream<T> (also extends java.io.Serializable)
• java.io.Serializable
  • org.apache.beam.sdk.io.gcp.bigquery.BigQueryServices
  • org.apache.beam.sdk.io.gcp.bigquery.BigQueryServices.BigQueryServerStream<T> (also extends java.lang.Iterable<T>)
  • org.apache.beam.sdk.io.gcp.bigquery.ErrorContainer<T>
• org.apache.beam.sdk.io.gcp.bigquery.TestBigQuery.PollingAssertion

Enum Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
    • org.apache.beam.sdk.io.gcp.bigquery.BigQueryIO.TypedRead.Method
    • org.apache.beam.sdk.io.gcp.bigquery.BigQueryIO.TypedRead.QueryPriority
    • org.apache.beam.sdk.io.gcp.bigquery.BigQueryIO.Write.CreateDisposition
    • org.apache.beam.sdk.io.gcp.bigquery.BigQueryIO.Write.Method
    • org.apache.beam.sdk.io.gcp.bigquery.BigQueryIO.Write.SchemaUpdateOption
    • org.apache.beam.sdk.io.gcp.bigquery.BigQueryIO.Write.WriteDisposition
    • org.apache.beam.sdk.io.gcp.bigquery.BigQueryServices.DatasetService.TableMetadataView
    • org.apache.beam.sdk.io.gcp.bigquery.BigQueryUtils.ConversionOptions.TruncateTimestamps