# -*- coding: utf-8 -*-
# Generated by the protocol buffer compiler.  DO NOT EDIT!
# source: google/cloud/bigquery/storage_v1beta1/proto/storage.proto

import sys

_b = sys.version_info[0] < 3 and (lambda x: x) or (lambda x: x.encode("latin1"))
from google.protobuf.internal import enum_type_wrapper
from google.protobuf import descriptor as _descriptor
from google.protobuf import message as _message
from google.protobuf import reflection as _reflection
from google.protobuf import symbol_database as _symbol_database

# @@protoc_insertion_point(imports)

_sym_db = _symbol_database.Default()


from google.api import annotations_pb2 as google_dot_api_dot_annotations__pb2
from google.api import client_pb2 as google_dot_api_dot_client__pb2
from google.api import field_behavior_pb2 as google_dot_api_dot_field__behavior__pb2
from google.api import resource_pb2 as google_dot_api_dot_resource__pb2
from google.cloud.bigquery_storage_v1beta1.proto import (
    arrow_pb2 as google_dot_cloud_dot_bigquery_dot_storage__v1beta1_dot_proto_dot_arrow__pb2,
)
from google.cloud.bigquery_storage_v1beta1.proto import (
    avro_pb2 as google_dot_cloud_dot_bigquery_dot_storage__v1beta1_dot_proto_dot_avro__pb2,
)
from google.cloud.bigquery_storage_v1beta1.proto import (
    read_options_pb2 as google_dot_cloud_dot_bigquery_dot_storage__v1beta1_dot_proto_dot_read__options__pb2,
)
from google.cloud.bigquery_storage_v1beta1.proto import (
    table_reference_pb2 as google_dot_cloud_dot_bigquery_dot_storage__v1beta1_dot_proto_dot_table__reference__pb2,
)
from google.protobuf import empty_pb2 as google_dot_protobuf_dot_empty__pb2
from google.protobuf import timestamp_pb2 as google_dot_protobuf_dot_timestamp__pb2


DESCRIPTOR = _descriptor.FileDescriptor(
    name="google/cloud/bigquery/storage_v1beta1/proto/storage.proto",
    package="google.cloud.bigquery.storage.v1beta1",
    syntax="proto3",
    serialized_options=_b(
        "\n)com.google.cloud.bigquery.storage.v1beta1ZLgoogle.golang.org/genproto/googleapis/cloud/bigquery/storage/v1beta1;storage"
    ),
    serialized_pb=_b(
        '\n9google/cloud/bigquery/storage_v1beta1/proto/storage.proto\x12%google.cloud.bigquery.storage.v1beta1\x1a\x1cgoogle/api/annotations.proto\x1a\x17google/api/client.proto\x1a\x1fgoogle/api/field_behavior.proto\x1a\x19google/api/resource.proto\x1a\x37google/cloud/bigquery/storage_v1beta1/proto/arrow.proto\x1a\x36google/cloud/bigquery/storage_v1beta1/proto/avro.proto\x1a>google/cloud/bigquery/storage_v1beta1/proto/read_options.proto\x1a\x41google/cloud/bigquery/storage_v1beta1/proto/table_reference.proto\x1a\x1bgoogle/protobuf/empty.proto\x1a\x1fgoogle/protobuf/timestamp.proto"|\n\x06Stream\x12\x0c\n\x04name\x18\x01 \x01(\t:d\xea\x41\x61\n%bigquerystorage.googleapis.com/Stream\x12\x38projects/{project}/locations/{location}/streams/{stream}"_\n\x0eStreamPosition\x12=\n\x06stream\x18\x01 \x01(\x0b\x32-.google.cloud.bigquery.storage.v1beta1.Stream\x12\x0e\n\x06offset\x18\x02 \x01(\x03"\x8d\x05\n\x0bReadSession\x12\x0c\n\x04name\x18\x01 \x01(\t\x12/\n\x0b\x65xpire_time\x18\x02 \x01(\x0b\x32\x1a.google.protobuf.Timestamp\x12H\n\x0b\x61vro_schema\x18\x05 \x01(\x0b\x32\x31.google.cloud.bigquery.storage.v1beta1.AvroSchemaH\x00\x12J\n\x0c\x61rrow_schema\x18\x06 \x01(\x0b\x32\x32.google.cloud.bigquery.storage.v1beta1.ArrowSchemaH\x00\x12>\n\x07streams\x18\x04 \x03(\x0b\x32-.google.cloud.bigquery.storage.v1beta1.Stream\x12N\n\x0ftable_reference\x18\x07 \x01(\x0b\x32\x35.google.cloud.bigquery.storage.v1beta1.TableReference\x12N\n\x0ftable_modifiers\x18\x08 \x01(\x0b\x32\x35.google.cloud.bigquery.storage.v1beta1.TableModifiers\x12R\n\x11sharding_strategy\x18\t \x01(\x0e\x32\x37.google.cloud.bigquery.storage.v1beta1.ShardingStrategy:k\xea\x41h\n*bigquerystorage.googleapis.com/ReadSession\x12:projects/{project}/locations/{location}/sessions/{session}B\x08\n\x06schema"\xd5\x03\n\x18\x43reateReadSessionRequest\x12S\n\x0ftable_reference\x18\x01 \x01(\x0b\x32\x35.google.cloud.bigquery.storage.v1beta1.TableReferenceB\x03\xe0\x41\x02\x12\x13\n\x06parent\x18\x06 \x01(\tB\x03\xe0\x41\x02\x12N\n\x0ftable_modifiers\x18\x02 \x01(\x0b\x32\x35.google.cloud.bigquery.storage.v1beta1.TableModifiers\x12\x19\n\x11requested_streams\x18\x03 \x01(\x05\x12M\n\x0cread_options\x18\x04 \x01(\x0b\x32\x37.google.cloud.bigquery.storage.v1beta1.TableReadOptions\x12\x41\n\x06\x66ormat\x18\x05 \x01(\x0e\x32\x31.google.cloud.bigquery.storage.v1beta1.DataFormat\x12R\n\x11sharding_strategy\x18\x07 \x01(\x0e\x32\x37.google.cloud.bigquery.storage.v1beta1.ShardingStrategy"d\n\x0fReadRowsRequest\x12Q\n\rread_position\x18\x01 \x01(\x0b\x32\x35.google.cloud.bigquery.storage.v1beta1.StreamPositionB\x03\xe0\x41\x02"\xa0\x01\n\x0cStreamStatus\x12\x1b\n\x13\x65stimated_row_count\x18\x01 \x01(\x03\x12\x19\n\x11\x66raction_consumed\x18\x02 \x01(\x02\x12\x41\n\x08progress\x18\x04 \x01(\x0b\x32/.google.cloud.bigquery.storage.v1beta1.Progress\x12\x15\n\ris_splittable\x18\x03 \x01(\x08">\n\x08Progress\x12\x19\n\x11\x61t_response_start\x18\x01 \x01(\x02\x12\x17\n\x0f\x61t_response_end\x18\x02 \x01(\x02"*\n\x0eThrottleStatus\x12\x18\n\x10throttle_percent\x18\x01 \x01(\x05"\xdf\x02\n\x10ReadRowsResponse\x12\x44\n\tavro_rows\x18\x03 \x01(\x0b\x32/.google.cloud.bigquery.storage.v1beta1.AvroRowsH\x00\x12U\n\x12\x61rrow_record_batch\x18\x04 \x01(\x0b\x32\x37.google.cloud.bigquery.storage.v1beta1.ArrowRecordBatchH\x00\x12\x11\n\trow_count\x18\x06 \x01(\x03\x12\x43\n\x06status\x18\x02 \x01(\x0b\x32\x33.google.cloud.bigquery.storage.v1beta1.StreamStatus\x12N\n\x0fthrottle_status\x18\x05 \x01(\x0b\x32\x35.google.cloud.bigquery.storage.v1beta1.ThrottleStatusB\x06\n\x04rows"\x90\x01\n$BatchCreateReadSessionStreamsRequest\x12H\n\x07session\x18\x01 \x01(\x0b\x32\x32.google.cloud.bigquery.storage.v1beta1.ReadSessionB\x03\xe0\x41\x02\x12\x1e\n\x11requested_streams\x18\x02 \x01(\x05\x42\x03\xe0\x41\x02"g\n%BatchCreateReadSessionStreamsResponse\x12>\n\x07streams\x18\x01 \x03(\x0b\x32-.google.cloud.bigquery.storage.v1beta1.Stream"V\n\x15\x46inalizeStreamRequest\x12=\n\x06stream\x18\x02 \x01(\x0b\x32-.google.cloud.bigquery.storage.v1beta1.Stream"r\n\x16SplitReadStreamRequest\x12\x46\n\x0foriginal_stream\x18\x01 \x01(\x0b\x32-.google.cloud.bigquery.storage.v1beta1.Stream\x12\x10\n\x08\x66raction\x18\x02 \x01(\x02"\xa9\x01\n\x17SplitReadStreamResponse\x12\x45\n\x0eprimary_stream\x18\x01 \x01(\x0b\x32-.google.cloud.bigquery.storage.v1beta1.Stream\x12G\n\x10remainder_stream\x18\x02 \x01(\x0b\x32-.google.cloud.bigquery.storage.v1beta1.Stream*>\n\nDataFormat\x12\x1b\n\x17\x44\x41TA_FORMAT_UNSPECIFIED\x10\x00\x12\x08\n\x04\x41VRO\x10\x01\x12\t\n\x05\x41RROW\x10\x03*O\n\x10ShardingStrategy\x12!\n\x1dSHARDING_STRATEGY_UNSPECIFIED\x10\x00\x12\n\n\x06LIQUID\x10\x01\x12\x0c\n\x08\x42\x41LANCED\x10\x02\x32\xeb\n\n\x0f\x42igQueryStorage\x12\xb3\x02\n\x11\x43reateReadSession\x12?.google.cloud.bigquery.storage.v1beta1.CreateReadSessionRequest\x1a\x32.google.cloud.bigquery.storage.v1beta1.ReadSession"\xa8\x01\x82\xd3\xe4\x93\x02w"0/v1beta1/{table_reference.project_id=projects/*}:\x01*Z@";/v1beta1/{table_reference.dataset_id=projects/*/datasets/*}:\x01*\xda\x41(table_reference,parent,requested_streams\x12\xd0\x01\n\x08ReadRows\x12\x36.google.cloud.bigquery.storage.v1beta1.ReadRowsRequest\x1a\x37.google.cloud.bigquery.storage.v1beta1.ReadRowsResponse"Q\x82\xd3\xe4\x93\x02;\x12\x39/v1beta1/{read_position.stream.name=projects/*/streams/*}\xda\x41\rread_position0\x01\x12\x90\x02\n\x1d\x42\x61tchCreateReadSessionStreams\x12K.google.cloud.bigquery.storage.v1beta1.BatchCreateReadSessionStreamsRequest\x1aL.google.cloud.bigquery.storage.v1beta1.BatchCreateReadSessionStreamsResponse"T\x82\xd3\xe4\x93\x02\x32"-/v1beta1/{session.name=projects/*/sessions/*}:\x01*\xda\x41\x19session,requested_streams\x12\xa7\x01\n\x0e\x46inalizeStream\x12<.google.cloud.bigquery.storage.v1beta1.FinalizeStreamRequest\x1a\x16.google.protobuf.Empty"?\x82\xd3\xe4\x93\x02\x30"+/v1beta1/{stream.name=projects/*/streams/*}:\x01*\xda\x41\x06stream\x12\xe0\x01\n\x0fSplitReadStream\x12=.google.cloud.bigquery.storage.v1beta1.SplitReadStreamRequest\x1a>.google.cloud.bigquery.storage.v1beta1.SplitReadStreamResponse"N\x82\xd3\xe4\x93\x02\x36\x12\x34/v1beta1/{original_stream.name=projects/*/streams/*}\xda\x41\x0foriginal_stream\x1a\xae\x01\xca\x41\x1e\x62igquerystorage.googleapis.com\xd2\x41\x89\x01https://www.googleapis.com/auth/bigquery,https://www.googleapis.com/auth/bigquery.readonly,https://www.googleapis.com/auth/cloud-platformBy\n)com.google.cloud.bigquery.storage.v1beta1ZLgoogle.golang.org/genproto/googleapis/cloud/bigquery/storage/v1beta1;storageb\x06proto3'
    ),
    dependencies=[
        google_dot_api_dot_annotations__pb2.DESCRIPTOR,
        google_dot_api_dot_client__pb2.DESCRIPTOR,
        google_dot_api_dot_field__behavior__pb2.DESCRIPTOR,
        google_dot_api_dot_resource__pb2.DESCRIPTOR,
        google_dot_cloud_dot_bigquery_dot_storage__v1beta1_dot_proto_dot_arrow__pb2.DESCRIPTOR,
        google_dot_cloud_dot_bigquery_dot_storage__v1beta1_dot_proto_dot_avro__pb2.DESCRIPTOR,
        google_dot_cloud_dot_bigquery_dot_storage__v1beta1_dot_proto_dot_read__options__pb2.DESCRIPTOR,
        google_dot_cloud_dot_bigquery_dot_storage__v1beta1_dot_proto_dot_table__reference__pb2.DESCRIPTOR,
        google_dot_protobuf_dot_empty__pb2.DESCRIPTOR,
        google_dot_protobuf_dot_timestamp__pb2.DESCRIPTOR,
    ],
)

