// Copyright 2025 Google LLC
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

// Code generated by protoc-gen-go. DO NOT EDIT.
// versions:
// 	protoc-gen-go v1.36.11
// 	protoc        v6.33.2
// source: google/cloud/bigquery/storage/v1beta2/storage.proto

package storagepb

import (
	reflect "reflect"
	sync "sync"
	unsafe "unsafe"

	_ "google.golang.org/genproto/googleapis/api/annotations"
	status "google.golang.org/genproto/googleapis/rpc/status"
	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
	timestamppb "google.golang.org/protobuf/types/known/timestamppb"
	wrapperspb "google.golang.org/protobuf/types/known/wrapperspb"
)

const (
	// Verify that this generated code is sufficiently up-to-date.
	_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
	// Verify that runtime/protoimpl is sufficiently up-to-date.
	_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
)

// Error code for `StorageError`.
type StorageError_StorageErrorCode int32

const (
	// Default error.
	StorageError_STORAGE_ERROR_CODE_UNSPECIFIED StorageError_StorageErrorCode = 0
	// Table is not found in the system.
	StorageError_TABLE_NOT_FOUND StorageError_StorageErrorCode = 1
	// Stream is already committed.
	StorageError_STREAM_ALREADY_COMMITTED StorageError_StorageErrorCode = 2
	// Stream is not found.
	StorageError_STREAM_NOT_FOUND StorageError_StorageErrorCode = 3
	// Invalid Stream type.
	// For example, you try to commit a stream that is not pending.
	StorageError_INVALID_STREAM_TYPE StorageError_StorageErrorCode = 4
	// Invalid Stream state.
	// For example, you try to commit a stream that is not finalized or is
	// garbaged.
	StorageError_INVALID_STREAM_STATE StorageError_StorageErrorCode = 5
	// Stream is finalized.
	StorageError_STREAM_FINALIZED StorageError_StorageErrorCode = 6
)

// Enum value maps for StorageError_StorageErrorCode.
var (
	StorageError_StorageErrorCode_name = map[int32]string{
		0: "STORAGE_ERROR_CODE_UNSPECIFIED",
		1: "TABLE_NOT_FOUND",
		2: "STREAM_ALREADY_COMMITTED",
		3: "STREAM_NOT_FOUND",
		4: "INVALID_STREAM_TYPE",
		5: "INVALID_STREAM_STATE",
		6: "STREAM_FINALIZED",
	}
	StorageError_StorageErrorCode_value = map[string]int32{
		"STORAGE_ERROR_CODE_UNSPECIFIED": 0,
		"TABLE_NOT_FOUND":                1,
		"STREAM_ALREADY_COMMITTED":       2,
		"STREAM_NOT_FOUND":               3,
		"INVALID_STREAM_TYPE":            4,
		"INVALID_STREAM_STATE":           5,
		"STREAM_FINALIZED":               6,
	}
)

func (x StorageError_StorageErrorCode) Enum() *StorageError_StorageErrorCode {
	p := new(StorageError_StorageErrorCode)
	*p = x
	return p
}

func (x StorageError_StorageErrorCode) String() string {
	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}

func (StorageError_StorageErrorCode) Descriptor() protoreflect.EnumDescriptor {
	return file_google_cloud_bigquery_storage_v1beta2_storage_proto_enumTypes[0].Descriptor()
}

func (StorageError_StorageErrorCode) Type() protoreflect.EnumType {
	return &file_google_cloud_bigquery_storage_v1beta2_storage_proto_enumTypes[0]
}

func (x StorageError_StorageErrorCode) Number() protoreflect.EnumNumber {
	return protoreflect.EnumNumber(x)
}

// Deprecated: Use StorageError_StorageErrorCode.Descriptor instead.
func (StorageError_StorageErrorCode) EnumDescriptor() ([]byte, []int) {
	return file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescGZIP(), []int{17, 0}
}

// Request message for `CreateReadSession`.
type CreateReadSessionRequest struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// Required. The request project that owns the session, in the form of
	// `projects/{project_id}`.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Required. Session to be created.
	ReadSession *ReadSession `protobuf:"bytes,2,opt,name=read_session,json=readSession,proto3" json:"read_session,omitempty"`
	// Max initial number of streams. If unset or zero, the server 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. Error
	// will be returned if the max count is greater than the current system
	// max limit of 1,000.
	//
	// Streams must be read starting from offset 0.
	MaxStreamCount int32 `protobuf:"varint,3,opt,name=max_stream_count,json=maxStreamCount,proto3" json:"max_stream_count,omitempty"`
	unknownFields  protoimpl.UnknownFields
	sizeCache      protoimpl.SizeCache
}

func (x *CreateReadSessionRequest) Reset() {
	*x = CreateReadSessionRequest{}
	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[0]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *CreateReadSessionRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*CreateReadSessionRequest) ProtoMessage() {}

func (x *CreateReadSessionRequest) ProtoReflect() protoreflect.Message {
	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[0]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use CreateReadSessionRequest.ProtoReflect.Descriptor instead.
func (*CreateReadSessionRequest) Descriptor() ([]byte, []int) {
	return file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescGZIP(), []int{0}
}

func (x *CreateReadSessionRequest) GetParent() string {
	if x != nil {
		return x.Parent
	}
	return ""
}

func (x *CreateReadSessionRequest) GetReadSession() *ReadSession {
	if x != nil {
		return x.ReadSession
	}
	return nil
}

func (x *CreateReadSessionRequest) GetMaxStreamCount() int32 {
	if x != nil {
		return x.MaxStreamCount
	}
	return 0
}

// Request message for `ReadRows`.
type ReadRowsRequest struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// Required. Stream to read rows from.
	ReadStream string `protobuf:"bytes,1,opt,name=read_stream,json=readStream,proto3" json:"read_stream,omitempty"`
	// The offset requested must be less than the last row read from Read.
	// Requesting a larger offset is undefined. If not specified, start reading
	// from offset zero.
	Offset        int64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *ReadRowsRequest) Reset() {
	*x = ReadRowsRequest{}
	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[1]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *ReadRowsRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*ReadRowsRequest) ProtoMessage() {}

func (x *ReadRowsRequest) ProtoReflect() protoreflect.Message {
	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[1]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use ReadRowsRequest.ProtoReflect.Descriptor instead.
func (*ReadRowsRequest) Descriptor() ([]byte, []int) {
	return file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescGZIP(), []int{1}
}

func (x *ReadRowsRequest) GetReadStream() string {
	if x != nil {
		return x.ReadStream
	}
	return ""
}

func (x *ReadRowsRequest) GetOffset() int64 {
	if x != nil {
		return x.Offset
	}
	return 0
}

// Information on if the current connection is being throttled.
type ThrottleState struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// How much this connection is being throttled. Zero means no throttling,
	// 100 means fully throttled.
	ThrottlePercent int32 `protobuf:"varint,1,opt,name=throttle_percent,json=throttlePercent,proto3" json:"throttle_percent,omitempty"`
	unknownFields   protoimpl.UnknownFields
	sizeCache       protoimpl.SizeCache
}

func (x *ThrottleState) Reset() {
	*x = ThrottleState{}
	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[2]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *ThrottleState) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*ThrottleState) ProtoMessage() {}

