# Generated by the protocol buffer compiler.  DO NOT EDIT!
# source: google/cloud/bigquery/storage/v1/storage.proto

require 'google/protobuf'

require 'google/api/annotations_pb'
require 'google/api/client_pb'
require 'google/api/field_behavior_pb'
require 'google/api/resource_pb'
require 'google/cloud/bigquery/storage/v1/arrow_pb'
require 'google/cloud/bigquery/storage/v1/avro_pb'
require 'google/cloud/bigquery/storage/v1/stream_pb'
Google::Protobuf::DescriptorPool.generated_pool.build do
  add_file("google/cloud/bigquery/storage/v1/storage.proto", :syntax => :proto3) do
    add_message "google.cloud.bigquery.storage.v1.CreateReadSessionRequest" do
      optional :parent, :string, 1
      optional :read_session, :message, 2, "google.cloud.bigquery.storage.v1.ReadSession"
      optional :max_stream_count, :int32, 3
    end
    add_message "google.cloud.bigquery.storage.v1.ReadRowsRequest" do
      optional :read_stream, :string, 1
      optional :offset, :int64, 2
    end
    add_message "google.cloud.bigquery.storage.v1.ThrottleState" do
      optional :throttle_percent, :int32, 1
    end
    add_message "google.cloud.bigquery.storage.v1.StreamStats" do
      optional :progress, :message, 2, "google.cloud.bigquery.storage.v1.StreamStats.Progress"
    end
    add_message "google.cloud.bigquery.storage.v1.StreamStats.Progress" do
      optional :at_response_start, :double, 1
      optional :at_response_end, :double, 2
    end
    add_message "google.cloud.bigquery.storage.v1.ReadRowsResponse" do
      optional :row_count, :int64, 6
      optional :stats, :message, 2, "google.cloud.bigquery.storage.v1.StreamStats"
      optional :throttle_state, :message, 5, "google.cloud.bigquery.storage.v1.ThrottleState"
      oneof :rows do
        optional :avro_rows, :message, 3, "google.cloud.bigquery.storage.v1.AvroRows"
        optional :arrow_record_batch, :message, 4, "google.cloud.bigquery.storage.v1.ArrowRecordBatch"
      end
      oneof :schema do
        optional :avro_schema, :message, 7, "google.cloud.bigquery.storage.v1.AvroSchema"
        optional :arrow_schema, :message, 8, "google.cloud.bigquery.storage.v1.ArrowSchema"
      end
    end
    add_message "google.cloud.bigquery.storage.v1.SplitReadStreamRequest" do
      optional :name, :string, 1
      optional :fraction, :double, 2
    end
    add_message "google.cloud.bigquery.storage.v1.SplitReadStreamResponse" do
      optional :primary_stream, :message, 1, "google.cloud.bigquery.storage.v1.ReadStream"
      optional :remainder_stream, :message, 2, "google.cloud.bigquery.storage.v1.ReadStream"
    end
  end
end

module Google
  module Cloud
    module Bigquery
      module Storage
        module V1
          CreateReadSessionRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.bigquery.storage.v1.CreateReadSessionRequest").msgclass
          ReadRowsRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.bigquery.storage.v1.ReadRowsRequest").msgclass
          ThrottleState = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.bigquery.storage.v1.ThrottleState").msgclass
          StreamStats = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.bigquery.storage.v1.StreamStats").msgclass
          StreamStats::Progress = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.bigquery.storage.v1.StreamStats.Progress").msgclass
          ReadRowsResponse = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.bigquery.storage.v1.ReadRowsResponse").msgclass
          SplitReadStreamRequest = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.bigquery.storage.v1.SplitReadStreamRequest").msgclass
          SplitReadStreamResponse = ::Google::Protobuf::DescriptorPool.generated_pool.lookup("google.cloud.bigquery.storage.v1.SplitReadStreamResponse").msgclass
        end
      end
    end
  end
end