_DATAFORMAT = _descriptor.EnumDescriptor(
    name="DataFormat",
    full_name="google.cloud.bigquery.storage.v1beta1.DataFormat",
    filename=None,
    file=DESCRIPTOR,
    values=[
        _descriptor.EnumValueDescriptor(
            name="DATA_FORMAT_UNSPECIFIED",
            index=0,
            number=0,
            serialized_options=None,
            type=None,
        ),
        _descriptor.EnumValueDescriptor(
            name="AVRO", index=1, number=1, serialized_options=None, type=None
        ),
        _descriptor.EnumValueDescriptor(
            name="ARROW", index=2, number=3, serialized_options=None, type=None
        ),
    ],
    containing_type=None,
    serialized_options=None,
    serialized_start=3227,
    serialized_end=3289,
)
_sym_db.RegisterEnumDescriptor(_DATAFORMAT)

DataFormat = enum_type_wrapper.EnumTypeWrapper(_DATAFORMAT)
_SHARDINGSTRATEGY = _descriptor.EnumDescriptor(
    name="ShardingStrategy",
    full_name="google.cloud.bigquery.storage.v1beta1.ShardingStrategy",
    filename=None,
    file=DESCRIPTOR,
    values=[
        _descriptor.EnumValueDescriptor(
            name="SHARDING_STRATEGY_UNSPECIFIED",
            index=0,
            number=0,
            serialized_options=None,
            type=None,
        ),
        _descriptor.EnumValueDescriptor(
            name="LIQUID", index=1, number=1, serialized_options=None, type=None
        ),
        _descriptor.EnumValueDescriptor(
            name="BALANCED", index=2, number=2, serialized_options=None, type=None
        ),
    ],
    containing_type=None,
    serialized_options=None,
    serialized_start=3291,
    serialized_end=3370,
)
_sym_db.RegisterEnumDescriptor(_SHARDINGSTRATEGY)

ShardingStrategy = enum_type_wrapper.EnumTypeWrapper(_SHARDINGSTRATEGY)
DATA_FORMAT_UNSPECIFIED = 0
AVRO = 1
ARROW = 3
SHARDING_STRATEGY_UNSPECIFIED = 0
LIQUID = 1
BALANCED = 2


_STREAM = _descriptor.Descriptor(
    name="Stream",
    full_name="google.cloud.bigquery.storage.v1beta1.Stream",
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
        _descriptor.FieldDescriptor(
            name="name",
            full_name="google.cloud.bigquery.storage.v1beta1.Stream.name",
            index=0,
            number=1,
            type=9,
            cpp_type=9,
            label=1,
            has_default_value=False,
            default_value=_b("").decode("utf-8"),
            message_type=None,
            enum_type=None,
            containing_type=None,
            is_extension=False,
            extension_scope=None,
            serialized_options=None,
            file=DESCRIPTOR,
        )
    ],
    extensions=[],
    nested_types=[],
    enum_types=[],
    serialized_options=_b(
        "\352Aa\n%bigquerystorage.googleapis.com/Stream\0228projects/{project}/locations/{location}/streams/{stream}"
    ),
    is_extendable=False,
    syntax="proto3",
    extension_ranges=[],
    oneofs=[],
    serialized_start=521,
    serialized_end=645,
)