func (x *ThrottleState) ProtoReflect() protoreflect.Message {
	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[2]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use ThrottleState.ProtoReflect.Descriptor instead.
func (*ThrottleState) Descriptor() ([]byte, []int) {
	return file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescGZIP(), []int{2}
}

func (x *ThrottleState) GetThrottlePercent() int32 {
	if x != nil {
		return x.ThrottlePercent
	}
	return 0
}

// Estimated stream statistics for a given Stream.
type StreamStats struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// Represents the progress of the current stream.
	Progress      *StreamStats_Progress `protobuf:"bytes,2,opt,name=progress,proto3" json:"progress,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *StreamStats) Reset() {
	*x = StreamStats{}
	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[3]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *StreamStats) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*StreamStats) ProtoMessage() {}

func (x *StreamStats) ProtoReflect() protoreflect.Message {
	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[3]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use StreamStats.ProtoReflect.Descriptor instead.
func (*StreamStats) Descriptor() ([]byte, []int) {
	return file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescGZIP(), []int{3}
}

func (x *StreamStats) GetProgress() *StreamStats_Progress {
	if x != nil {
		return x.Progress
	}
	return nil
}

// Response from calling `ReadRows` may include row data, progress and
// throttling information.
type ReadRowsResponse struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// Row data is returned in format specified during session creation.
	//
	// Types that are valid to be assigned to Rows:
	//
	//	*ReadRowsResponse_AvroRows
	//	*ReadRowsResponse_ArrowRecordBatch
	Rows isReadRowsResponse_Rows `protobuf_oneof:"rows"`
	// Number of serialized rows in the rows block.
	RowCount int64 `protobuf:"varint,6,opt,name=row_count,json=rowCount,proto3" json:"row_count,omitempty"`
	// Statistics for the stream.
	Stats *StreamStats `protobuf:"bytes,2,opt,name=stats,proto3" json:"stats,omitempty"`
	// Throttling state. If unset, the latest response still describes
	// the current throttling status.
	ThrottleState *ThrottleState `protobuf:"bytes,5,opt,name=throttle_state,json=throttleState,proto3" json:"throttle_state,omitempty"`
	// 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. This schema is equivalent to the one returned by
	// CreateSession. This field is only populated in the first ReadRowsResponse
	// RPC.
	//
	// Types that are valid to be assigned to Schema:
	//
	//	*ReadRowsResponse_AvroSchema
	//	*ReadRowsResponse_ArrowSchema
	Schema        isReadRowsResponse_Schema `protobuf_oneof:"schema"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *ReadRowsResponse) Reset() {
	*x = ReadRowsResponse{}
	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[4]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *ReadRowsResponse) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*ReadRowsResponse) ProtoMessage() {}

func (x *ReadRowsResponse) ProtoReflect() protoreflect.Message {
	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[4]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use ReadRowsResponse.ProtoReflect.Descriptor instead.
func (*ReadRowsResponse) Descriptor() ([]byte, []int) {
	return file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescGZIP(), []int{4}
}

func (x *ReadRowsResponse) GetRows() isReadRowsResponse_Rows {
	if x != nil {
		return x.Rows
	}
	return nil
}

func (x *ReadRowsResponse) GetAvroRows() *AvroRows {
	if x != nil {
		if x, ok := x.Rows.(*ReadRowsResponse_AvroRows); ok {
			return x.AvroRows
		}
	}
	return nil
}

func (x *ReadRowsResponse) GetArrowRecordBatch() *ArrowRecordBatch {
	if x != nil {
		if x, ok := x.Rows.(*ReadRowsResponse_ArrowRecordBatch); ok {
			return x.ArrowRecordBatch
		}
	}
	return nil
}

func (x *ReadRowsResponse) GetRowCount() int64 {
	if x != nil {
		return x.RowCount
	}
	return 0
}

func (x *ReadRowsResponse) GetStats() *StreamStats {
	if x != nil {
		return x.Stats
	}
	return nil
}

func (x *ReadRowsResponse) GetThrottleState() *ThrottleState {
	if x != nil {
		return x.ThrottleState
	}
	return nil
}

func (x *ReadRowsResponse) GetSchema() isReadRowsResponse_Schema {
	if x != nil {
		return x.Schema
	}
	return nil
}

func (x *ReadRowsResponse) GetAvroSchema() *AvroSchema {
	if x != nil {
		if x, ok := x.Schema.(*ReadRowsResponse_AvroSchema); ok {
			return x.AvroSchema
		}
	}
	return nil
}

func (x *ReadRowsResponse) GetArrowSchema() *ArrowSchema {
	if x != nil {
		if x, ok := x.Schema.(*ReadRowsResponse_ArrowSchema); ok {
			return x.ArrowSchema
		}
	}
	return nil
}

type isReadRowsResponse_Rows interface {
	isReadRowsResponse_Rows()
}

type ReadRowsResponse_AvroRows struct {
	// Serialized row data in AVRO format.
	AvroRows *AvroRows `protobuf:"bytes,3,opt,name=avro_rows,json=avroRows,proto3,oneof"`
}

type ReadRowsResponse_ArrowRecordBatch struct {
	// Serialized row data in Arrow RecordBatch format.
	ArrowRecordBatch *ArrowRecordBatch `protobuf:"bytes,4,opt,name=arrow_record_batch,json=arrowRecordBatch,proto3,oneof"`
}

func (*ReadRowsResponse_AvroRows) isReadRowsResponse_Rows() {}

func (*ReadRowsResponse_ArrowRecordBatch) isReadRowsResponse_Rows() {}

type isReadRowsResponse_Schema interface {
	isReadRowsResponse_Schema()
}

type ReadRowsResponse_AvroSchema struct {
	// Output only. Avro schema.
	AvroSchema *AvroSchema `protobuf:"bytes,7,opt,name=avro_schema,json=avroSchema,proto3,oneof"`
}

type ReadRowsResponse_ArrowSchema struct {
	// Output only. Arrow schema.
	ArrowSchema *ArrowSchema `protobuf:"bytes,8,opt,name=arrow_schema,json=arrowSchema,proto3,oneof"`
}

func (*ReadRowsResponse_AvroSchema) isReadRowsResponse_Schema() {}

func (*ReadRowsResponse_ArrowSchema) isReadRowsResponse_Schema() {}

// Request message for `SplitReadStream`.
type SplitReadStreamRequest struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// Required. Name of the stream to split.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// 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 a data storage boundary on the server side.
	Fraction      float64 `protobuf:"fixed64,2,opt,name=fraction,proto3" json:"fraction,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *SplitReadStreamRequest) Reset() {
	*x = SplitReadStreamRequest{}
	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[5]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *SplitReadStreamRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*SplitReadStreamRequest) ProtoMessage() {}

func (x *SplitReadStreamRequest) ProtoReflect() protoreflect.Message {
	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[5]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use SplitReadStreamRequest.ProtoReflect.Descriptor instead.
func (*SplitReadStreamRequest) Descriptor() ([]byte, []int) {
	return file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescGZIP(), []int{5}
}

func (x *SplitReadStreamRequest) GetName() string {
	if x != nil {
		return x.Name
	}
	return ""
}

func (x *SplitReadStreamRequest) GetFraction() float64 {
	if x != nil {
		return x.Fraction
	}
	return 0
}

type SplitReadStreamResponse struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// Primary stream, which contains the beginning portion of
	// |original_stream|. An empty value indicates that the original stream can no
	// longer be split.
	PrimaryStream *ReadStream `protobuf:"bytes,1,opt,name=primary_stream,json=primaryStream,proto3" json:"primary_stream,omitempty"`
	// Remainder stream, which contains the tail of |original_stream|. An empty
	// value indicates that the original stream can no longer be split.
	RemainderStream *ReadStream `protobuf:"bytes,2,opt,name=remainder_stream,json=remainderStream,proto3" json:"remainder_stream,omitempty"`
	unknownFields   protoimpl.UnknownFields
	sizeCache       protoimpl.SizeCache
}

func (x *SplitReadStreamResponse) Reset() {
	*x = SplitReadStreamResponse{}
	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[6]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *SplitReadStreamResponse) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*SplitReadStreamResponse) ProtoMessage() {}

func (x *SplitReadStreamResponse) ProtoReflect() protoreflect.Message {
	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[6]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use SplitReadStreamResponse.ProtoReflect.Descriptor instead.
func (*SplitReadStreamResponse) Descriptor() ([]byte, []int) {
	return file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescGZIP(), []int{6}
}

func (x *SplitReadStreamResponse) GetPrimaryStream() *ReadStream {
	if x != nil {
		return x.PrimaryStream
	}
	return nil
}

func (x *SplitReadStreamResponse) GetRemainderStream() *ReadStream {
	if x != nil {
		return x.RemainderStream
	}
	return nil
}

// Request message for `CreateWriteStream`.
type CreateWriteStreamRequest struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// Required. Reference to the table to which the stream belongs, in the format
	// of `projects/{project}/datasets/{dataset}/tables/{table}`.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Required. Stream to be created.
	WriteStream   *WriteStream `protobuf:"bytes,2,opt,name=write_stream,json=writeStream,proto3" json:"write_stream,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *CreateWriteStreamRequest) Reset() {
	*x = CreateWriteStreamRequest{}
	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[7]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *CreateWriteStreamRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*CreateWriteStreamRequest) ProtoMessage() {}

