# 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
from google.protobuf import descriptor_pb2

# @@protoc_insertion_point(imports)

_sym_db = _symbol_database.Default()


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_pb=_b(
        '\n9google/cloud/bigquery/storage_v1beta1/proto/storage.proto\x12%google.cloud.bigquery.storage.v1beta1\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\x12\x11\n\trow_count\x18\x02 \x01(\x03"_\n\x0eStreamPosition\x12=\n\x06stream\x18\x01 \x01(\x0b\x32-.google.cloud.bigquery.storage.v1beta1.Stream\x12\x0e\n\x06offset\x18\x02 \x01(\x03"\x80\x03\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\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.TableModifiersB\x08\n\x06schema"\xf7\x02\n\x18\x43reateReadSessionRequest\x12N\n\x0ftable_reference\x18\x01 \x01(\x0b\x32\x35.google.cloud.bigquery.storage.v1beta1.TableReference\x12\x0e\n\x06parent\x18\x06 \x01(\t\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"_\n\x0fReadRowsRequest\x12L\n\rread_position\x18\x01 \x01(\x0b\x32\x35.google.cloud.bigquery.storage.v1beta1.StreamPosition"+\n\x0cStreamStatus\x12\x1b\n\x13\x65stimated_row_count\x18\x01 \x01(\x03"*\n\x0eThrottleStatus\x12\x18\n\x10throttle_percent\x18\x01 \x01(\x05"\xf5\x01\n\x10ReadRowsResponse\x12\x44\n\tavro_rows\x18\x03 \x01(\x0b\x32/.google.cloud.bigquery.storage.v1beta1.AvroRowsH\x00\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"\x86\x01\n$BatchCreateReadSessionStreamsRequest\x12\x43\n\x07session\x18\x01 \x01(\x0b\x32\x32.google.cloud.bigquery.storage.v1beta1.ReadSession\x12\x19\n\x11requested_streams\x18\x02 \x01(\x05"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"`\n\x16SplitReadStreamRequest\x12\x46\n\x0foriginal_stream\x18\x01 \x01(\x0b\x32-.google.cloud.bigquery.storage.v1beta1.Stream"\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*3\n\nDataFormat\x12\x1b\n\x17\x44\x41TA_FORMAT_UNSPECIFIED\x10\x00\x12\x08\n\x04\x41VRO\x10\x01\x32\xdd\x05\n\x0f\x42igQueryStorage\x12\x8a\x01\n\x11\x43reateReadSession\x12?.google.cloud.bigquery.storage.v1beta1.CreateReadSessionRequest\x1a\x32.google.cloud.bigquery.storage.v1beta1.ReadSession"\x00\x12\x7f\n\x08ReadRows\x12\x36.google.cloud.bigquery.storage.v1beta1.ReadRowsRequest\x1a\x37.google.cloud.bigquery.storage.v1beta1.ReadRowsResponse"\x00\x30\x01\x12\xbc\x01\n\x1d\x42\x61tchCreateReadSessionStreams\x12K.google.cloud.bigquery.storage.v1beta1.BatchCreateReadSessionStreamsRequest\x1aL.google.cloud.bigquery.storage.v1beta1.BatchCreateReadSessionStreamsResponse"\x00\x12h\n\x0e\x46inalizeStream\x12<.google.cloud.bigquery.storage.v1beta1.FinalizeStreamRequest\x1a\x16.google.protobuf.Empty"\x00\x12\x92\x01\n\x0fSplitReadStream\x12=.google.cloud.bigquery.storage.v1beta1.SplitReadStreamRequest\x1a>.google.cloud.bigquery.storage.v1beta1.SplitReadStreamResponse"\x00\x42y\n)com.google.cloud.bigquery.storage.v1beta1ZLgoogle.golang.org/genproto/googleapis/cloud/bigquery/storage/v1beta1;storageb\x06proto3'
    ),
    dependencies=[
        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, options=None, type=None
        ),
        _descriptor.EnumValueDescriptor(
            name="AVRO", index=1, number=1, options=None, type=None
        ),
    ],
    containing_type=None,
    options=None,
    serialized_start=2288,
    serialized_end=2339,
)
_sym_db.RegisterEnumDescriptor(_DATAFORMAT)

DataFormat = enum_type_wrapper.EnumTypeWrapper(_DATAFORMAT)
DATA_FORMAT_UNSPECIFIED = 0
AVRO = 1