_STREAMPOSITION = _descriptor.Descriptor(
    name="StreamPosition",
    full_name="google.cloud.bigquery.storage.v1beta1.StreamPosition",
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
        _descriptor.FieldDescriptor(
            name="stream",
            full_name="google.cloud.bigquery.storage.v1beta1.StreamPosition.stream",
            index=0,
            number=1,
            type=11,
            cpp_type=10,
            label=1,
            has_default_value=False,
            default_value=None,
            message_type=None,
            enum_type=None,
            containing_type=None,
            is_extension=False,
            extension_scope=None,
            serialized_options=None,
            file=DESCRIPTOR,
        ),
        _descriptor.FieldDescriptor(
            name="offset",
            full_name="google.cloud.bigquery.storage.v1beta1.StreamPosition.offset",
            index=1,
            number=2,
            type=3,
            cpp_type=2,
            label=1,
            has_default_value=False,
            default_value=0,
            message_type=None,
            enum_type=None,
            containing_type=None,
            is_extension=False,
            extension_scope=None,
            serialized_options=None,
            file=DESCRIPTOR,
        ),
    ],
    extensions=[],
    nested_types=[],
    enum_types=[],
    serialized_options=None,
    is_extendable=False,
    syntax="proto3",
    extension_ranges=[],
    oneofs=[],
    serialized_start=647,
    serialized_end=742,
)


_READSESSION = _descriptor.Descriptor(
    name="ReadSession",
    full_name="google.cloud.bigquery.storage.v1beta1.ReadSession",
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
        _descriptor.FieldDescriptor(
            name="name",
            full_name="google.cloud.bigquery.storage.v1beta1.ReadSession.name",
            index=0,
            number=1,
            type=9,
            cpp_type=9,
            label=1,
            has_default_value=False,
            default_value=_b("").decode("utf-8"),
            message_type=None,
            enum_type=None,
            containing_type=None,
            is_extension=False,
            extension_scope=None,
            serialized_options=None,
            file=DESCRIPTOR,
        ),
        _descriptor.FieldDescriptor(
            name="expire_time",
            full_name="google.cloud.bigquery.storage.v1beta1.ReadSession.expire_time",
            index=1,
            number=2,
            type=11,
            cpp_type=10,
            label=1,
            has_default_value=False,
            default_value=None,
            message_type=None,
            enum_type=None,
            containing_type=None,
            is_extension=False,
            extension_scope=None,
            serialized_options=None,
            file=DESCRIPTOR,
        ),
        _descriptor.FieldDescriptor(
            name="avro_schema",
            full_name="google.cloud.bigquery.storage.v1beta1.ReadSession.avro_schema",
            index=2,
            number=5,
            type=11,
            cpp_type=10,
            label=1,
            has_default_value=False,
            default_value=None,
            message_type=None,
            enum_type=None,
            containing_type=None,
            is_extension=False,
            extension_scope=None,
            serialized_options=None,
            file=DESCRIPTOR,
        ),
        _descriptor.FieldDescriptor(
            name="arrow_schema",
            full_name="google.cloud.bigquery.storage.v1beta1.ReadSession.arrow_schema",
            index=3,
            number=6,
            type=11,
            cpp_type=10,
            label=1,
            has_default_value=False,
            default_value=None,
            message_type=None,
            enum_type=None,
            containing_type=None,
            is_extension=False,
            extension_scope=None,
            serialized_options=None,
            file=DESCRIPTOR,
        ),
        _descriptor.FieldDescriptor(
            name="streams",
            full_name="google.cloud.bigquery.storage.v1beta1.ReadSession.streams",
            index=4,
            number=4,
            type=11,
            cpp_type=10,
            label=3,
            has_default_value=False,
            default_value=[],
            message_type=None,
            enum_type=None,
            containing_type=None,
            is_extension=False,
            extension_scope=None,
            serialized_options=None,
            file=DESCRIPTOR,
        ),
        _descriptor.FieldDescriptor(
            name="table_reference",
            full_name="google.cloud.bigquery.storage.v1beta1.ReadSession.table_reference",
            index=5,
            number=7,
            type=11,
            cpp_type=10,
            label=1,
            has_default_value=False,
            default_value=None,
            message_type=None,
            enum_type=None,
            containing_type=None,
            is_extension=False,
            extension_scope=None,
            serialized_options=None,
            file=DESCRIPTOR,
        ),
        _descriptor.FieldDescriptor(
            name="table_modifiers",
            full_name="google.cloud.bigquery.storage.v1beta1.ReadSession.table_modifiers",
            index=6,
            number=8,
            type=11,
            cpp_type=10,
            label=1,
            has_default_value=False,
            default_value=None,
            message_type=None,
            enum_type=None,
            containing_type=None,
            is_extension=False,
            extension_scope=None,
            serialized_options=None,
            file=DESCRIPTOR,
        ),
        _descriptor.FieldDescriptor(
            name="sharding_strategy",
            full_name="google.cloud.bigquery.storage.v1beta1.ReadSession.sharding_strategy",
            index=7,
            number=9,
            type=14,
            cpp_type=8,
            label=1,
            has_default_value=False,
            default_value=0,
            message_type=None,
            enum_type=None,
            containing_type=None,
            is_extension=False,
            extension_scope=None,
            serialized_options=None,
            file=DESCRIPTOR,
        ),
    ],
    extensions=[],
    nested_types=[],
    enum_types=[],
    serialized_options=_b(
        "\352Ah\n*bigquerystorage.googleapis.com/ReadSession\022:projects/{project}/locations/{location}/sessions/{session}"
    ),
    is_extendable=False,
    syntax="proto3",
    extension_ranges=[],
    oneofs=[
        _descriptor.OneofDescriptor(
            name="schema",
            full_name="google.cloud.bigquery.storage.v1beta1.ReadSession.schema",
            index=0,
            containing_type=None,
            fields=[],
        )
    ],
    serialized_start=745,
    serialized_end=1398,
)


_CREATEREADSESSIONREQUEST = _descriptor.Descriptor(
    name="CreateReadSessionRequest",
    full_name="google.cloud.bigquery.storage.v1beta1.CreateReadSessionRequest",
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
        _descriptor.FieldDescriptor(
            name="table_reference",
            full_name="google.cloud.bigquery.storage.v1beta1.CreateReadSessionRequest.table_reference",
            index=0,
            number=1,
            type=11,
            cpp_type=10,
            label=1,
            has_default_value=False,
            default_value=None,
            message_type=None,
            enum_type=None,
            containing_type=None,
            is_extension=False,
            extension_scope=None,
            serialized_options=_b("\340A\002"),
            file=DESCRIPTOR,
        ),
        _descriptor.FieldDescriptor(
            name="parent",
            full_name="google.cloud.bigquery.storage.v1beta1.CreateReadSessionRequest.parent",
            index=1,
            number=6,
            type=9,
            cpp_type=9,
            label=1,
            has_default_value=False,
            default_value=_b("").decode("utf-8"),
            message_type=None,
            enum_type=None,
            containing_type=None,
            is_extension=False,
            extension_scope=None,
            serialized_options=_b("\340A\002"),
            file=DESCRIPTOR,
        ),
        _descriptor.FieldDescriptor(
            name="table_modifiers",
            full_name="google.cloud.bigquery.storage.v1beta1.CreateReadSessionRequest.table_modifiers",
            index=2,
            number=2,
            type=11,
            cpp_type=10,
            label=1,
            has_default_value=False,
            default_value=None,
            message_type=None,
            enum_type=None,
            containing_type=None,
            is_extension=False,
            extension_scope=None,
            serialized_options=None,
            file=DESCRIPTOR,
        ),
        _descriptor.FieldDescriptor(
            name="requested_streams",
            full_name="google.cloud.bigquery.storage.v1beta1.CreateReadSessionRequest.requested_streams",
            index=3,
            number=3,
            type=5,
            cpp_type=1,
            label=1,
            has_default_value=False,
            default_value=0,
            message_type=None,
            enum_type=None,
            containing_type=None,
            is_extension=False,
            extension_scope=None,
            serialized_options=None,
            file=DESCRIPTOR,
        ),
        _descriptor.FieldDescriptor(
            name="read_options",
            full_name="google.cloud.bigquery.storage.v1beta1.CreateReadSessionRequest.read_options",
            index=4,
            number=4,
            type=11,
            cpp_type=10,
            label=1,
            has_default_value=False,
            default_value=None,
            message_type=None,
            enum_type=None,
            containing_type=None,
            is_extension=False,
            extension_scope=None,
            serialized_options=None,
            file=DESCRIPTOR,
        ),
        _descriptor.FieldDescriptor(
            name="format",
            full_name="google.cloud.bigquery.storage.v1beta1.CreateReadSessionRequest.format",
            index=5,
            number=5,
            type=14,
            cpp_type=8,
            label=1,
            has_default_value=False,
            default_value=0,
            message_type=None,
            enum_type=None,
            containing_type=None,
            is_extension=False,
            extension_scope=None,
            serialized_options=None,
            file=DESCRIPTOR,
        ),
        _descriptor.FieldDescriptor(
            name="sharding_strategy",
            full_name="google.cloud.bigquery.storage.v1beta1.CreateReadSessionRequest.sharding_strategy",
            index=6,
            number=7,
            type=14,
            cpp_type=8,
            label=1,
            has_default_value=False,
            default_value=0,
            message_type=None,
            enum_type=None,
            containing_type=None,
            is_extension=False,
            extension_scope=None,
            serialized_options=None,
            file=DESCRIPTOR,
        ),
    ],
    extensions=[],
    nested_types=[],
    enum_types=[],
    serialized_options=None,
    is_extendable=False,
    syntax="proto3",
    extension_ranges=[],
    oneofs=[],
    serialized_start=1401,
    serialized_end=1870,
)