func (x *CreateWriteStreamRequest) ProtoReflect() protoreflect.Message {
	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[7]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use CreateWriteStreamRequest.ProtoReflect.Descriptor instead.
func (*CreateWriteStreamRequest) Descriptor() ([]byte, []int) {
	return file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescGZIP(), []int{7}
}

func (x *CreateWriteStreamRequest) GetParent() string {
	if x != nil {
		return x.Parent
	}
	return ""
}

func (x *CreateWriteStreamRequest) GetWriteStream() *WriteStream {
	if x != nil {
		return x.WriteStream
	}
	return nil
}

// Request message for `AppendRows`.
type AppendRowsRequest struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// Required. The stream that is the target of the append operation. This value
	// must be specified for the initial request. If subsequent requests specify
	// the stream name, it must equal to the value provided in the first request.
	// To write to the _default stream, populate this field with a string in the
	// format `projects/{project}/datasets/{dataset}/tables/{table}/_default`.
	WriteStream string `protobuf:"bytes,1,opt,name=write_stream,json=writeStream,proto3" json:"write_stream,omitempty"`
	// If present, the write is only performed if the next append offset is same
	// as the provided value. If not present, the write is performed at the
	// current end of stream. Specifying a value for this field is not allowed
	// when calling AppendRows for the '_default' stream.
	Offset *wrapperspb.Int64Value `protobuf:"bytes,2,opt,name=offset,proto3" json:"offset,omitempty"`
	// Input rows. The `writer_schema` field must be specified at the initial
	// request and currently, it will be ignored if specified in following
	// requests. Following requests must have data in the same format as the
	// initial request.
	//
	// Types that are valid to be assigned to Rows:
	//
	//	*AppendRowsRequest_ProtoRows
	Rows isAppendRowsRequest_Rows `protobuf_oneof:"rows"`
	// Id set by client to annotate its identity. Only initial request setting is
	// respected.
	TraceId       string `protobuf:"bytes,6,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *AppendRowsRequest) Reset() {
	*x = AppendRowsRequest{}
	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[8]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *AppendRowsRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*AppendRowsRequest) ProtoMessage() {}

func (x *AppendRowsRequest) ProtoReflect() protoreflect.Message {
	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[8]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use AppendRowsRequest.ProtoReflect.Descriptor instead.
func (*AppendRowsRequest) Descriptor() ([]byte, []int) {
	return file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescGZIP(), []int{8}
}

func (x *AppendRowsRequest) GetWriteStream() string {
	if x != nil {
		return x.WriteStream
	}
	return ""
}

func (x *AppendRowsRequest) GetOffset() *wrapperspb.Int64Value {
	if x != nil {
		return x.Offset
	}
	return nil
}

func (x *AppendRowsRequest) GetRows() isAppendRowsRequest_Rows {
	if x != nil {
		return x.Rows
	}
	return nil
}

func (x *AppendRowsRequest) GetProtoRows() *AppendRowsRequest_ProtoData {
	if x != nil {
		if x, ok := x.Rows.(*AppendRowsRequest_ProtoRows); ok {
			return x.ProtoRows
		}
	}
	return nil
}

func (x *AppendRowsRequest) GetTraceId() string {
	if x != nil {
		return x.TraceId
	}
	return ""
}

type isAppendRowsRequest_Rows interface {
	isAppendRowsRequest_Rows()
}

type AppendRowsRequest_ProtoRows struct {
	// Rows in proto format.
	ProtoRows *AppendRowsRequest_ProtoData `protobuf:"bytes,4,opt,name=proto_rows,json=protoRows,proto3,oneof"`
}

func (*AppendRowsRequest_ProtoRows) isAppendRowsRequest_Rows() {}

// Response message for `AppendRows`.
type AppendRowsResponse struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// Types that are valid to be assigned to Response:
	//
	//	*AppendRowsResponse_AppendResult_
	//	*AppendRowsResponse_Error
	Response isAppendRowsResponse_Response `protobuf_oneof:"response"`
	// If backend detects a schema update, pass it to user so that user can
	// use it to input new type of message. It will be empty when no schema
	// updates have occurred.
	UpdatedSchema *TableSchema `protobuf:"bytes,3,opt,name=updated_schema,json=updatedSchema,proto3" json:"updated_schema,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *AppendRowsResponse) Reset() {
	*x = AppendRowsResponse{}
	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[9]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *AppendRowsResponse) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*AppendRowsResponse) ProtoMessage() {}

func (x *AppendRowsResponse) ProtoReflect() protoreflect.Message {
	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[9]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use AppendRowsResponse.ProtoReflect.Descriptor instead.
func (*AppendRowsResponse) Descriptor() ([]byte, []int) {
	return file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescGZIP(), []int{9}
}

func (x *AppendRowsResponse) GetResponse() isAppendRowsResponse_Response {
	if x != nil {
		return x.Response
	}
	return nil
}

func (x *AppendRowsResponse) GetAppendResult() *AppendRowsResponse_AppendResult {
	if x != nil {
		if x, ok := x.Response.(*AppendRowsResponse_AppendResult_); ok {
			return x.AppendResult
		}
	}
	return nil
}

func (x *AppendRowsResponse) GetError() *status.Status {
	if x != nil {
		if x, ok := x.Response.(*AppendRowsResponse_Error); ok {
			return x.Error
		}
	}
	return nil
}

func (x *AppendRowsResponse) GetUpdatedSchema() *TableSchema {
	if x != nil {
		return x.UpdatedSchema
	}
	return nil
}

type isAppendRowsResponse_Response interface {
	isAppendRowsResponse_Response()
}

type AppendRowsResponse_AppendResult_ struct {
	// Result if the append is successful.
	AppendResult *AppendRowsResponse_AppendResult `protobuf:"bytes,1,opt,name=append_result,json=appendResult,proto3,oneof"`
}

type AppendRowsResponse_Error struct {
	// Error returned when problems were encountered.  If present,
	// it indicates rows were not accepted into the system.
	// Users can retry or continue with other append requests within the
	// same connection.
	//
	// Additional information about error signalling:
	//
	// ALREADY_EXISTS: Happens when an append specified an offset, and the
	// backend already has received data at this offset.  Typically encountered
	// in retry scenarios, and can be ignored.
	//
	// OUT_OF_RANGE: Returned when the specified offset in the stream is beyond
	// the current end of the stream.
	//
	// INVALID_ARGUMENT: Indicates a malformed request or data.
	//
	// ABORTED: Request processing is aborted because of prior failures.  The
	// request can be retried if previous failure is addressed.
	//
	// INTERNAL: Indicates server side error(s) that can be retried.
	Error *status.Status `protobuf:"bytes,2,opt,name=error,proto3,oneof"`
}

func (*AppendRowsResponse_AppendResult_) isAppendRowsResponse_Response() {}

func (*AppendRowsResponse_Error) isAppendRowsResponse_Response() {}

// Request message for `GetWriteStreamRequest`.
type GetWriteStreamRequest struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// Required. Name of the stream to get, in the form of
	// `projects/{project}/datasets/{dataset}/tables/{table}/streams/{stream}`.
	Name          string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *GetWriteStreamRequest) Reset() {
	*x = GetWriteStreamRequest{}
	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[10]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *GetWriteStreamRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*GetWriteStreamRequest) ProtoMessage() {}