_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,
            options=None,
            file=DESCRIPTOR,
        ),
        _descriptor.FieldDescriptor(
            name="row_count",
            full_name="google.cloud.bigquery.storage.v1beta1.Stream.row_count",
            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,
            options=None,
            file=DESCRIPTOR,
        ),
    ],
    extensions=[],
    nested_types=[],
    enum_types=[],
    options=None,
    is_extendable=False,
    syntax="proto3",
    extension_ranges=[],
    oneofs=[],
    serialized_start=349,
    serialized_end=390,
)


_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,
            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,
            options=None,
            file=DESCRIPTOR,
        ),
    ],
    extensions=[],
    nested_types=[],
    enum_types=[],
    options=None,
    is_extendable=False,
    syntax="proto3",
    extension_ranges=[],
    oneofs=[],
    serialized_start=392,
    serialized_end=487,
)


_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,
            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,
            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,
            options=None,
            file=DESCRIPTOR,
        ),
        _descriptor.FieldDescriptor(
            name="streams",
            full_name="google.cloud.bigquery.storage.v1beta1.ReadSession.streams",
            index=3,
            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,
            options=None,
            file=DESCRIPTOR,
        ),
        _descriptor.FieldDescriptor(
            name="table_reference",
            full_name="google.cloud.bigquery.storage.v1beta1.ReadSession.table_reference",
            index=4,
            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,
            options=None,
            file=DESCRIPTOR,
        ),
        _descriptor.FieldDescriptor(
            name="table_modifiers",
            full_name="google.cloud.bigquery.storage.v1beta1.ReadSession.table_modifiers",
            index=5,
            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,
            options=None,
            file=DESCRIPTOR,
        ),
    ],
    extensions=[],
    nested_types=[],
    enum_types=[],
    options=None,
    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=490,
    serialized_end=874,
)


_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,
            options=None,
            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,
            options=None,
            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,
            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,
            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,
            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,
            options=None,
            file=DESCRIPTOR,
        ),
    ],
    extensions=[],
    nested_types=[],
    enum_types=[],
    options=None,
    is_extendable=False,
    syntax="proto3",
    extension_ranges=[],
    oneofs=[],
    serialized_start=877,
    serialized_end=1252,
)


_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,
            options=None,
            file=DESCRIPTOR,
        )
    ],
    extensions=[],
    nested_types=[],
    enum_types=[],
    options=None,
    is_extendable=False,
    syntax="proto3",
    extension_ranges=[],
    oneofs=[],
    serialized_start=1254,
    serialized_end=1349,
)


_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,
            options=None,
            file=DESCRIPTOR,
        )
    ],
    extensions=[],
    nested_types=[],
    enum_types=[],
    options=None,
    is_extendable=False,
    syntax="proto3",
    extension_ranges=[],
    oneofs=[],
    serialized_start=1351,
    serialized_end=1394,
)


_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,
            options=None,
            file=DESCRIPTOR,
        )
    ],
    extensions=[],
    nested_types=[],
    enum_types=[],
    options=None,
    is_extendable=False,
    syntax="proto3",
    extension_ranges=[],
    oneofs=[],
    serialized_start=1396,
    serialized_end=1438,
)


_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,
            options=None,
            file=DESCRIPTOR,
        ),
        _descriptor.FieldDescriptor(
            name="status",
            full_name="google.cloud.bigquery.storage.v1beta1.ReadRowsResponse.status",
            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,
            options=None,
            file=DESCRIPTOR,
        ),
        _descriptor.FieldDescriptor(
            name="throttle_status",
            full_name="google.cloud.bigquery.storage.v1beta1.ReadRowsResponse.throttle_status",
            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,
            options=None,
            file=DESCRIPTOR,
        ),
    ],
    extensions=[],
    nested_types=[],
    enum_types=[],
    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=1441,
    serialized_end=1686,
)


_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,
            options=None,
            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,
            options=None,
            file=DESCRIPTOR,
        ),
    ],
    extensions=[],
    nested_types=[],
    enum_types=[],
    options=None,
    is_extendable=False,
    syntax="proto3",
    extension_ranges=[],
    oneofs=[],
    serialized_start=1689,
    serialized_end=1823,
)


_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,
            options=None,
            file=DESCRIPTOR,
        )
    ],
    extensions=[],
    nested_types=[],
    enum_types=[],
    options=None,
    is_extendable=False,
    syntax="proto3",
    extension_ranges=[],
    oneofs=[],
    serialized_start=1825,
    serialized_end=1928,
)