_READROWSREQUEST = _descriptor.Descriptor(
    name="ReadRowsRequest",
    full_name="google.cloud.bigquery.storage.v1beta1.ReadRowsRequest",
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
        _descriptor.FieldDescriptor(
            name="read_position",
            full_name="google.cloud.bigquery.storage.v1beta1.ReadRowsRequest.read_position",
            index=0,
            number=1,
            type=11,
            cpp_type=10,
            label=1,
            has_default_value=False,
            default_value=None,
            message_type=None,
            enum_type=None,
            containing_type=None,
            is_extension=False,
            extension_scope=None,
            serialized_options=_b("\340A\002"),
            file=DESCRIPTOR,
        )
    ],
    extensions=[],
    nested_types=[],
    enum_types=[],
    serialized_options=None,
    is_extendable=False,
    syntax="proto3",
    extension_ranges=[],
    oneofs=[],
    serialized_start=1872,
    serialized_end=1972,
)


_STREAMSTATUS = _descriptor.Descriptor(
    name="StreamStatus",
    full_name="google.cloud.bigquery.storage.v1beta1.StreamStatus",
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
        _descriptor.FieldDescriptor(
            name="estimated_row_count",
            full_name="google.cloud.bigquery.storage.v1beta1.StreamStatus.estimated_row_count",
            index=0,
            number=1,
            type=3,
            cpp_type=2,
            label=1,
            has_default_value=False,
            default_value=0,
            message_type=None,
            enum_type=None,
            containing_type=None,
            is_extension=False,
            extension_scope=None,
            serialized_options=None,
            file=DESCRIPTOR,
        ),
        _descriptor.FieldDescriptor(
            name="fraction_consumed",
            full_name="google.cloud.bigquery.storage.v1beta1.StreamStatus.fraction_consumed",
            index=1,
            number=2,
            type=2,
            cpp_type=6,
            label=1,
            has_default_value=False,
            default_value=float(0),
            message_type=None,
            enum_type=None,
            containing_type=None,
            is_extension=False,
            extension_scope=None,
            serialized_options=None,
            file=DESCRIPTOR,
        ),
        _descriptor.FieldDescriptor(
            name="progress",
            full_name="google.cloud.bigquery.storage.v1beta1.StreamStatus.progress",
            index=2,
            number=4,
            type=11,
            cpp_type=10,
            label=1,
            has_default_value=False,
            default_value=None,
            message_type=None,
            enum_type=None,
            containing_type=None,
            is_extension=False,
            extension_scope=None,
            serialized_options=None,
            file=DESCRIPTOR,
        ),
        _descriptor.FieldDescriptor(
            name="is_splittable",
            full_name="google.cloud.bigquery.storage.v1beta1.StreamStatus.is_splittable",
            index=3,
            number=3,
            type=8,
            cpp_type=7,
            label=1,
            has_default_value=False,
            default_value=False,
            message_type=None,
            enum_type=None,
            containing_type=None,
            is_extension=False,
            extension_scope=None,
            serialized_options=None,
            file=DESCRIPTOR,
        ),
    ],
    extensions=[],
    nested_types=[],
    enum_types=[],
    serialized_options=None,
    is_extendable=False,
    syntax="proto3",
    extension_ranges=[],
    oneofs=[],
    serialized_start=1975,
    serialized_end=2135,
)


_PROGRESS = _descriptor.Descriptor(
    name="Progress",
    full_name="google.cloud.bigquery.storage.v1beta1.Progress",
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
        _descriptor.FieldDescriptor(
            name="at_response_start",
            full_name="google.cloud.bigquery.storage.v1beta1.Progress.at_response_start",
            index=0,
            number=1,
            type=2,
            cpp_type=6,
            label=1,
            has_default_value=False,
            default_value=float(0),
            message_type=None,
            enum_type=None,
            containing_type=None,
            is_extension=False,
            extension_scope=None,
            serialized_options=None,
            file=DESCRIPTOR,
        ),
        _descriptor.FieldDescriptor(
            name="at_response_end",
            full_name="google.cloud.bigquery.storage.v1beta1.Progress.at_response_end",
            index=1,
            number=2,
            type=2,
            cpp_type=6,
            label=1,
            has_default_value=False,
            default_value=float(0),
            message_type=None,
            enum_type=None,
            containing_type=None,
            is_extension=False,
            extension_scope=None,
            serialized_options=None,
            file=DESCRIPTOR,
        ),
    ],
    extensions=[],
    nested_types=[],
    enum_types=[],
    serialized_options=None,
    is_extendable=False,
    syntax="proto3",
    extension_ranges=[],
    oneofs=[],
    serialized_start=2137,
    serialized_end=2199,
)


_THROTTLESTATUS = _descriptor.Descriptor(
    name="ThrottleStatus",
    full_name="google.cloud.bigquery.storage.v1beta1.ThrottleStatus",
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
        _descriptor.FieldDescriptor(
            name="throttle_percent",
            full_name="google.cloud.bigquery.storage.v1beta1.ThrottleStatus.throttle_percent",
            index=0,
            number=1,
            type=5,
            cpp_type=1,
            label=1,
            has_default_value=False,
            default_value=0,
            message_type=None,
            enum_type=None,
            containing_type=None,
            is_extension=False,
            extension_scope=None,
            serialized_options=None,
            file=DESCRIPTOR,
        )
    ],
    extensions=[],
    nested_types=[],
    enum_types=[],
    serialized_options=None,
    is_extendable=False,
    syntax="proto3",
    extension_ranges=[],
    oneofs=[],
    serialized_start=2201,
    serialized_end=2243,
)