func (x *GetWriteStreamRequest) ProtoReflect() protoreflect.Message {
	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[10]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use GetWriteStreamRequest.ProtoReflect.Descriptor instead.
func (*GetWriteStreamRequest) Descriptor() ([]byte, []int) {
	return file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescGZIP(), []int{10}
}

func (x *GetWriteStreamRequest) GetName() string {
	if x != nil {
		return x.Name
	}
	return ""
}

// Request message for `BatchCommitWriteStreams`.
type BatchCommitWriteStreamsRequest struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// Required. Parent table that all the streams should belong to, in the form
	// of `projects/{project}/datasets/{dataset}/tables/{table}`.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Required. The group of streams that will be committed atomically.
	WriteStreams  []string `protobuf:"bytes,2,rep,name=write_streams,json=writeStreams,proto3" json:"write_streams,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *BatchCommitWriteStreamsRequest) Reset() {
	*x = BatchCommitWriteStreamsRequest{}
	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[11]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *BatchCommitWriteStreamsRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*BatchCommitWriteStreamsRequest) ProtoMessage() {}

func (x *BatchCommitWriteStreamsRequest) ProtoReflect() protoreflect.Message {
	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[11]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use BatchCommitWriteStreamsRequest.ProtoReflect.Descriptor instead.
func (*BatchCommitWriteStreamsRequest) Descriptor() ([]byte, []int) {
	return file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescGZIP(), []int{11}
}

func (x *BatchCommitWriteStreamsRequest) GetParent() string {
	if x != nil {
		return x.Parent
	}
	return ""
}

func (x *BatchCommitWriteStreamsRequest) GetWriteStreams() []string {
	if x != nil {
		return x.WriteStreams
	}
	return nil
}

// Response message for `BatchCommitWriteStreams`.
type BatchCommitWriteStreamsResponse struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// The time at which streams were committed in microseconds granularity.
	// This field will only exist when there are no stream errors.
	// **Note** if this field is not set, it means the commit was not successful.
	CommitTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=commit_time,json=commitTime,proto3" json:"commit_time,omitempty"`
	// Stream level error if commit failed. Only streams with error will be in
	// the list.
	// If empty, there is no error and all streams are committed successfully.
	// If non empty, certain streams have errors and ZERO stream is committed due
	// to atomicity guarantee.
	StreamErrors  []*StorageError `protobuf:"bytes,2,rep,name=stream_errors,json=streamErrors,proto3" json:"stream_errors,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *BatchCommitWriteStreamsResponse) Reset() {
	*x = BatchCommitWriteStreamsResponse{}
	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[12]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *BatchCommitWriteStreamsResponse) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*BatchCommitWriteStreamsResponse) ProtoMessage() {}

func (x *BatchCommitWriteStreamsResponse) ProtoReflect() protoreflect.Message {
	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[12]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use BatchCommitWriteStreamsResponse.ProtoReflect.Descriptor instead.
func (*BatchCommitWriteStreamsResponse) Descriptor() ([]byte, []int) {
	return file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescGZIP(), []int{12}
}

func (x *BatchCommitWriteStreamsResponse) GetCommitTime() *timestamppb.Timestamp {
	if x != nil {
		return x.CommitTime
	}
	return nil
}

func (x *BatchCommitWriteStreamsResponse) GetStreamErrors() []*StorageError {
	if x != nil {
		return x.StreamErrors
	}
	return nil
}

// Request message for invoking `FinalizeWriteStream`.
type FinalizeWriteStreamRequest struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// Required. Name of the stream to finalize, in the form of
	// `projects/{project}/datasets/{dataset}/tables/{table}/streams/{stream}`.
	Name          string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *FinalizeWriteStreamRequest) Reset() {
	*x = FinalizeWriteStreamRequest{}
	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[13]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *FinalizeWriteStreamRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*FinalizeWriteStreamRequest) ProtoMessage() {}

func (x *FinalizeWriteStreamRequest) ProtoReflect() protoreflect.Message {
	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[13]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use FinalizeWriteStreamRequest.ProtoReflect.Descriptor instead.
func (*FinalizeWriteStreamRequest) Descriptor() ([]byte, []int) {
	return file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescGZIP(), []int{13}
}

func (x *FinalizeWriteStreamRequest) GetName() string {
	if x != nil {
		return x.Name
	}
	return ""
}

// Response message for `FinalizeWriteStream`.
type FinalizeWriteStreamResponse struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// Number of rows in the finalized stream.
	RowCount      int64 `protobuf:"varint,1,opt,name=row_count,json=rowCount,proto3" json:"row_count,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *FinalizeWriteStreamResponse) Reset() {
	*x = FinalizeWriteStreamResponse{}
	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[14]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *FinalizeWriteStreamResponse) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*FinalizeWriteStreamResponse) ProtoMessage() {}

func (x *FinalizeWriteStreamResponse) ProtoReflect() protoreflect.Message {
	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[14]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use FinalizeWriteStreamResponse.ProtoReflect.Descriptor instead.
func (*FinalizeWriteStreamResponse) Descriptor() ([]byte, []int) {
	return file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescGZIP(), []int{14}
}

func (x *FinalizeWriteStreamResponse) GetRowCount() int64 {
	if x != nil {
		return x.RowCount
	}
	return 0
}

// Request message for `FlushRows`.
type FlushRowsRequest struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// Required. The stream that is the target of the flush operation.
	WriteStream string `protobuf:"bytes,1,opt,name=write_stream,json=writeStream,proto3" json:"write_stream,omitempty"`
	// Ending offset of the flush operation. Rows before this offset(including
	// this offset) will be flushed.
	Offset        *wrapperspb.Int64Value `protobuf:"bytes,2,opt,name=offset,proto3" json:"offset,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *FlushRowsRequest) Reset() {
	*x = FlushRowsRequest{}
	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[15]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *FlushRowsRequest) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*FlushRowsRequest) ProtoMessage() {}

func (x *FlushRowsRequest) ProtoReflect() protoreflect.Message {
	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[15]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use FlushRowsRequest.ProtoReflect.Descriptor instead.
func (*FlushRowsRequest) Descriptor() ([]byte, []int) {
	return file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescGZIP(), []int{15}
}

func (x *FlushRowsRequest) GetWriteStream() string {
	if x != nil {
		return x.WriteStream
	}
	return ""
}

func (x *FlushRowsRequest) GetOffset() *wrapperspb.Int64Value {
	if x != nil {
		return x.Offset
	}
	return nil
}

// Respond message for `FlushRows`.
type FlushRowsResponse struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// The rows before this offset (including this offset) are flushed.
	Offset        int64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *FlushRowsResponse) Reset() {
	*x = FlushRowsResponse{}
	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[16]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *FlushRowsResponse) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*FlushRowsResponse) ProtoMessage() {}

func (x *FlushRowsResponse) ProtoReflect() protoreflect.Message {
	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[16]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use FlushRowsResponse.ProtoReflect.Descriptor instead.
func (*FlushRowsResponse) Descriptor() ([]byte, []int) {
	return file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescGZIP(), []int{16}
}

func (x *FlushRowsResponse) GetOffset() int64 {
	if x != nil {
		return x.Offset
	}
	return 0
}

// Structured custom BigQuery Storage error message. The error can be attached
// as error details in the returned rpc Status. In particular, the use of error
// codes allows more structured error handling, and reduces the need to evaluate
// unstructured error text strings.
type StorageError struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// BigQuery Storage specific error code.
	Code StorageError_StorageErrorCode `protobuf:"varint,1,opt,name=code,proto3,enum=google.cloud.bigquery.storage.v1beta2.StorageError_StorageErrorCode" json:"code,omitempty"`
	// Name of the failed entity.
	Entity string `protobuf:"bytes,2,opt,name=entity,proto3" json:"entity,omitempty"`
	// Message that describes the error.
	ErrorMessage  string `protobuf:"bytes,3,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *StorageError) Reset() {
	*x = StorageError{}
	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[17]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *StorageError) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*StorageError) ProtoMessage() {}

func (x *StorageError) ProtoReflect() protoreflect.Message {
	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[17]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use StorageError.ProtoReflect.Descriptor instead.
func (*StorageError) Descriptor() ([]byte, []int) {
	return file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescGZIP(), []int{17}
}

func (x *StorageError) GetCode() StorageError_StorageErrorCode {
	if x != nil {
		return x.Code
	}
	return StorageError_STORAGE_ERROR_CODE_UNSPECIFIED
}

func (x *StorageError) GetEntity() string {
	if x != nil {
		return x.Entity
	}
	return ""
}

func (x *StorageError) GetErrorMessage() string {
	if x != nil {
		return x.ErrorMessage
	}
	return ""
}

type StreamStats_Progress struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// 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.
	AtResponseStart float64 `protobuf:"fixed64,1,opt,name=at_response_start,json=atResponseStart,proto3" json:"at_response_start,omitempty"`
	// Similar to `at_response_start`, except that this value includes the
	// rows in the current response.
	AtResponseEnd float64 `protobuf:"fixed64,2,opt,name=at_response_end,json=atResponseEnd,proto3" json:"at_response_end,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *StreamStats_Progress) Reset() {
	*x = StreamStats_Progress{}
	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[18]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *StreamStats_Progress) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*StreamStats_Progress) ProtoMessage() {}

func (x *StreamStats_Progress) ProtoReflect() protoreflect.Message {
	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[18]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use StreamStats_Progress.ProtoReflect.Descriptor instead.
func (*StreamStats_Progress) Descriptor() ([]byte, []int) {
	return file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescGZIP(), []int{3, 0}
}

func (x *StreamStats_Progress) GetAtResponseStart() float64 {
	if x != nil {
		return x.AtResponseStart
	}
	return 0
}

func (x *StreamStats_Progress) GetAtResponseEnd() float64 {
	if x != nil {
		return x.AtResponseEnd
	}
	return 0
}

// Proto schema and data.
type AppendRowsRequest_ProtoData struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// Proto schema used to serialize the data.
	WriterSchema *ProtoSchema `protobuf:"bytes,1,opt,name=writer_schema,json=writerSchema,proto3" json:"writer_schema,omitempty"`
	// Serialized row data in protobuf message format.
	Rows          *ProtoRows `protobuf:"bytes,2,opt,name=rows,proto3" json:"rows,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *AppendRowsRequest_ProtoData) Reset() {
	*x = AppendRowsRequest_ProtoData{}
	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[19]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *AppendRowsRequest_ProtoData) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*AppendRowsRequest_ProtoData) ProtoMessage() {}