_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,
            options=None,
            file=DESCRIPTOR,
        )
    ],
    extensions=[],
    nested_types=[],
    enum_types=[],
    options=None,
    is_extendable=False,
    syntax="proto3",
    extension_ranges=[],
    oneofs=[],
    serialized_start=1930,
    serialized_end=2016,
)


_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,
            options=None,
            file=DESCRIPTOR,
        )
    ],
    extensions=[],
    nested_types=[],
    enum_types=[],
    options=None,
    is_extendable=False,
    syntax="proto3",
    extension_ranges=[],
    oneofs=[],
    serialized_start=2018,
    serialized_end=2114,
)


_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,
            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,
            options=None,
            file=DESCRIPTOR,
        ),
    ],
    extensions=[],
    nested_types=[],
    enum_types=[],
    options=None,
    is_extendable=False,
    syntax="proto3",
    extension_ranges=[],
    oneofs=[],
    serialized_start=2117,
    serialized_end=2286,
)

_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["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.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"]
_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
_READROWSREQUEST.fields_by_name["read_position"].message_type = _STREAMPOSITION
_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["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"]
_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["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
_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}/stream/{stream_id}``
      row_count:
          Rows in the stream.
  """,
        # @@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/{project_id}/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.
      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.
  """,
        # @@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/your-project-id"
          indicating the project this ReadSession is associated with.
          This is the project that will be billed for usage.
      table_modifiers:
          Optional. Any modifiers to the Table (e.g. snapshot
          timestamp).
      requested_streams:
          Optional. 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:
          Optional. Read options for this session (e.g. column
          selection, filters).
      format:
          Data output format. Currently default to Avro.
  """,
        # @@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.
  """,
        # @@protoc_insertion_point(class_scope:google.cloud.bigquery.storage.v1beta1.StreamStatus)
    ),
)
_sym_db.RegisterMessage(StreamStatus)

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.
      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.
  """,
        # @@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. Will contain the beginning portion of
          \|original\_stream\|.
      remainder_stream:
          Remainder stream. Will contain the tail of
          \|original\_stream\|.
  """,
        # @@protoc_insertion_point(class_scope:google.cloud.bigquery.storage.v1beta1.SplitReadStreamResponse)
    ),
)
_sym_db.RegisterMessage(SplitReadStreamResponse)


DESCRIPTOR.has_options = True
DESCRIPTOR._options = _descriptor._ParseOptions(
    descriptor_pb2.FileOptions(),
    _b(
        "\n)com.google.cloud.bigquery.storage.v1beta1ZLgoogle.golang.org/genproto/googleapis/cloud/bigquery/storage/v1beta1;storage"
    ),
)

_BIGQUERYSTORAGE = _descriptor.ServiceDescriptor(
    name="BigQueryStorage",
    full_name="google.cloud.bigquery.storage.v1beta1.BigQueryStorage",
    file=DESCRIPTOR,
    index=0,
    options=None,
    serialized_start=2342,
    serialized_end=3075,
    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,
            options=None,
        ),
        _descriptor.MethodDescriptor(
            name="ReadRows",
            full_name="google.cloud.bigquery.storage.v1beta1.BigQueryStorage.ReadRows",
            index=1,
            containing_service=None,
            input_type=_READROWSREQUEST,
            output_type=_READROWSRESPONSE,
            options=None,
        ),
        _descriptor.MethodDescriptor(
            name="BatchCreateReadSessionStreams",
            full_name="google.cloud.bigquery.storage.v1beta1.BigQueryStorage.BatchCreateReadSessionStreams",
            index=2,
            containing_service=None,
            input_type=_BATCHCREATEREADSESSIONSTREAMSREQUEST,
            output_type=_BATCHCREATEREADSESSIONSTREAMSRESPONSE,
            options=None,
        ),
        _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,
            options=None,
        ),
        _descriptor.MethodDescriptor(
            name="SplitReadStream",
            full_name="google.cloud.bigquery.storage.v1beta1.BigQueryStorage.SplitReadStream",
            index=4,
            containing_service=None,
            input_type=_SPLITREADSTREAMREQUEST,
            output_type=_SPLITREADSTREAMRESPONSE,
            options=None,
        ),
    ],
)
_sym_db.RegisterServiceDescriptor(_BIGQUERYSTORAGE)

DESCRIPTOR.services_by_name["BigQueryStorage"] = _BIGQUERYSTORAGE

# @@protoc_insertion_point(module_scope)