_READROWSRESPONSE = _descriptor.Descriptor(
    name="ReadRowsResponse",
    full_name="google.cloud.bigquery.storage.v1beta1.ReadRowsResponse",
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
        _descriptor.FieldDescriptor(
            name="avro_rows",
            full_name="google.cloud.bigquery.storage.v1beta1.ReadRowsResponse.avro_rows",
            index=0,
            number=3,
            type=11,
            cpp_type=10,
            label=1,
            has_default_value=False,
            default_value=None,
            message_type=None,
            enum_type=None,
            containing_type=None,
            is_extension=False,
            extension_scope=None,
            serialized_options=None,
            file=DESCRIPTOR,
        ),
        _descriptor.FieldDescriptor(
            name="arrow_record_batch",
            full_name="google.cloud.bigquery.storage.v1beta1.ReadRowsResponse.arrow_record_batch",
            index=1,
            number=4,
            type=11,
            cpp_type=10,
            label=1,
            has_default_value=False,
            default_value=None,
            message_type=None,
            enum_type=None,
            containing_type=None,
            is_extension=False,
            extension_scope=None,
            serialized_options=None,
            file=DESCRIPTOR,
        ),
        _descriptor.FieldDescriptor(
            name="row_count",
            full_name="google.cloud.bigquery.storage.v1beta1.ReadRowsResponse.row_count",
            index=2,
            number=6,
            type=3,
            cpp_type=2,
            label=1,
            has_default_value=False,
            default_value=0,
            message_type=None,
            enum_type=None,
            containing_type=None,
            is_extension=False,
            extension_scope=None,
            serialized_options=None,
            file=DESCRIPTOR,
        ),
        _descriptor.FieldDescriptor(
            name="status",
            full_name="google.cloud.bigquery.storage.v1beta1.ReadRowsResponse.status",
            index=3,
            number=2,
            type=11,
            cpp_type=10,
            label=1,
            has_default_value=False,
            default_value=None,
            message_type=None,
            enum_type=None,
            containing_type=None,
            is_extension=False,
            extension_scope=None,
            serialized_options=None,
            file=DESCRIPTOR,
        ),
        _descriptor.FieldDescriptor(
            name="throttle_status",
            full_name="google.cloud.bigquery.storage.v1beta1.ReadRowsResponse.throttle_status",
            index=4,
            number=5,
            type=11,
            cpp_type=10,
            label=1,
            has_default_value=False,
            default_value=None,
            message_type=None,
            enum_type=None,
            containing_type=None,
            is_extension=False,
            extension_scope=None,
            serialized_options=None,
            file=DESCRIPTOR,
        ),
    ],
    extensions=[],
    nested_types=[],
    enum_types=[],
    serialized_options=None,
    is_extendable=False,
    syntax="proto3",
    extension_ranges=[],
    oneofs=[
        _descriptor.OneofDescriptor(
            name="rows",
            full_name="google.cloud.bigquery.storage.v1beta1.ReadRowsResponse.rows",
            index=0,
            containing_type=None,
            fields=[],
        )
    ],
    serialized_start=2246,
    serialized_end=2597,
)


_BATCHCREATEREADSESSIONSTREAMSREQUEST = _descriptor.Descriptor(
    name="BatchCreateReadSessionStreamsRequest",
    full_name="google.cloud.bigquery.storage.v1beta1.BatchCreateReadSessionStreamsRequest",
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
        _descriptor.FieldDescriptor(
            name="session",
            full_name="google.cloud.bigquery.storage.v1beta1.BatchCreateReadSessionStreamsRequest.session",
            index=0,
            number=1,
            type=11,
            cpp_type=10,
            label=1,
            has_default_value=False,
            default_value=None,
            message_type=None,
            enum_type=None,
            containing_type=None,
            is_extension=False,
            extension_scope=None,
            serialized_options=_b("\340A\002"),
            file=DESCRIPTOR,
        ),
        _descriptor.FieldDescriptor(
            name="requested_streams",
            full_name="google.cloud.bigquery.storage.v1beta1.BatchCreateReadSessionStreamsRequest.requested_streams",
            index=1,
            number=2,
            type=5,
            cpp_type=1,
            label=1,
            has_default_value=False,
            default_value=0,
            message_type=None,
            enum_type=None,
            containing_type=None,
            is_extension=False,
            extension_scope=None,
            serialized_options=_b("\340A\002"),
            file=DESCRIPTOR,
        ),
    ],
    extensions=[],
    nested_types=[],
    enum_types=[],
    serialized_options=None,
    is_extendable=False,
    syntax="proto3",
    extension_ranges=[],
    oneofs=[],
    serialized_start=2600,
    serialized_end=2744,
)


_BATCHCREATEREADSESSIONSTREAMSRESPONSE = _descriptor.Descriptor(
    name="BatchCreateReadSessionStreamsResponse",
    full_name="google.cloud.bigquery.storage.v1beta1.BatchCreateReadSessionStreamsResponse",
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
        _descriptor.FieldDescriptor(
            name="streams",
            full_name="google.cloud.bigquery.storage.v1beta1.BatchCreateReadSessionStreamsResponse.streams",
            index=0,
            number=1,
            type=11,
            cpp_type=10,
            label=3,
            has_default_value=False,
            default_value=[],
            message_type=None,
            enum_type=None,
            containing_type=None,
            is_extension=False,
            extension_scope=None,
            serialized_options=None,
            file=DESCRIPTOR,
        )
    ],
    extensions=[],
    nested_types=[],
    enum_types=[],
    serialized_options=None,
    is_extendable=False,
    syntax="proto3",
    extension_ranges=[],
    oneofs=[],
    serialized_start=2746,
    serialized_end=2849,
)


_FINALIZESTREAMREQUEST = _descriptor.Descriptor(
    name="FinalizeStreamRequest",
    full_name="google.cloud.bigquery.storage.v1beta1.FinalizeStreamRequest",
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
        _descriptor.FieldDescriptor(
            name="stream",
            full_name="google.cloud.bigquery.storage.v1beta1.FinalizeStreamRequest.stream",
            index=0,
            number=2,
            type=11,
            cpp_type=10,
            label=1,
            has_default_value=False,
            default_value=None,
            message_type=None,
            enum_type=None,
            containing_type=None,
            is_extension=False,
            extension_scope=None,
            serialized_options=None,
            file=DESCRIPTOR,
        )
    ],
    extensions=[],
    nested_types=[],
    enum_types=[],
    serialized_options=None,
    is_extendable=False,
    syntax="proto3",
    extension_ranges=[],
    oneofs=[],
    serialized_start=2851,
    serialized_end=2937,
)


_SPLITREADSTREAMREQUEST = _descriptor.Descriptor(
    name="SplitReadStreamRequest",
    full_name="google.cloud.bigquery.storage.v1beta1.SplitReadStreamRequest",
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
        _descriptor.FieldDescriptor(
            name="original_stream",
            full_name="google.cloud.bigquery.storage.v1beta1.SplitReadStreamRequest.original_stream",
            index=0,
            number=1,
            type=11,
            cpp_type=10,
            label=1,
            has_default_value=False,
            default_value=None,
            message_type=None,
            enum_type=None,
            containing_type=None,
            is_extension=False,
            extension_scope=None,
            serialized_options=None,
            file=DESCRIPTOR,
        ),
        _descriptor.FieldDescriptor(
            name="fraction",
            full_name="google.cloud.bigquery.storage.v1beta1.SplitReadStreamRequest.fraction",
            index=1,
            number=2,
            type=2,
            cpp_type=6,
            label=1,
            has_default_value=False,
            default_value=float(0),
            message_type=None,
            enum_type=None,
            containing_type=None,
            is_extension=False,
            extension_scope=None,
            serialized_options=None,
            file=DESCRIPTOR,
        ),
    ],
    extensions=[],
    nested_types=[],
    enum_types=[],
    serialized_options=None,
    is_extendable=False,
    syntax="proto3",
    extension_ranges=[],
    oneofs=[],
    serialized_start=2939,
    serialized_end=3053,
)


_SPLITREADSTREAMRESPONSE = _descriptor.Descriptor(
    name="SplitReadStreamResponse",
    full_name="google.cloud.bigquery.storage.v1beta1.SplitReadStreamResponse",
    filename=None,
    file=DESCRIPTOR,
    containing_type=None,
    fields=[
        _descriptor.FieldDescriptor(
            name="primary_stream",
            full_name="google.cloud.bigquery.storage.v1beta1.SplitReadStreamResponse.primary_stream",
            index=0,
            number=1,
            type=11,
            cpp_type=10,
            label=1,
            has_default_value=False,
            default_value=None,
            message_type=None,
            enum_type=None,
            containing_type=None,
            is_extension=False,
            extension_scope=None,
            serialized_options=None,
            file=DESCRIPTOR,
        ),
        _descriptor.FieldDescriptor(
            name="remainder_stream",
            full_name="google.cloud.bigquery.storage.v1beta1.SplitReadStreamResponse.remainder_stream",
            index=1,
            number=2,
            type=11,
            cpp_type=10,
            label=1,
            has_default_value=False,
            default_value=None,
            message_type=None,
            enum_type=None,
            containing_type=None,
            is_extension=False,
            extension_scope=None,
            serialized_options=None,
            file=DESCRIPTOR,
        ),
    ],
    extensions=[],
    nested_types=[],
    enum_types=[],
    serialized_options=None,
    is_extendable=False,
    syntax="proto3",
    extension_ranges=[],
    oneofs=[],
    serialized_start=3056,
    serialized_end=3225,
)