func (x *AppendRowsRequest_ProtoData) ProtoReflect() protoreflect.Message {
	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[19]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use AppendRowsRequest_ProtoData.ProtoReflect.Descriptor instead.
func (*AppendRowsRequest_ProtoData) Descriptor() ([]byte, []int) {
	return file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescGZIP(), []int{8, 0}
}

func (x *AppendRowsRequest_ProtoData) GetWriterSchema() *ProtoSchema {
	if x != nil {
		return x.WriterSchema
	}
	return nil
}

func (x *AppendRowsRequest_ProtoData) GetRows() *ProtoRows {
	if x != nil {
		return x.Rows
	}
	return nil
}

// AppendResult is returned for successful append requests.
type AppendRowsResponse_AppendResult struct {
	state protoimpl.MessageState `protogen:"open.v1"`
	// The row offset at which the last append occurred. The offset will not be
	// set if appending using default streams.
	Offset        *wrapperspb.Int64Value `protobuf:"bytes,1,opt,name=offset,proto3" json:"offset,omitempty"`
	unknownFields protoimpl.UnknownFields
	sizeCache     protoimpl.SizeCache
}

func (x *AppendRowsResponse_AppendResult) Reset() {
	*x = AppendRowsResponse_AppendResult{}
	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[20]
	ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
	ms.StoreMessageInfo(mi)
}

func (x *AppendRowsResponse_AppendResult) String() string {
	return protoimpl.X.MessageStringOf(x)
}

func (*AppendRowsResponse_AppendResult) ProtoMessage() {}

func (x *AppendRowsResponse_AppendResult) ProtoReflect() protoreflect.Message {
	mi := &file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[20]
	if x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}

// Deprecated: Use AppendRowsResponse_AppendResult.ProtoReflect.Descriptor instead.
func (*AppendRowsResponse_AppendResult) Descriptor() ([]byte, []int) {
	return file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescGZIP(), []int{9, 0}
}

func (x *AppendRowsResponse_AppendResult) GetOffset() *wrapperspb.Int64Value {
	if x != nil {
		return x.Offset
	}
	return nil
}

var File_google_cloud_bigquery_storage_v1beta2_storage_proto protoreflect.FileDescriptor

const file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDesc = "" +
	"\n" +
	"3google/cloud/bigquery/storage/v1beta2/storage.proto\x12%google.cloud.bigquery.storage.v1beta2\x1a\x1cgoogle/api/annotations.proto\x1a\x17google/api/client.proto\x1a\x1fgoogle/api/field_behavior.proto\x1a\x19google/api/resource.proto\x1a1google/cloud/bigquery/storage/v1beta2/arrow.proto\x1a0google/cloud/bigquery/storage/v1beta2/avro.proto\x1a4google/cloud/bigquery/storage/v1beta2/protobuf.proto\x1a2google/cloud/bigquery/storage/v1beta2/stream.proto\x1a1google/cloud/bigquery/storage/v1beta2/table.proto\x1a\x1fgoogle/protobuf/timestamp.proto\x1a\x1egoogle/protobuf/wrappers.proto\x1a\x17google/rpc/status.proto\"\xed\x01\n" +
	"\x18CreateReadSessionRequest\x12K\n" +
	"\x06parent\x18\x01 \x01(\tB3\xe0A\x02\xfaA-\n" +
	"+cloudresourcemanager.googleapis.com/ProjectR\x06parent\x12Z\n" +
	"\fread_session\x18\x02 \x01(\v22.google.cloud.bigquery.storage.v1beta2.ReadSessionB\x03\xe0A\x02R\vreadSession\x12(\n" +
	"\x10max_stream_count\x18\x03 \x01(\x05R\x0emaxStreamCount\"}\n" +
	"\x0fReadRowsRequest\x12R\n" +
	"\vread_stream\x18\x01 \x01(\tB1\xe0A\x02\xfaA+\n" +
	")bigquerystorage.googleapis.com/ReadStreamR\n" +
	"readStream\x12\x16\n" +
	"\x06offset\x18\x02 \x01(\x03R\x06offset\":\n" +
	"\rThrottleState\x12)\n" +
	"\x10throttle_percent\x18\x01 \x01(\x05R\x0fthrottlePercent\"\xc6\x01\n" +
	"\vStreamStats\x12W\n" +
	"\bprogress\x18\x02 \x01(\v2;.google.cloud.bigquery.storage.v1beta2.StreamStats.ProgressR\bprogress\x1a^\n" +
	"\bProgress\x12*\n" +
	"\x11at_response_start\x18\x01 \x01(\x01R\x0fatResponseStart\x12&\n" +
	"\x0fat_response_end\x18\x02 \x01(\x01R\ratResponseEnd\"\xda\x04\n" +
	"\x10ReadRowsResponse\x12N\n" +
	"\tavro_rows\x18\x03 \x01(\v2/.google.cloud.bigquery.storage.v1beta2.AvroRowsH\x00R\bavroRows\x12g\n" +
	"\x12arrow_record_batch\x18\x04 \x01(\v27.google.cloud.bigquery.storage.v1beta2.ArrowRecordBatchH\x00R\x10arrowRecordBatch\x12\x1b\n" +
	"\trow_count\x18\x06 \x01(\x03R\browCount\x12H\n" +
	"\x05stats\x18\x02 \x01(\v22.google.cloud.bigquery.storage.v1beta2.StreamStatsR\x05stats\x12[\n" +
	"\x0ethrottle_state\x18\x05 \x01(\v24.google.cloud.bigquery.storage.v1beta2.ThrottleStateR\rthrottleState\x12Y\n" +
	"\vavro_schema\x18\a \x01(\v21.google.cloud.bigquery.storage.v1beta2.AvroSchemaB\x03\xe0A\x03H\x01R\n" +
	"avroSchema\x12\\\n" +
	"\farrow_schema\x18\b \x01(\v22.google.cloud.bigquery.storage.v1beta2.ArrowSchemaB\x03\xe0A\x03H\x01R\varrowSchemaB\x06\n" +
	"\x04rowsB\b\n" +
	"\x06schema\"{\n" +
	"\x16SplitReadStreamRequest\x12E\n" +
	"\x04name\x18\x01 \x01(\tB1\xe0A\x02\xfaA+\n" +
	")bigquerystorage.googleapis.com/ReadStreamR\x04name\x12\x1a\n" +
	"\bfraction\x18\x02 \x01(\x01R\bfraction\"\xd1\x01\n" +
	"\x17SplitReadStreamResponse\x12X\n" +
	"\x0eprimary_stream\x18\x01 \x01(\v21.google.cloud.bigquery.storage.v1beta2.ReadStreamR\rprimaryStream\x12\\\n" +
	"\x10remainder_stream\x18\x02 \x01(\v21.google.cloud.bigquery.storage.v1beta2.ReadStreamR\x0fremainderStream\"\xb5\x01\n" +
	"\x18CreateWriteStreamRequest\x12=\n" +
	"\x06parent\x18\x01 \x01(\tB%\xe0A\x02\xfaA\x1f\n" +
	"\x1dbigquery.googleapis.com/TableR\x06parent\x12Z\n" +
	"\fwrite_stream\x18\x02 \x01(\v22.google.cloud.bigquery.storage.v1beta2.WriteStreamB\x03\xe0A\x02R\vwriteStream\"\xd4\x03\n" +
	"\x11AppendRowsRequest\x12U\n" +
	"\fwrite_stream\x18\x01 \x01(\tB2\xe0A\x02\xfaA,\n" +
	"*bigquerystorage.googleapis.com/WriteStreamR\vwriteStream\x123\n" +
	"\x06offset\x18\x02 \x01(\v2\x1b.google.protobuf.Int64ValueR\x06offset\x12c\n" +
	"\n" +
	"proto_rows\x18\x04 \x01(\v2B.google.cloud.bigquery.storage.v1beta2.AppendRowsRequest.ProtoDataH\x00R\tprotoRows\x12\x19\n" +
	"\btrace_id\x18\x06 \x01(\tR\atraceId\x1a\xaa\x01\n" +
	"\tProtoData\x12W\n" +
	"\rwriter_schema\x18\x01 \x01(\v22.google.cloud.bigquery.storage.v1beta2.ProtoSchemaR\fwriterSchema\x12D\n" +
	"\x04rows\x18\x02 \x01(\v20.google.cloud.bigquery.storage.v1beta2.ProtoRowsR\x04rowsB\x06\n" +
	"\x04rows\"\xdb\x02\n" +
	"\x12AppendRowsResponse\x12m\n" +
	"\rappend_result\x18\x01 \x01(\v2F.google.cloud.bigquery.storage.v1beta2.AppendRowsResponse.AppendResultH\x00R\fappendResult\x12*\n" +
	"\x05error\x18\x02 \x01(\v2\x12.google.rpc.StatusH\x00R\x05error\x12Y\n" +
	"\x0eupdated_schema\x18\x03 \x01(\v22.google.cloud.bigquery.storage.v1beta2.TableSchemaR\rupdatedSchema\x1aC\n" +
	"\fAppendResult\x123\n" +
	"\x06offset\x18\x01 \x01(\v2\x1b.google.protobuf.Int64ValueR\x06offsetB\n" +
	"\n" +
	"\bresponse\"_\n" +
	"\x15GetWriteStreamRequest\x12F\n" +
	"\x04name\x18\x01 \x01(\tB2\xe0A\x02\xfaA,\n" +
	"*bigquerystorage.googleapis.com/WriteStreamR\x04name\"g\n" +
	"\x1eBatchCommitWriteStreamsRequest\x12\x1b\n" +
	"\x06parent\x18\x01 \x01(\tB\x03\xe0A\x02R\x06parent\x12(\n" +
	"\rwrite_streams\x18\x02 \x03(\tB\x03\xe0A\x02R\fwriteStreams\"\xb8\x01\n" +
	"\x1fBatchCommitWriteStreamsResponse\x12;\n" +
	"\vcommit_time\x18\x01 \x01(\v2\x1a.google.protobuf.TimestampR\n" +
	"commitTime\x12X\n" +
	"\rstream_errors\x18\x02 \x03(\v23.google.cloud.bigquery.storage.v1beta2.StorageErrorR\fstreamErrors\"d\n" +
	"\x1aFinalizeWriteStreamRequest\x12F\n" +
	"\x04name\x18\x01 \x01(\tB2\xe0A\x02\xfaA,\n" +
	"*bigquerystorage.googleapis.com/WriteStreamR\x04name\":\n" +
	"\x1bFinalizeWriteStreamResponse\x12\x1b\n" +
	"\trow_count\x18\x01 \x01(\x03R\browCount\"\x9e\x01\n" +
	"\x10FlushRowsRequest\x12U\n" +
	"\fwrite_stream\x18\x01 \x01(\tB2\xe0A\x02\xfaA,\n" +
	"*bigquerystorage.googleapis.com/WriteStreamR\vwriteStream\x123\n" +
	"\x06offset\x18\x02 \x01(\v2\x1b.google.protobuf.Int64ValueR\x06offset\"+\n" +
	"\x11FlushRowsResponse\x12\x16\n" +
	"\x06offset\x18\x01 \x01(\x03R\x06offset\"\xf0\x02\n" +
	"\fStorageError\x12X\n" +
	"\x04code\x18\x01 \x01(\x0e2D.google.cloud.bigquery.storage.v1beta2.StorageError.StorageErrorCodeR\x04code\x12\x16\n" +
	"\x06entity\x18\x02 \x01(\tR\x06entity\x12#\n" +
	"\rerror_message\x18\x03 \x01(\tR\ferrorMessage\"\xc8\x01\n" +
	"\x10StorageErrorCode\x12\"\n" +
	"\x1eSTORAGE_ERROR_CODE_UNSPECIFIED\x10\x00\x12\x13\n" +
	"\x0fTABLE_NOT_FOUND\x10\x01\x12\x1c\n" +
	"\x18STREAM_ALREADY_COMMITTED\x10\x02\x12\x14\n" +
	"\x10STREAM_NOT_FOUND\x10\x03\x12\x17\n" +
	"\x13INVALID_STREAM_TYPE\x10\x04\x12\x18\n" +
	"\x14INVALID_STREAM_STATE\x10\x05\x12\x14\n" +
	"\x10STREAM_FINALIZED\x10\x062\xbf\x06\n" +
	"\fBigQueryRead\x12\xf8\x01\n" +
	"\x11CreateReadSession\x12?.google.cloud.bigquery.storage.v1beta2.CreateReadSessionRequest\x1a2.google.cloud.bigquery.storage.v1beta2.ReadSession\"n\xdaA$parent,read_session,max_stream_count\x82\xd3\xe4\x93\x02A:\x01*\"</v1beta2/{read_session.table=projects/*/datasets/*/tables/*}\x12\xde\x01\n" +
	"\bReadRows\x126.google.cloud.bigquery.storage.v1beta2.ReadRowsRequest\x1a7.google.cloud.bigquery.storage.v1beta2.ReadRowsResponse\"_\xdaA\x12read_stream,offset\x82\xd3\xe4\x93\x02D\x12B/v1beta2/{read_stream=projects/*/locations/*/sessions/*/streams/*}0\x01\x12\xd5\x01\n" +
	"\x0fSplitReadStream\x12=.google.cloud.bigquery.storage.v1beta2.SplitReadStreamRequest\x1a>.google.cloud.bigquery.storage.v1beta2.SplitReadStreamResponse\"C\x82\xd3\xe4\x93\x02=\x12;/v1beta2/{name=projects/*/locations/*/sessions/*/streams/*}\x1a{\xcaA\x1ebigquerystorage.googleapis.com\xd2AWhttps://www.googleapis.com/auth/bigquery,https://www.googleapis.com/auth/cloud-platform2\xab\f\n" +
	"\rBigQueryWrite\x12\xe9\x01\n" +
	"\x11CreateWriteStream\x12?.google.cloud.bigquery.storage.v1beta2.CreateWriteStreamRequest\x1a2.google.cloud.bigquery.storage.v1beta2.WriteStream\"_\xdaA\x13parent,write_stream\x82\xd3\xe4\x93\x02@:\fwrite_stream\"0/v1beta2/{parent=projects/*/datasets/*/tables/*}\x88\x02\x01\x12\xe4\x01\n" +
	"\n" +
	"AppendRows\x128.google.cloud.bigquery.storage.v1beta2.AppendRowsRequest\x1a9.google.cloud.bigquery.storage.v1beta2.AppendRowsResponse\"]\xdaA\fwrite_stream\x82\xd3\xe4\x93\x02E:\x01*\"@/v1beta2/{write_stream=projects/*/datasets/*/tables/*/streams/*}\x88\x02\x01(\x010\x01\x12\xd1\x01\n" +
	"\x0eGetWriteStream\x12<.google.cloud.bigquery.storage.v1beta2.GetWriteStreamRequest\x1a2.google.cloud.bigquery.storage.v1beta2.WriteStream\"M\xdaA\x04name\x82\xd3\xe4\x93\x02=:\x01*\"8/v1beta2/{name=projects/*/datasets/*/tables/*/streams/*}\x88\x02\x01\x12\xeb\x01\n" +
	"\x13FinalizeWriteStream\x12A.google.cloud.bigquery.storage.v1beta2.FinalizeWriteStreamRequest\x1aB.google.cloud.bigquery.storage.v1beta2.FinalizeWriteStreamResponse\"M\xdaA\x04name\x82\xd3\xe4\x93\x02=:\x01*\"8/v1beta2/{name=projects/*/datasets/*/tables/*/streams/*}\x88\x02\x01\x12\xee\x01\n" +
	"\x17BatchCommitWriteStreams\x12E.google.cloud.bigquery.storage.v1beta2.BatchCommitWriteStreamsRequest\x1aF.google.cloud.bigquery.storage.v1beta2.BatchCommitWriteStreamsResponse\"D\xdaA\x06parent\x82\xd3\xe4\x93\x022\x120/v1beta2/{parent=projects/*/datasets/*/tables/*}\x88\x02\x01\x12\xdd\x01\n" +
	"\tFlushRows\x127.google.cloud.bigquery.storage.v1beta2.FlushRowsRequest\x1a8.google.cloud.bigquery.storage.v1beta2.FlushRowsResponse\"]\xdaA\fwrite_stream\x82\xd3\xe4\x93\x02E:\x01*\"@/v1beta2/{write_stream=projects/*/datasets/*/tables/*/streams/*}\x88\x02\x01\x1a\xb3\x01\xcaA\x1ebigquerystorage.googleapis.com\xd2A\x8b\x01https://www.googleapis.com/auth/bigquery,https://www.googleapis.com/auth/bigquery.insertdata,https://www.googleapis.com/auth/cloud-platform\x88\x02\x01B\x80\x01\n" +
	")com.google.cloud.bigquery.storage.v1beta2B\fStorageProtoP\x01ZCcloud.google.com/go/bigquery/storage/apiv1beta2/storagepb;storagepbb\x06proto3"

var (
	file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescOnce sync.Once
	file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescData []byte
)

func file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescGZIP() []byte {
	file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescOnce.Do(func() {
		file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescData = protoimpl.X.CompressGZIP(unsafe.Slice(unsafe.StringData(file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDesc), len(file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDesc)))
	})
	return file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDescData
}

var file_google_cloud_bigquery_storage_v1beta2_storage_proto_enumTypes = make([]protoimpl.EnumInfo, 1)
var file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes = make([]protoimpl.MessageInfo, 21)
var file_google_cloud_bigquery_storage_v1beta2_storage_proto_goTypes = []any{
	(StorageError_StorageErrorCode)(0),      // 0: google.cloud.bigquery.storage.v1beta2.StorageError.StorageErrorCode
	(*CreateReadSessionRequest)(nil),        // 1: google.cloud.bigquery.storage.v1beta2.CreateReadSessionRequest
	(*ReadRowsRequest)(nil),                 // 2: google.cloud.bigquery.storage.v1beta2.ReadRowsRequest
	(*ThrottleState)(nil),                   // 3: google.cloud.bigquery.storage.v1beta2.ThrottleState
	(*StreamStats)(nil),                     // 4: google.cloud.bigquery.storage.v1beta2.StreamStats
	(*ReadRowsResponse)(nil),                // 5: google.cloud.bigquery.storage.v1beta2.ReadRowsResponse
	(*SplitReadStreamRequest)(nil),          // 6: google.cloud.bigquery.storage.v1beta2.SplitReadStreamRequest
	(*SplitReadStreamResponse)(nil),         // 7: google.cloud.bigquery.storage.v1beta2.SplitReadStreamResponse
	(*CreateWriteStreamRequest)(nil),        // 8: google.cloud.bigquery.storage.v1beta2.CreateWriteStreamRequest
	(*AppendRowsRequest)(nil),               // 9: google.cloud.bigquery.storage.v1beta2.AppendRowsRequest
	(*AppendRowsResponse)(nil),              // 10: google.cloud.bigquery.storage.v1beta2.AppendRowsResponse
	(*GetWriteStreamRequest)(nil),           // 11: google.cloud.bigquery.storage.v1beta2.GetWriteStreamRequest
	(*BatchCommitWriteStreamsRequest)(nil),  // 12: google.cloud.bigquery.storage.v1beta2.BatchCommitWriteStreamsRequest
	(*BatchCommitWriteStreamsResponse)(nil), // 13: google.cloud.bigquery.storage.v1beta2.BatchCommitWriteStreamsResponse
	(*FinalizeWriteStreamRequest)(nil),      // 14: google.cloud.bigquery.storage.v1beta2.FinalizeWriteStreamRequest
	(*FinalizeWriteStreamResponse)(nil),     // 15: google.cloud.bigquery.storage.v1beta2.FinalizeWriteStreamResponse
	(*FlushRowsRequest)(nil),                // 16: google.cloud.bigquery.storage.v1beta2.FlushRowsRequest
	(*FlushRowsResponse)(nil),               // 17: google.cloud.bigquery.storage.v1beta2.FlushRowsResponse
	(*StorageError)(nil),                    // 18: google.cloud.bigquery.storage.v1beta2.StorageError
	(*StreamStats_Progress)(nil),            // 19: google.cloud.bigquery.storage.v1beta2.StreamStats.Progress
	(*AppendRowsRequest_ProtoData)(nil),     // 20: google.cloud.bigquery.storage.v1beta2.AppendRowsRequest.ProtoData
	(*AppendRowsResponse_AppendResult)(nil), // 21: google.cloud.bigquery.storage.v1beta2.AppendRowsResponse.AppendResult
	(*ReadSession)(nil),                     // 22: google.cloud.bigquery.storage.v1beta2.ReadSession
	(*AvroRows)(nil),                        // 23: google.cloud.bigquery.storage.v1beta2.AvroRows
	(*ArrowRecordBatch)(nil),                // 24: google.cloud.bigquery.storage.v1beta2.ArrowRecordBatch
	(*AvroSchema)(nil),                      // 25: google.cloud.bigquery.storage.v1beta2.AvroSchema
	(*ArrowSchema)(nil),                     // 26: google.cloud.bigquery.storage.v1beta2.ArrowSchema
	(*ReadStream)(nil),                      // 27: google.cloud.bigquery.storage.v1beta2.ReadStream
	(*WriteStream)(nil),                     // 28: google.cloud.bigquery.storage.v1beta2.WriteStream
	(*wrapperspb.Int64Value)(nil),           // 29: google.protobuf.Int64Value
	(*status.Status)(nil),                   // 30: google.rpc.Status
	(*TableSchema)(nil),                     // 31: google.cloud.bigquery.storage.v1beta2.TableSchema
	(*timestamppb.Timestamp)(nil),           // 32: google.protobuf.Timestamp
	(*ProtoSchema)(nil),                     // 33: google.cloud.bigquery.storage.v1beta2.ProtoSchema
	(*ProtoRows)(nil),                       // 34: google.cloud.bigquery.storage.v1beta2.ProtoRows
}
var file_google_cloud_bigquery_storage_v1beta2_storage_proto_depIdxs = []int32{
	22, // 0: google.cloud.bigquery.storage.v1beta2.CreateReadSessionRequest.read_session:type_name -> google.cloud.bigquery.storage.v1beta2.ReadSession
	19, // 1: google.cloud.bigquery.storage.v1beta2.StreamStats.progress:type_name -> google.cloud.bigquery.storage.v1beta2.StreamStats.Progress
	23, // 2: google.cloud.bigquery.storage.v1beta2.ReadRowsResponse.avro_rows:type_name -> google.cloud.bigquery.storage.v1beta2.AvroRows
	24, // 3: google.cloud.bigquery.storage.v1beta2.ReadRowsResponse.arrow_record_batch:type_name -> google.cloud.bigquery.storage.v1beta2.ArrowRecordBatch
	4,  // 4: google.cloud.bigquery.storage.v1beta2.ReadRowsResponse.stats:type_name -> google.cloud.bigquery.storage.v1beta2.StreamStats
	3,  // 5: google.cloud.bigquery.storage.v1beta2.ReadRowsResponse.throttle_state:type_name -> google.cloud.bigquery.storage.v1beta2.ThrottleState
	25, // 6: google.cloud.bigquery.storage.v1beta2.ReadRowsResponse.avro_schema:type_name -> google.cloud.bigquery.storage.v1beta2.AvroSchema
	26, // 7: google.cloud.bigquery.storage.v1beta2.ReadRowsResponse.arrow_schema:type_name -> google.cloud.bigquery.storage.v1beta2.ArrowSchema
	27, // 8: google.cloud.bigquery.storage.v1beta2.SplitReadStreamResponse.primary_stream:type_name -> google.cloud.bigquery.storage.v1beta2.ReadStream
	27, // 9: google.cloud.bigquery.storage.v1beta2.SplitReadStreamResponse.remainder_stream:type_name -> google.cloud.bigquery.storage.v1beta2.ReadStream
	28, // 10: google.cloud.bigquery.storage.v1beta2.CreateWriteStreamRequest.write_stream:type_name -> google.cloud.bigquery.storage.v1beta2.WriteStream
	29, // 11: google.cloud.bigquery.storage.v1beta2.AppendRowsRequest.offset:type_name -> google.protobuf.Int64Value
	20, // 12: google.cloud.bigquery.storage.v1beta2.AppendRowsRequest.proto_rows:type_name -> google.cloud.bigquery.storage.v1beta2.AppendRowsRequest.ProtoData
	21, // 13: google.cloud.bigquery.storage.v1beta2.AppendRowsResponse.append_result:type_name -> google.cloud.bigquery.storage.v1beta2.AppendRowsResponse.AppendResult
	30, // 14: google.cloud.bigquery.storage.v1beta2.AppendRowsResponse.error:type_name -> google.rpc.Status
	31, // 15: google.cloud.bigquery.storage.v1beta2.AppendRowsResponse.updated_schema:type_name -> google.cloud.bigquery.storage.v1beta2.TableSchema
	32, // 16: google.cloud.bigquery.storage.v1beta2.BatchCommitWriteStreamsResponse.commit_time:type_name -> google.protobuf.Timestamp
	18, // 17: google.cloud.bigquery.storage.v1beta2.BatchCommitWriteStreamsResponse.stream_errors:type_name -> google.cloud.bigquery.storage.v1beta2.StorageError
	29, // 18: google.cloud.bigquery.storage.v1beta2.FlushRowsRequest.offset:type_name -> google.protobuf.Int64Value
	0,  // 19: google.cloud.bigquery.storage.v1beta2.StorageError.code:type_name -> google.cloud.bigquery.storage.v1beta2.StorageError.StorageErrorCode
	33, // 20: google.cloud.bigquery.storage.v1beta2.AppendRowsRequest.ProtoData.writer_schema:type_name -> google.cloud.bigquery.storage.v1beta2.ProtoSchema
	34, // 21: google.cloud.bigquery.storage.v1beta2.AppendRowsRequest.ProtoData.rows:type_name -> google.cloud.bigquery.storage.v1beta2.ProtoRows
	29, // 22: google.cloud.bigquery.storage.v1beta2.AppendRowsResponse.AppendResult.offset:type_name -> google.protobuf.Int64Value
	1,  // 23: google.cloud.bigquery.storage.v1beta2.BigQueryRead.CreateReadSession:input_type -> google.cloud.bigquery.storage.v1beta2.CreateReadSessionRequest
	2,  // 24: google.cloud.bigquery.storage.v1beta2.BigQueryRead.ReadRows:input_type -> google.cloud.bigquery.storage.v1beta2.ReadRowsRequest
	6,  // 25: google.cloud.bigquery.storage.v1beta2.BigQueryRead.SplitReadStream:input_type -> google.cloud.bigquery.storage.v1beta2.SplitReadStreamRequest
	8,  // 26: google.cloud.bigquery.storage.v1beta2.BigQueryWrite.CreateWriteStream:input_type -> google.cloud.bigquery.storage.v1beta2.CreateWriteStreamRequest
	9,  // 27: google.cloud.bigquery.storage.v1beta2.BigQueryWrite.AppendRows:input_type -> google.cloud.bigquery.storage.v1beta2.AppendRowsRequest
	11, // 28: google.cloud.bigquery.storage.v1beta2.BigQueryWrite.GetWriteStream:input_type -> google.cloud.bigquery.storage.v1beta2.GetWriteStreamRequest
	14, // 29: google.cloud.bigquery.storage.v1beta2.BigQueryWrite.FinalizeWriteStream:input_type -> google.cloud.bigquery.storage.v1beta2.FinalizeWriteStreamRequest
	12, // 30: google.cloud.bigquery.storage.v1beta2.BigQueryWrite.BatchCommitWriteStreams:input_type -> google.cloud.bigquery.storage.v1beta2.BatchCommitWriteStreamsRequest
	16, // 31: google.cloud.bigquery.storage.v1beta2.BigQueryWrite.FlushRows:input_type -> google.cloud.bigquery.storage.v1beta2.FlushRowsRequest
	22, // 32: google.cloud.bigquery.storage.v1beta2.BigQueryRead.CreateReadSession:output_type -> google.cloud.bigquery.storage.v1beta2.ReadSession
	5,  // 33: google.cloud.bigquery.storage.v1beta2.BigQueryRead.ReadRows:output_type -> google.cloud.bigquery.storage.v1beta2.ReadRowsResponse
	7,  // 34: google.cloud.bigquery.storage.v1beta2.BigQueryRead.SplitReadStream:output_type -> google.cloud.bigquery.storage.v1beta2.SplitReadStreamResponse
	28, // 35: google.cloud.bigquery.storage.v1beta2.BigQueryWrite.CreateWriteStream:output_type -> google.cloud.bigquery.storage.v1beta2.WriteStream
	10, // 36: google.cloud.bigquery.storage.v1beta2.BigQueryWrite.AppendRows:output_type -> google.cloud.bigquery.storage.v1beta2.AppendRowsResponse
	28, // 37: google.cloud.bigquery.storage.v1beta2.BigQueryWrite.GetWriteStream:output_type -> google.cloud.bigquery.storage.v1beta2.WriteStream
	15, // 38: google.cloud.bigquery.storage.v1beta2.BigQueryWrite.FinalizeWriteStream:output_type -> google.cloud.bigquery.storage.v1beta2.FinalizeWriteStreamResponse
	13, // 39: google.cloud.bigquery.storage.v1beta2.BigQueryWrite.BatchCommitWriteStreams:output_type -> google.cloud.bigquery.storage.v1beta2.BatchCommitWriteStreamsResponse
	17, // 40: google.cloud.bigquery.storage.v1beta2.BigQueryWrite.FlushRows:output_type -> google.cloud.bigquery.storage.v1beta2.FlushRowsResponse
	32, // [32:41] is the sub-list for method output_type
	23, // [23:32] is the sub-list for method input_type
	23, // [23:23] is the sub-list for extension type_name
	23, // [23:23] is the sub-list for extension extendee
	0,  // [0:23] is the sub-list for field type_name
}

func init() { file_google_cloud_bigquery_storage_v1beta2_storage_proto_init() }
func file_google_cloud_bigquery_storage_v1beta2_storage_proto_init() {
	if File_google_cloud_bigquery_storage_v1beta2_storage_proto != nil {
		return
	}
	file_google_cloud_bigquery_storage_v1beta2_arrow_proto_init()
	file_google_cloud_bigquery_storage_v1beta2_avro_proto_init()
	file_google_cloud_bigquery_storage_v1beta2_protobuf_proto_init()
	file_google_cloud_bigquery_storage_v1beta2_stream_proto_init()
	file_google_cloud_bigquery_storage_v1beta2_table_proto_init()
	file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[4].OneofWrappers = []any{
		(*ReadRowsResponse_AvroRows)(nil),
		(*ReadRowsResponse_ArrowRecordBatch)(nil),
		(*ReadRowsResponse_AvroSchema)(nil),
		(*ReadRowsResponse_ArrowSchema)(nil),
	}
	file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[8].OneofWrappers = []any{
		(*AppendRowsRequest_ProtoRows)(nil),
	}
	file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes[9].OneofWrappers = []any{
		(*AppendRowsResponse_AppendResult_)(nil),
		(*AppendRowsResponse_Error)(nil),
	}
	type x struct{}
	out := protoimpl.TypeBuilder{
		File: protoimpl.DescBuilder{
			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
			RawDescriptor: unsafe.Slice(unsafe.StringData(file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDesc), len(file_google_cloud_bigquery_storage_v1beta2_storage_proto_rawDesc)),
			NumEnums:      1,
			NumMessages:   21,
			NumExtensions: 0,
			NumServices:   2,
		},
		GoTypes:           file_google_cloud_bigquery_storage_v1beta2_storage_proto_goTypes,
		DependencyIndexes: file_google_cloud_bigquery_storage_v1beta2_storage_proto_depIdxs,
		EnumInfos:         file_google_cloud_bigquery_storage_v1beta2_storage_proto_enumTypes,
		MessageInfos:      file_google_cloud_bigquery_storage_v1beta2_storage_proto_msgTypes,
	}.Build()
	File_google_cloud_bigquery_storage_v1beta2_storage_proto = out.File
	file_google_cloud_bigquery_storage_v1beta2_storage_proto_goTypes = nil
	file_google_cloud_bigquery_storage_v1beta2_storage_proto_depIdxs = nil
}