_STREAMPOSITION.fields_by_name["stream"].message_type = _STREAM
_READSESSION.fields_by_name[
    "expire_time"
].message_type = google_dot_protobuf_dot_timestamp__pb2._TIMESTAMP
_READSESSION.fields_by_name[
    "avro_schema"
].message_type = (
    google_dot_cloud_dot_bigquery_dot_storage__v1beta1_dot_proto_dot_avro__pb2._AVROSCHEMA
)
_READSESSION.fields_by_name[
    "arrow_schema"
].message_type = (
    google_dot_cloud_dot_bigquery_dot_storage__v1beta1_dot_proto_dot_arrow__pb2._ARROWSCHEMA
)
_READSESSION.fields_by_name["streams"].message_type = _STREAM
_READSESSION.fields_by_name[
    "table_reference"
].message_type = (
    google_dot_cloud_dot_bigquery_dot_storage__v1beta1_dot_proto_dot_table__reference__pb2._TABLEREFERENCE
)
_READSESSION.fields_by_name[
    "table_modifiers"
].message_type = (
    google_dot_cloud_dot_bigquery_dot_storage__v1beta1_dot_proto_dot_table__reference__pb2._TABLEMODIFIERS
)
_READSESSION.fields_by_name["sharding_strategy"].enum_type = _SHARDINGSTRATEGY
_READSESSION.oneofs_by_name["schema"].fields.append(
    _READSESSION.fields_by_name["avro_schema"]
)
_READSESSION.fields_by_name[
    "avro_schema"
].containing_oneof = _READSESSION.oneofs_by_name["schema"]
_READSESSION.oneofs_by_name["schema"].fields.append(
    _READSESSION.fields_by_name["arrow_schema"]
)
_READSESSION.fields_by_name[
    "arrow_schema"
].containing_oneof = _READSESSION.oneofs_by_name["schema"]
_CREATEREADSESSIONREQUEST.fields_by_name[
    "table_reference"
].message_type = (
    google_dot_cloud_dot_bigquery_dot_storage__v1beta1_dot_proto_dot_table__reference__pb2._TABLEREFERENCE
)
_CREATEREADSESSIONREQUEST.fields_by_name[
    "table_modifiers"
].message_type = (
    google_dot_cloud_dot_bigquery_dot_storage__v1beta1_dot_proto_dot_table__reference__pb2._TABLEMODIFIERS
)
_CREATEREADSESSIONREQUEST.fields_by_name[
    "read_options"
].message_type = (
    google_dot_cloud_dot_bigquery_dot_storage__v1beta1_dot_proto_dot_read__options__pb2._TABLEREADOPTIONS
)
_CREATEREADSESSIONREQUEST.fields_by_name["format"].enum_type = _DATAFORMAT
_CREATEREADSESSIONREQUEST.fields_by_name[
    "sharding_strategy"
].enum_type = _SHARDINGSTRATEGY
_READROWSREQUEST.fields_by_name["read_position"].message_type = _STREAMPOSITION
_STREAMSTATUS.fields_by_name["progress"].message_type = _PROGRESS
_READROWSRESPONSE.fields_by_name[
    "avro_rows"
].message_type = (
    google_dot_cloud_dot_bigquery_dot_storage__v1beta1_dot_proto_dot_avro__pb2._AVROROWS
)
_READROWSRESPONSE.fields_by_name[
    "arrow_record_batch"
].message_type = (
    google_dot_cloud_dot_bigquery_dot_storage__v1beta1_dot_proto_dot_arrow__pb2._ARROWRECORDBATCH
)
_READROWSRESPONSE.fields_by_name["status"].message_type = _STREAMSTATUS
_READROWSRESPONSE.fields_by_name["throttle_status"].message_type = _THROTTLESTATUS
_READROWSRESPONSE.oneofs_by_name["rows"].fields.append(
    _READROWSRESPONSE.fields_by_name["avro_rows"]
)
_READROWSRESPONSE.fields_by_name[
    "avro_rows"
].containing_oneof = _READROWSRESPONSE.oneofs_by_name["rows"]
_READROWSRESPONSE.oneofs_by_name["rows"].fields.append(
    _READROWSRESPONSE.fields_by_name["arrow_record_batch"]
)
_READROWSRESPONSE.fields_by_name[
    "arrow_record_batch"
].containing_oneof = _READROWSRESPONSE.oneofs_by_name["rows"]
_BATCHCREATEREADSESSIONSTREAMSREQUEST.fields_by_name[
    "session"
].message_type = _READSESSION
_BATCHCREATEREADSESSIONSTREAMSRESPONSE.fields_by_name["streams"].message_type = _STREAM
_FINALIZESTREAMREQUEST.fields_by_name["stream"].message_type = _STREAM
_SPLITREADSTREAMREQUEST.fields_by_name["original_stream"].message_type = _STREAM
_SPLITREADSTREAMRESPONSE.fields_by_name["primary_stream"].message_type = _STREAM
_SPLITREADSTREAMRESPONSE.fields_by_name["remainder_stream"].message_type = _STREAM
DESCRIPTOR.message_types_by_name["Stream"] = _STREAM
DESCRIPTOR.message_types_by_name["StreamPosition"] = _STREAMPOSITION
DESCRIPTOR.message_types_by_name["ReadSession"] = _READSESSION
DESCRIPTOR.message_types_by_name["CreateReadSessionRequest"] = _CREATEREADSESSIONREQUEST
DESCRIPTOR.message_types_by_name["ReadRowsRequest"] = _READROWSREQUEST
DESCRIPTOR.message_types_by_name["StreamStatus"] = _STREAMSTATUS
DESCRIPTOR.message_types_by_name["Progress"] = _PROGRESS
DESCRIPTOR.message_types_by_name["ThrottleStatus"] = _THROTTLESTATUS
DESCRIPTOR.message_types_by_name["ReadRowsResponse"] = _READROWSRESPONSE
DESCRIPTOR.message_types_by_name[
    "BatchCreateReadSessionStreamsRequest"
] = _BATCHCREATEREADSESSIONSTREAMSREQUEST
DESCRIPTOR.message_types_by_name[
    "BatchCreateReadSessionStreamsResponse"
] = _BATCHCREATEREADSESSIONSTREAMSRESPONSE
DESCRIPTOR.message_types_by_name["FinalizeStreamRequest"] = _FINALIZESTREAMREQUEST
DESCRIPTOR.message_types_by_name["SplitReadStreamRequest"] = _SPLITREADSTREAMREQUEST
DESCRIPTOR.message_types_by_name["SplitReadStreamResponse"] = _SPLITREADSTREAMRESPONSE
DESCRIPTOR.enum_types_by_name["DataFormat"] = _DATAFORMAT
DESCRIPTOR.enum_types_by_name["ShardingStrategy"] = _SHARDINGSTRATEGY
_sym_db.RegisterFileDescriptor(DESCRIPTOR)

Stream = _reflection.GeneratedProtocolMessageType(
    "Stream",
    (_message.Message,),
    dict(
        DESCRIPTOR=_STREAM,
        __module__="google.cloud.bigquery.storage_v1beta1.proto.storage_pb2",
        __doc__="""Information about a single data stream within a read session.
  
  
  Attributes:
      name:
          Name of the stream, in the form ``projects/{project_id}/locati
          ons/{location}/streams/{stream_id}``.
  """,
        # @@protoc_insertion_point(class_scope:google.cloud.bigquery.storage.v1beta1.Stream)
    ),
)
_sym_db.RegisterMessage(Stream)

StreamPosition = _reflection.GeneratedProtocolMessageType(
    "StreamPosition",
    (_message.Message,),
    dict(
        DESCRIPTOR=_STREAMPOSITION,
        __module__="google.cloud.bigquery.storage_v1beta1.proto.storage_pb2",
        __doc__="""Expresses a point within a given stream using an offset position.
  
  
  Attributes:
      stream:
          Identifier for a given Stream.
      offset:
          Position in the stream.
  """,
        # @@protoc_insertion_point(class_scope:google.cloud.bigquery.storage.v1beta1.StreamPosition)
    ),
)
_sym_db.RegisterMessage(StreamPosition)

ReadSession = _reflection.GeneratedProtocolMessageType(
    "ReadSession",
    (_message.Message,),
    dict(
        DESCRIPTOR=_READSESSION,
        __module__="google.cloud.bigquery.storage_v1beta1.proto.storage_pb2",
        __doc__="""Information returned from a ``CreateReadSession`` request.
  
  
  Attributes:
      name:
          Unique identifier for the session, in the form ``projects/{pro
          ject_id}/locations/{location}/sessions/{session_id}``.
      expire_time:
          Time at which the session becomes invalid. After this time,
          subsequent requests to read this Session will return errors.
      schema:
          The schema for the read. If read\_options.selected\_fields is
          set, the schema may be different from the table schema as it
          will only contain the selected fields.
      avro_schema:
          Avro schema.
      arrow_schema:
          Arrow schema.
      streams:
          Streams associated with this session.
      table_reference:
          Table that this ReadSession is reading from.
      table_modifiers:
          Any modifiers which are applied when reading from the
          specified table.
      sharding_strategy:
          The strategy to use for distributing data among the streams.
  """,
        # @@protoc_insertion_point(class_scope:google.cloud.bigquery.storage.v1beta1.ReadSession)
    ),
)
_sym_db.RegisterMessage(ReadSession)

CreateReadSessionRequest = _reflection.GeneratedProtocolMessageType(
    "CreateReadSessionRequest",
    (_message.Message,),
    dict(
        DESCRIPTOR=_CREATEREADSESSIONREQUEST,
        __module__="google.cloud.bigquery.storage_v1beta1.proto.storage_pb2",
        __doc__="""Creates a new read session, which may include additional options such as
  requested parallelism, projection filters and constraints.
  
  
  Attributes:
      table_reference:
          Required. Reference to the table to read.
      parent:
          Required. String of the form ``projects/{project_id}``
          indicating the project this ReadSession is associated with.
          This is the project that will be billed for usage.
      table_modifiers:
          Any modifiers to the Table (e.g. snapshot timestamp).
      requested_streams:
          Initial number of streams. If unset or 0, we will provide a
          value of streams so as to produce reasonable throughput. Must
          be non-negative. The number of streams may be lower than the
          requested number, depending on the amount parallelism that is
          reasonable for the table and the maximum amount of parallelism
          allowed by the system.  Streams must be read starting from
          offset 0.
      read_options:
          Read options for this session (e.g. column selection,
          filters).
      format:
          Data output format. Currently default to Avro.
      sharding_strategy:
          The strategy to use for distributing data among multiple
          streams. Currently defaults to liquid sharding.
  """,
        # @@protoc_insertion_point(class_scope:google.cloud.bigquery.storage.v1beta1.CreateReadSessionRequest)
    ),
)
_sym_db.RegisterMessage(CreateReadSessionRequest)

ReadRowsRequest = _reflection.GeneratedProtocolMessageType(
    "ReadRowsRequest",
    (_message.Message,),
    dict(
        DESCRIPTOR=_READROWSREQUEST,
        __module__="google.cloud.bigquery.storage_v1beta1.proto.storage_pb2",
        __doc__="""Requesting row data via ``ReadRows`` must provide Stream position
  information.
  
  
  Attributes:
      read_position:
          Required. Identifier of the position in the stream to start
          reading from. The offset requested must be less than the last
          row read from ReadRows. Requesting a larger offset is
          undefined.
  """,
        # @@protoc_insertion_point(class_scope:google.cloud.bigquery.storage.v1beta1.ReadRowsRequest)
    ),
)
_sym_db.RegisterMessage(ReadRowsRequest)

StreamStatus = _reflection.GeneratedProtocolMessageType(
    "StreamStatus",
    (_message.Message,),
    dict(
        DESCRIPTOR=_STREAMSTATUS,
        __module__="google.cloud.bigquery.storage_v1beta1.proto.storage_pb2",
        __doc__="""Progress information for a given Stream.
  
  
  Attributes:
      estimated_row_count:
          Number of estimated rows in the current stream. May change
          over time as different readers in the stream progress at rates
          which are relatively fast or slow.
      fraction_consumed:
          A value in the range [0.0, 1.0] that represents the fraction
          of rows assigned to this stream that have been processed by
          the server. In the presence of read filters, the server may
          process more rows than it returns, so this value reflects
          progress through the pre-filtering rows.  This value is only
          populated for sessions created through the BALANCED sharding
          strategy.
      progress:
          Represents the progress of the current stream.  Note: This
          value is under development and should not be used. Use
          ``fraction_consumed`` instead.
      is_splittable:
          Whether this stream can be split. For sessions that use the
          LIQUID sharding strategy, this value is always false. For
          BALANCED sessions, this value is false when enough data have
          been read such that no more splits are possible at that point
          or beyond. For small tables or streams that are the result of
          a chain of splits, this value may never be true.
  """,
        # @@protoc_insertion_point(class_scope:google.cloud.bigquery.storage.v1beta1.StreamStatus)
    ),
)
_sym_db.RegisterMessage(StreamStatus)

Progress = _reflection.GeneratedProtocolMessageType(
    "Progress",
    (_message.Message,),
    dict(
        DESCRIPTOR=_PROGRESS,
        __module__="google.cloud.bigquery.storage_v1beta1.proto.storage_pb2",
        __doc__="""Protocol buffer.

  Attributes:
      at_response_start:
          The fraction of rows assigned to the stream that have been
          processed by the server so far, not including the rows in the
          current response message.  This value, along with
          ``at_response_end``, can be used to interpolate the progress
          made as the rows in the message are being processed using the
          following formula: ``at_response_start + (at_response_end -
          at_response_start) * rows_processed_from_response /
          rows_in_response``.  Note that if a filter is provided, the
          ``at_response_end`` value of the previous response may not
          necessarily be equal to the ``at_response_start`` value of the
          current response.
      at_response_end:
          Similar to ``at_response_start``, except that this value
          includes the rows in the current response.
  """,
        # @@protoc_insertion_point(class_scope:google.cloud.bigquery.storage.v1beta1.Progress)
    ),
)
_sym_db.RegisterMessage(Progress)

ThrottleStatus = _reflection.GeneratedProtocolMessageType(
    "ThrottleStatus",
    (_message.Message,),
    dict(
        DESCRIPTOR=_THROTTLESTATUS,
        __module__="google.cloud.bigquery.storage_v1beta1.proto.storage_pb2",
        __doc__="""Information on if the current connection is being throttled.
  
  
  Attributes:
      throttle_percent:
          How much this connection is being throttled. 0 is no
          throttling, 100 is completely throttled.
  """,
        # @@protoc_insertion_point(class_scope:google.cloud.bigquery.storage.v1beta1.ThrottleStatus)
    ),
)
_sym_db.RegisterMessage(ThrottleStatus)

ReadRowsResponse = _reflection.GeneratedProtocolMessageType(
    "ReadRowsResponse",
    (_message.Message,),
    dict(
        DESCRIPTOR=_READROWSRESPONSE,
        __module__="google.cloud.bigquery.storage_v1beta1.proto.storage_pb2",
        __doc__="""Response from calling ``ReadRows`` may include row data, progress and
  throttling information.
  
  
  Attributes:
      rows:
          Row data is returned in format specified during session
          creation.
      avro_rows:
          Serialized row data in AVRO format.
      arrow_record_batch:
          Serialized row data in Arrow RecordBatch format.
      row_count:
          Number of serialized rows in the rows block. This value is
          recorded here, in addition to the row\_count values in the
          output-specific messages in ``rows``, so that code which needs
          to record progress through the stream can do so in an output
          format-independent way.
      status:
          Estimated stream statistics.
      throttle_status:
          Throttling status. If unset, the latest response still
          describes the current throttling status.
  """,
        # @@protoc_insertion_point(class_scope:google.cloud.bigquery.storage.v1beta1.ReadRowsResponse)
    ),
)
_sym_db.RegisterMessage(ReadRowsResponse)

BatchCreateReadSessionStreamsRequest = _reflection.GeneratedProtocolMessageType(
    "BatchCreateReadSessionStreamsRequest",
    (_message.Message,),
    dict(
        DESCRIPTOR=_BATCHCREATEREADSESSIONSTREAMSREQUEST,
        __module__="google.cloud.bigquery.storage_v1beta1.proto.storage_pb2",
        __doc__="""Information needed to request additional streams for an established read
  session.
  
  
  Attributes:
      session:
          Required. Must be a non-expired session obtained from a call
          to CreateReadSession. Only the name field needs to be set.
      requested_streams:
          Required. Number of new streams requested. Must be positive.
          Number of added streams may be less than this, see
          CreateReadSessionRequest for more information.
  """,
        # @@protoc_insertion_point(class_scope:google.cloud.bigquery.storage.v1beta1.BatchCreateReadSessionStreamsRequest)
    ),
)
_sym_db.RegisterMessage(BatchCreateReadSessionStreamsRequest)

BatchCreateReadSessionStreamsResponse = _reflection.GeneratedProtocolMessageType(
    "BatchCreateReadSessionStreamsResponse",
    (_message.Message,),
    dict(
        DESCRIPTOR=_BATCHCREATEREADSESSIONSTREAMSRESPONSE,
        __module__="google.cloud.bigquery.storage_v1beta1.proto.storage_pb2",
        __doc__="""The response from ``BatchCreateReadSessionStreams`` returns the stream
  identifiers for the newly created streams.
  
  
  Attributes:
      streams:
          Newly added streams.
  """,
        # @@protoc_insertion_point(class_scope:google.cloud.bigquery.storage.v1beta1.BatchCreateReadSessionStreamsResponse)
    ),
)
_sym_db.RegisterMessage(BatchCreateReadSessionStreamsResponse)

FinalizeStreamRequest = _reflection.GeneratedProtocolMessageType(
    "FinalizeStreamRequest",
    (_message.Message,),
    dict(
        DESCRIPTOR=_FINALIZESTREAMREQUEST,
        __module__="google.cloud.bigquery.storage_v1beta1.proto.storage_pb2",
        __doc__="""Request information for invoking ``FinalizeStream``.
  
  
  Attributes:
      stream:
          Stream to finalize.
  """,
        # @@protoc_insertion_point(class_scope:google.cloud.bigquery.storage.v1beta1.FinalizeStreamRequest)
    ),
)
_sym_db.RegisterMessage(FinalizeStreamRequest)

SplitReadStreamRequest = _reflection.GeneratedProtocolMessageType(
    "SplitReadStreamRequest",
    (_message.Message,),
    dict(
        DESCRIPTOR=_SPLITREADSTREAMREQUEST,
        __module__="google.cloud.bigquery.storage_v1beta1.proto.storage_pb2",
        __doc__="""Request information for ``SplitReadStream``.
  
  
  Attributes:
      original_stream:
          Stream to split.
      fraction:
          A value in the range (0.0, 1.0) that specifies the fractional
          point at which the original stream should be split. The actual
          split point is evaluated on pre-filtered rows, so if a filter
          is provided, then there is no guarantee that the division of
          the rows between the new child streams will be proportional to
          this fractional value. Additionally, because the server-side
          unit for assigning data is collections of rows, this fraction
          will always map to to a data storage boundary on the server
          side.
  """,
        # @@protoc_insertion_point(class_scope:google.cloud.bigquery.storage.v1beta1.SplitReadStreamRequest)
    ),
)
_sym_db.RegisterMessage(SplitReadStreamRequest)

SplitReadStreamResponse = _reflection.GeneratedProtocolMessageType(
    "SplitReadStreamResponse",
    (_message.Message,),
    dict(
        DESCRIPTOR=_SPLITREADSTREAMRESPONSE,
        __module__="google.cloud.bigquery.storage_v1beta1.proto.storage_pb2",
        __doc__="""Response from ``SplitReadStream``.
  
  
  Attributes:
      primary_stream:
          Primary stream, which contains the beginning portion of
          \|original\_stream\|. An empty value indicates that the
          original stream can no longer be split.
      remainder_stream:
          Remainder stream, which contains the tail of
          \|original\_stream\|. An empty value indicates that the
          original stream can no longer be split.
  """,
        # @@protoc_insertion_point(class_scope:google.cloud.bigquery.storage.v1beta1.SplitReadStreamResponse)
    ),
)
_sym_db.RegisterMessage(SplitReadStreamResponse)


DESCRIPTOR._options = None
_STREAM._options = None
_READSESSION._options = None
_CREATEREADSESSIONREQUEST.fields_by_name["table_reference"]._options = None
_CREATEREADSESSIONREQUEST.fields_by_name["parent"]._options = None
_READROWSREQUEST.fields_by_name["read_position"]._options = None
_BATCHCREATEREADSESSIONSTREAMSREQUEST.fields_by_name["session"]._options = None
_BATCHCREATEREADSESSIONSTREAMSREQUEST.fields_by_name[
    "requested_streams"
]._options = None

_BIGQUERYSTORAGE = _descriptor.ServiceDescriptor(
    name="BigQueryStorage",
    full_name="google.cloud.bigquery.storage.v1beta1.BigQueryStorage",
    file=DESCRIPTOR,
    index=0,
    serialized_options=_b(
        "\312A\036bigquerystorage.googleapis.com\322A\211\001https://www.googleapis.com/auth/bigquery,https://www.googleapis.com/auth/bigquery.readonly,https://www.googleapis.com/auth/cloud-platform"
    ),
    serialized_start=3373,
    serialized_end=4760,
    methods=[
        _descriptor.MethodDescriptor(
            name="CreateReadSession",
            full_name="google.cloud.bigquery.storage.v1beta1.BigQueryStorage.CreateReadSession",
            index=0,
            containing_service=None,
            input_type=_CREATEREADSESSIONREQUEST,
            output_type=_READSESSION,
            serialized_options=_b(
                '\202\323\344\223\002w"0/v1beta1/{table_reference.project_id=projects/*}:\001*Z@";/v1beta1/{table_reference.dataset_id=projects/*/datasets/*}:\001*\332A(table_reference,parent,requested_streams'
            ),
        ),
        _descriptor.MethodDescriptor(
            name="ReadRows",
            full_name="google.cloud.bigquery.storage.v1beta1.BigQueryStorage.ReadRows",
            index=1,
            containing_service=None,
            input_type=_READROWSREQUEST,
            output_type=_READROWSRESPONSE,
            serialized_options=_b(
                "\202\323\344\223\002;\0229/v1beta1/{read_position.stream.name=projects/*/streams/*}\332A\rread_position"
            ),
        ),
        _descriptor.MethodDescriptor(
            name="BatchCreateReadSessionStreams",
            full_name="google.cloud.bigquery.storage.v1beta1.BigQueryStorage.BatchCreateReadSessionStreams",
            index=2,
            containing_service=None,
            input_type=_BATCHCREATEREADSESSIONSTREAMSREQUEST,
            output_type=_BATCHCREATEREADSESSIONSTREAMSRESPONSE,
            serialized_options=_b(
                '\202\323\344\223\0022"-/v1beta1/{session.name=projects/*/sessions/*}:\001*\332A\031session,requested_streams'
            ),
        ),
        _descriptor.MethodDescriptor(
            name="FinalizeStream",
            full_name="google.cloud.bigquery.storage.v1beta1.BigQueryStorage.FinalizeStream",
            index=3,
            containing_service=None,
            input_type=_FINALIZESTREAMREQUEST,
            output_type=google_dot_protobuf_dot_empty__pb2._EMPTY,
            serialized_options=_b(
                '\202\323\344\223\0020"+/v1beta1/{stream.name=projects/*/streams/*}:\001*\332A\006stream'
            ),
        ),
        _descriptor.MethodDescriptor(
            name="SplitReadStream",
            full_name="google.cloud.bigquery.storage.v1beta1.BigQueryStorage.SplitReadStream",
            index=4,
            containing_service=None,
            input_type=_SPLITREADSTREAMREQUEST,
            output_type=_SPLITREADSTREAMRESPONSE,
            serialized_options=_b(
                "\202\323\344\223\0026\0224/v1beta1/{original_stream.name=projects/*/streams/*}\332A\017original_stream"
            ),
        ),
    ],
)
_sym_db.RegisterServiceDescriptor(_BIGQUERYSTORAGE)

DESCRIPTOR.services_by_name["BigQueryStorage"] = _BIGQUERYSTORAGE

# @@protoc_insertion_point(module_scope)
