Source file src/cloud.google.com/go/bigquery/storage/apiv1beta2/storagepb/stream.pb.go

Documentation: cloud.google.com/go/bigquery/storage/apiv1beta2/storagepb

     1  // Copyright 2021 Google LLC
     2  //
     3  // Licensed under the Apache License, Version 2.0 (the "License");
     4  // you may not use this file except in compliance with the License.
     5  // You may obtain a copy of the License at
     6  //
     7  //     http://www.apache.org/licenses/LICENSE-2.0
     8  //
     9  // Unless required by applicable law or agreed to in writing, software
    10  // distributed under the License is distributed on an "AS IS" BASIS,
    11  // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
    12  // See the License for the specific language governing permissions and
    13  // limitations under the License.
    14  
    15  // Code generated by protoc-gen-go. DO NOT EDIT.
    16  // versions:
    17  // 	protoc-gen-go v1.32.0
    18  // 	protoc        v4.25.2
    19  // source: google/cloud/bigquery/storage/v1beta2/stream.proto
    20  
    21  package storagepb
    22  
    23  import (
    24  	reflect "reflect"
    25  	sync "sync"
    26  
    27  	_ "google.golang.org/genproto/googleapis/api/annotations"
    28  	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
    29  	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
    30  	timestamppb "google.golang.org/protobuf/types/known/timestamppb"
    31  )
    32  
    33  const (
    34  	// Verify that this generated code is sufficiently up-to-date.
    35  	_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
    36  	// Verify that runtime/protoimpl is sufficiently up-to-date.
    37  	_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
    38  )
    39  
    40  // Data format for input or output data.
    41  type DataFormat int32
    42  
    43  const (
    44  	DataFormat_DATA_FORMAT_UNSPECIFIED DataFormat = 0
    45  	// Avro is a standard open source row based file format.
    46  	// See https://avro.apache.org/ for more details.
    47  	DataFormat_AVRO DataFormat = 1
    48  	// Arrow is a standard open source column-based message format.
    49  	// See https://arrow.apache.org/ for more details.
    50  	DataFormat_ARROW DataFormat = 2
    51  )
    52  
    53  // Enum value maps for DataFormat.
    54  var (
    55  	DataFormat_name = map[int32]string{
    56  		0: "DATA_FORMAT_UNSPECIFIED",
    57  		1: "AVRO",
    58  		2: "ARROW",
    59  	}
    60  	DataFormat_value = map[string]int32{
    61  		"DATA_FORMAT_UNSPECIFIED": 0,
    62  		"AVRO":                    1,
    63  		"ARROW":                   2,
    64  	}
    65  )
    66  
    67  func (x DataFormat) Enum() *DataFormat {
    68  	p := new(DataFormat)
    69  	*p = x
    70  	return p
    71  }
    72  
    73  func (x DataFormat) String() string {
    74  	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
    75  }
    76  
    77  func (DataFormat) Descriptor() protoreflect.EnumDescriptor {
    78  	return file_google_cloud_bigquery_storage_v1beta2_stream_proto_enumTypes[0].Descriptor()
    79  }
    80  
    81  func (DataFormat) Type() protoreflect.EnumType {
    82  	return &file_google_cloud_bigquery_storage_v1beta2_stream_proto_enumTypes[0]
    83  }
    84  
    85  func (x DataFormat) Number() protoreflect.EnumNumber {
    86  	return protoreflect.EnumNumber(x)
    87  }
    88  
    89  // Deprecated: Use DataFormat.Descriptor instead.
    90  func (DataFormat) EnumDescriptor() ([]byte, []int) {
    91  	return file_google_cloud_bigquery_storage_v1beta2_stream_proto_rawDescGZIP(), []int{0}
    92  }
    93  
    94  // Type enum of the stream.
    95  type WriteStream_Type int32
    96  
    97  const (
    98  	// Unknown type.
    99  	WriteStream_TYPE_UNSPECIFIED WriteStream_Type = 0
   100  	// Data will commit automatically and appear as soon as the write is
   101  	// acknowledged.
   102  	WriteStream_COMMITTED WriteStream_Type = 1
   103  	// Data is invisible until the stream is committed.
   104  	WriteStream_PENDING WriteStream_Type = 2
   105  	// Data is only visible up to the offset to which it was flushed.
   106  	WriteStream_BUFFERED WriteStream_Type = 3
   107  )
   108  
   109  // Enum value maps for WriteStream_Type.
   110  var (
   111  	WriteStream_Type_name = map[int32]string{
   112  		0: "TYPE_UNSPECIFIED",
   113  		1: "COMMITTED",
   114  		2: "PENDING",
   115  		3: "BUFFERED",
   116  	}
   117  	WriteStream_Type_value = map[string]int32{
   118  		"TYPE_UNSPECIFIED": 0,
   119  		"COMMITTED":        1,
   120  		"PENDING":          2,
   121  		"BUFFERED":         3,
   122  	}
   123  )
   124  
   125  func (x WriteStream_Type) Enum() *WriteStream_Type {
   126  	p := new(WriteStream_Type)
   127  	*p = x
   128  	return p
   129  }
   130  
   131  func (x WriteStream_Type) String() string {
   132  	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
   133  }
   134  
   135  func (WriteStream_Type) Descriptor() protoreflect.EnumDescriptor {
   136  	return file_google_cloud_bigquery_storage_v1beta2_stream_proto_enumTypes[1].Descriptor()
   137  }
   138  
   139  func (WriteStream_Type) Type() protoreflect.EnumType {
   140  	return &file_google_cloud_bigquery_storage_v1beta2_stream_proto_enumTypes[1]
   141  }
   142  
   143  func (x WriteStream_Type) Number() protoreflect.EnumNumber {
   144  	return protoreflect.EnumNumber(x)
   145  }
   146  
   147  // Deprecated: Use WriteStream_Type.Descriptor instead.
   148  func (WriteStream_Type) EnumDescriptor() ([]byte, []int) {
   149  	return file_google_cloud_bigquery_storage_v1beta2_stream_proto_rawDescGZIP(), []int{2, 0}
   150  }
   151  
   152  // Information about the ReadSession.
   153  type ReadSession struct {
   154  	state         protoimpl.MessageState
   155  	sizeCache     protoimpl.SizeCache
   156  	unknownFields protoimpl.UnknownFields
   157  
   158  	// Output only. Unique identifier for the session, in the form
   159  	// `projects/{project_id}/locations/{location}/sessions/{session_id}`.
   160  	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
   161  	// Output only. Time at which the session becomes invalid. After this time, subsequent
   162  	// requests to read this Session will return errors. The expire_time is
   163  	// automatically assigned and currently cannot be specified or updated.
   164  	ExpireTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=expire_time,json=expireTime,proto3" json:"expire_time,omitempty"`
   165  	// Immutable. Data format of the output data.
   166  	DataFormat DataFormat `protobuf:"varint,3,opt,name=data_format,json=dataFormat,proto3,enum=google.cloud.bigquery.storage.v1beta2.DataFormat" json:"data_format,omitempty"`
   167  	// The schema for the read. If read_options.selected_fields is set, the
   168  	// schema may be different from the table schema as it will only contain
   169  	// the selected fields.
   170  	//
   171  	// Types that are assignable to Schema:
   172  	//
   173  	//	*ReadSession_AvroSchema
   174  	//	*ReadSession_ArrowSchema
   175  	Schema isReadSession_Schema `protobuf_oneof:"schema"`
   176  	// Immutable. Table that this ReadSession is reading from, in the form
   177  	// `projects/{project_id}/datasets/{dataset_id}/tables/{table_id}
   178  	Table string `protobuf:"bytes,6,opt,name=table,proto3" json:"table,omitempty"`
   179  	// Optional. Any modifiers which are applied when reading from the specified table.
   180  	TableModifiers *ReadSession_TableModifiers `protobuf:"bytes,7,opt,name=table_modifiers,json=tableModifiers,proto3" json:"table_modifiers,omitempty"`
   181  	// Optional. Read options for this session (e.g. column selection, filters).
   182  	ReadOptions *ReadSession_TableReadOptions `protobuf:"bytes,8,opt,name=read_options,json=readOptions,proto3" json:"read_options,omitempty"`
   183  	// Output only. A list of streams created with the session.
   184  	//
   185  	// At least one stream is created with the session. In the future, larger
   186  	// request_stream_count values *may* result in this list being unpopulated,
   187  	// in that case, the user will need to use a List method to get the streams
   188  	// instead, which is not yet available.
   189  	Streams []*ReadStream `protobuf:"bytes,10,rep,name=streams,proto3" json:"streams,omitempty"`
   190  }
   191  
   192  func (x *ReadSession) Reset() {
   193  	*x = ReadSession{}
   194  	if protoimpl.UnsafeEnabled {
   195  		mi := &file_google_cloud_bigquery_storage_v1beta2_stream_proto_msgTypes[0]
   196  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   197  		ms.StoreMessageInfo(mi)
   198  	}
   199  }
   200  
   201  func (x *ReadSession) String() string {
   202  	return protoimpl.X.MessageStringOf(x)
   203  }
   204  
   205  func (*ReadSession) ProtoMessage() {}
   206  
   207  func (x *ReadSession) ProtoReflect() protoreflect.Message {
   208  	mi := &file_google_cloud_bigquery_storage_v1beta2_stream_proto_msgTypes[0]
   209  	if protoimpl.UnsafeEnabled && x != nil {
   210  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   211  		if ms.LoadMessageInfo() == nil {
   212  			ms.StoreMessageInfo(mi)
   213  		}
   214  		return ms
   215  	}
   216  	return mi.MessageOf(x)
   217  }
   218  
   219  // Deprecated: Use ReadSession.ProtoReflect.Descriptor instead.
   220  func (*ReadSession) Descriptor() ([]byte, []int) {
   221  	return file_google_cloud_bigquery_storage_v1beta2_stream_proto_rawDescGZIP(), []int{0}
   222  }
   223  
   224  func (x *ReadSession) GetName() string {
   225  	if x != nil {
   226  		return x.Name
   227  	}
   228  	return ""
   229  }
   230  
   231  func (x *ReadSession) GetExpireTime() *timestamppb.Timestamp {
   232  	if x != nil {
   233  		return x.ExpireTime
   234  	}
   235  	return nil
   236  }
   237  
   238  func (x *ReadSession) GetDataFormat() DataFormat {
   239  	if x != nil {
   240  		return x.DataFormat
   241  	}
   242  	return DataFormat_DATA_FORMAT_UNSPECIFIED
   243  }
   244  
   245  func (m *ReadSession) GetSchema() isReadSession_Schema {
   246  	if m != nil {
   247  		return m.Schema
   248  	}
   249  	return nil
   250  }
   251  
   252  func (x *ReadSession) GetAvroSchema() *AvroSchema {
   253  	if x, ok := x.GetSchema().(*ReadSession_AvroSchema); ok {
   254  		return x.AvroSchema
   255  	}
   256  	return nil
   257  }
   258  
   259  func (x *ReadSession) GetArrowSchema() *ArrowSchema {
   260  	if x, ok := x.GetSchema().(*ReadSession_ArrowSchema); ok {
   261  		return x.ArrowSchema
   262  	}
   263  	return nil
   264  }
   265  
   266  func (x *ReadSession) GetTable() string {
   267  	if x != nil {
   268  		return x.Table
   269  	}
   270  	return ""
   271  }
   272  
   273  func (x *ReadSession) GetTableModifiers() *ReadSession_TableModifiers {
   274  	if x != nil {
   275  		return x.TableModifiers
   276  	}
   277  	return nil
   278  }
   279  
   280  func (x *ReadSession) GetReadOptions() *ReadSession_TableReadOptions {
   281  	if x != nil {
   282  		return x.ReadOptions
   283  	}
   284  	return nil
   285  }
   286  
   287  func (x *ReadSession) GetStreams() []*ReadStream {
   288  	if x != nil {
   289  		return x.Streams
   290  	}
   291  	return nil
   292  }
   293  
   294  type isReadSession_Schema interface {
   295  	isReadSession_Schema()
   296  }
   297  
   298  type ReadSession_AvroSchema struct {
   299  	// Output only. Avro schema.
   300  	AvroSchema *AvroSchema `protobuf:"bytes,4,opt,name=avro_schema,json=avroSchema,proto3,oneof"`
   301  }
   302  
   303  type ReadSession_ArrowSchema struct {
   304  	// Output only. Arrow schema.
   305  	ArrowSchema *ArrowSchema `protobuf:"bytes,5,opt,name=arrow_schema,json=arrowSchema,proto3,oneof"`
   306  }
   307  
   308  func (*ReadSession_AvroSchema) isReadSession_Schema() {}
   309  
   310  func (*ReadSession_ArrowSchema) isReadSession_Schema() {}
   311  
   312  // Information about a single stream that gets data out of the storage system.
   313  // Most of the information about `ReadStream` instances is aggregated, making
   314  // `ReadStream` lightweight.
   315  type ReadStream struct {
   316  	state         protoimpl.MessageState
   317  	sizeCache     protoimpl.SizeCache
   318  	unknownFields protoimpl.UnknownFields
   319  
   320  	// Output only. Name of the stream, in the form
   321  	// `projects/{project_id}/locations/{location}/sessions/{session_id}/streams/{stream_id}`.
   322  	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
   323  }
   324  
   325  func (x *ReadStream) Reset() {
   326  	*x = ReadStream{}
   327  	if protoimpl.UnsafeEnabled {
   328  		mi := &file_google_cloud_bigquery_storage_v1beta2_stream_proto_msgTypes[1]
   329  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   330  		ms.StoreMessageInfo(mi)
   331  	}
   332  }
   333  
   334  func (x *ReadStream) String() string {
   335  	return protoimpl.X.MessageStringOf(x)
   336  }
   337  
   338  func (*ReadStream) ProtoMessage() {}
   339  
   340  func (x *ReadStream) ProtoReflect() protoreflect.Message {
   341  	mi := &file_google_cloud_bigquery_storage_v1beta2_stream_proto_msgTypes[1]
   342  	if protoimpl.UnsafeEnabled && x != nil {
   343  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   344  		if ms.LoadMessageInfo() == nil {
   345  			ms.StoreMessageInfo(mi)
   346  		}
   347  		return ms
   348  	}
   349  	return mi.MessageOf(x)
   350  }
   351  
   352  // Deprecated: Use ReadStream.ProtoReflect.Descriptor instead.
   353  func (*ReadStream) Descriptor() ([]byte, []int) {
   354  	return file_google_cloud_bigquery_storage_v1beta2_stream_proto_rawDescGZIP(), []int{1}
   355  }
   356  
   357  func (x *ReadStream) GetName() string {
   358  	if x != nil {
   359  		return x.Name
   360  	}
   361  	return ""
   362  }
   363  
   364  // Information about a single stream that gets data inside the storage system.
   365  type WriteStream struct {
   366  	state         protoimpl.MessageState
   367  	sizeCache     protoimpl.SizeCache
   368  	unknownFields protoimpl.UnknownFields
   369  
   370  	// Output only. Name of the stream, in the form
   371  	// `projects/{project}/datasets/{dataset}/tables/{table}/streams/{stream}`.
   372  	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
   373  	// Immutable. Type of the stream.
   374  	Type WriteStream_Type `protobuf:"varint,2,opt,name=type,proto3,enum=google.cloud.bigquery.storage.v1beta2.WriteStream_Type" json:"type,omitempty"`
   375  	// Output only. Create time of the stream. For the _default stream, this is the
   376  	// creation_time of the table.
   377  	CreateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
   378  	// Output only. Commit time of the stream.
   379  	// If a stream is of `COMMITTED` type, then it will have a commit_time same as
   380  	// `create_time`. If the stream is of `PENDING` type, commit_time being empty
   381  	// means it is not committed.
   382  	CommitTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=commit_time,json=commitTime,proto3" json:"commit_time,omitempty"`
   383  	// Output only. The schema of the destination table. It is only returned in
   384  	// `CreateWriteStream` response. Caller should generate data that's
   385  	// compatible with this schema to send in initial `AppendRowsRequest`.
   386  	// The table schema could go out of date during the life time of the stream.
   387  	TableSchema *TableSchema `protobuf:"bytes,5,opt,name=table_schema,json=tableSchema,proto3" json:"table_schema,omitempty"`
   388  }
   389  
   390  func (x *WriteStream) Reset() {
   391  	*x = WriteStream{}
   392  	if protoimpl.UnsafeEnabled {
   393  		mi := &file_google_cloud_bigquery_storage_v1beta2_stream_proto_msgTypes[2]
   394  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   395  		ms.StoreMessageInfo(mi)
   396  	}
   397  }
   398  
   399  func (x *WriteStream) String() string {
   400  	return protoimpl.X.MessageStringOf(x)
   401  }
   402  
   403  func (*WriteStream) ProtoMessage() {}
   404  
   405  func (x *WriteStream) ProtoReflect() protoreflect.Message {
   406  	mi := &file_google_cloud_bigquery_storage_v1beta2_stream_proto_msgTypes[2]
   407  	if protoimpl.UnsafeEnabled && x != nil {
   408  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   409  		if ms.LoadMessageInfo() == nil {
   410  			ms.StoreMessageInfo(mi)
   411  		}
   412  		return ms
   413  	}
   414  	return mi.MessageOf(x)
   415  }
   416  
   417  // Deprecated: Use WriteStream.ProtoReflect.Descriptor instead.
   418  func (*WriteStream) Descriptor() ([]byte, []int) {
   419  	return file_google_cloud_bigquery_storage_v1beta2_stream_proto_rawDescGZIP(), []int{2}
   420  }
   421  
   422  func (x *WriteStream) GetName() string {
   423  	if x != nil {
   424  		return x.Name
   425  	}
   426  	return ""
   427  }
   428  
   429  func (x *WriteStream) GetType() WriteStream_Type {
   430  	if x != nil {
   431  		return x.Type
   432  	}
   433  	return WriteStream_TYPE_UNSPECIFIED
   434  }
   435  
   436  func (x *WriteStream) GetCreateTime() *timestamppb.Timestamp {
   437  	if x != nil {
   438  		return x.CreateTime
   439  	}
   440  	return nil
   441  }
   442  
   443  func (x *WriteStream) GetCommitTime() *timestamppb.Timestamp {
   444  	if x != nil {
   445  		return x.CommitTime
   446  	}
   447  	return nil
   448  }
   449  
   450  func (x *WriteStream) GetTableSchema() *TableSchema {
   451  	if x != nil {
   452  		return x.TableSchema
   453  	}
   454  	return nil
   455  }
   456  
   457  // Additional attributes when reading a table.
   458  type ReadSession_TableModifiers struct {
   459  	state         protoimpl.MessageState
   460  	sizeCache     protoimpl.SizeCache
   461  	unknownFields protoimpl.UnknownFields
   462  
   463  	// The snapshot time of the table. If not set, interpreted as now.
   464  	SnapshotTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=snapshot_time,json=snapshotTime,proto3" json:"snapshot_time,omitempty"`
   465  }
   466  
   467  func (x *ReadSession_TableModifiers) Reset() {
   468  	*x = ReadSession_TableModifiers{}
   469  	if protoimpl.UnsafeEnabled {
   470  		mi := &file_google_cloud_bigquery_storage_v1beta2_stream_proto_msgTypes[3]
   471  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   472  		ms.StoreMessageInfo(mi)
   473  	}
   474  }
   475  
   476  func (x *ReadSession_TableModifiers) String() string {
   477  	return protoimpl.X.MessageStringOf(x)
   478  }
   479  
   480  func (*ReadSession_TableModifiers) ProtoMessage() {}
   481  
   482  func (x *ReadSession_TableModifiers) ProtoReflect() protoreflect.Message {
   483  	mi := &file_google_cloud_bigquery_storage_v1beta2_stream_proto_msgTypes[3]
   484  	if protoimpl.UnsafeEnabled && x != nil {
   485  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   486  		if ms.LoadMessageInfo() == nil {
   487  			ms.StoreMessageInfo(mi)
   488  		}
   489  		return ms
   490  	}
   491  	return mi.MessageOf(x)
   492  }
   493  
   494  // Deprecated: Use ReadSession_TableModifiers.ProtoReflect.Descriptor instead.
   495  func (*ReadSession_TableModifiers) Descriptor() ([]byte, []int) {
   496  	return file_google_cloud_bigquery_storage_v1beta2_stream_proto_rawDescGZIP(), []int{0, 0}
   497  }
   498  
   499  func (x *ReadSession_TableModifiers) GetSnapshotTime() *timestamppb.Timestamp {
   500  	if x != nil {
   501  		return x.SnapshotTime
   502  	}
   503  	return nil
   504  }
   505  
   506  // Options dictating how we read a table.
   507  type ReadSession_TableReadOptions struct {
   508  	state         protoimpl.MessageState
   509  	sizeCache     protoimpl.SizeCache
   510  	unknownFields protoimpl.UnknownFields
   511  
   512  	// Names of the fields in the table that should be read. If empty, all
   513  	// fields will be read. If the specified field is a nested field, all
   514  	// the sub-fields in the field will be selected. The output field order is
   515  	// unrelated to the order of fields in selected_fields.
   516  	SelectedFields []string `protobuf:"bytes,1,rep,name=selected_fields,json=selectedFields,proto3" json:"selected_fields,omitempty"`
   517  	// SQL text filtering statement, similar to a WHERE clause in a query.
   518  	// Aggregates are not supported.
   519  	//
   520  	// Examples: "int_field > 5"
   521  	//
   522  	//	"date_field = CAST('2014-9-27' as DATE)"
   523  	//	"nullable_field is not NULL"
   524  	//	"st_equals(geo_field, st_geofromtext("POINT(2, 2)"))"
   525  	//	"numeric_field BETWEEN 1.0 AND 5.0"
   526  	//
   527  	// Restricted to a maximum length for 1 MB.
   528  	RowRestriction string `protobuf:"bytes,2,opt,name=row_restriction,json=rowRestriction,proto3" json:"row_restriction,omitempty"`
   529  	// Optional. Options specific to the Apache Arrow output format.
   530  	ArrowSerializationOptions *ArrowSerializationOptions `protobuf:"bytes,3,opt,name=arrow_serialization_options,json=arrowSerializationOptions,proto3" json:"arrow_serialization_options,omitempty"`
   531  }
   532  
   533  func (x *ReadSession_TableReadOptions) Reset() {
   534  	*x = ReadSession_TableReadOptions{}
   535  	if protoimpl.UnsafeEnabled {
   536  		mi := &file_google_cloud_bigquery_storage_v1beta2_stream_proto_msgTypes[4]
   537  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   538  		ms.StoreMessageInfo(mi)
   539  	}
   540  }
   541  
   542  func (x *ReadSession_TableReadOptions) String() string {
   543  	return protoimpl.X.MessageStringOf(x)
   544  }
   545  
   546  func (*ReadSession_TableReadOptions) ProtoMessage() {}
   547  
   548  func (x *ReadSession_TableReadOptions) ProtoReflect() protoreflect.Message {
   549  	mi := &file_google_cloud_bigquery_storage_v1beta2_stream_proto_msgTypes[4]
   550  	if protoimpl.UnsafeEnabled && x != nil {
   551  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   552  		if ms.LoadMessageInfo() == nil {
   553  			ms.StoreMessageInfo(mi)
   554  		}
   555  		return ms
   556  	}
   557  	return mi.MessageOf(x)
   558  }
   559  
   560  // Deprecated: Use ReadSession_TableReadOptions.ProtoReflect.Descriptor instead.
   561  func (*ReadSession_TableReadOptions) Descriptor() ([]byte, []int) {
   562  	return file_google_cloud_bigquery_storage_v1beta2_stream_proto_rawDescGZIP(), []int{0, 1}
   563  }
   564  
   565  func (x *ReadSession_TableReadOptions) GetSelectedFields() []string {
   566  	if x != nil {
   567  		return x.SelectedFields
   568  	}
   569  	return nil
   570  }
   571  
   572  func (x *ReadSession_TableReadOptions) GetRowRestriction() string {
   573  	if x != nil {
   574  		return x.RowRestriction
   575  	}
   576  	return ""
   577  }
   578  
   579  func (x *ReadSession_TableReadOptions) GetArrowSerializationOptions() *ArrowSerializationOptions {
   580  	if x != nil {
   581  		return x.ArrowSerializationOptions
   582  	}
   583  	return nil
   584  }
   585  
   586  var File_google_cloud_bigquery_storage_v1beta2_stream_proto protoreflect.FileDescriptor
   587  
   588  var file_google_cloud_bigquery_storage_v1beta2_stream_proto_rawDesc = []byte{
   589  	0x0a, 0x32, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x62,
   590  	0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2f,
   591  	0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x2e, 0x70,
   592  	0x72, 0x6f, 0x74, 0x6f, 0x12, 0x25, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f,
   593  	0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72,
   594  	0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x1a, 0x1f, 0x67, 0x6f, 0x6f,
   595  	0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x66, 0x69, 0x65, 0x6c, 0x64, 0x5f, 0x62, 0x65,
   596  	0x68, 0x61, 0x76, 0x69, 0x6f, 0x72, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x19, 0x67, 0x6f,
   597  	0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x72, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63,
   598  	0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x31, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f,
   599  	0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2f, 0x73,
   600  	0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2f, 0x61,
   601  	0x72, 0x72, 0x6f, 0x77, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x30, 0x67, 0x6f, 0x6f, 0x67,
   602  	0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72,
   603  	0x79, 0x2f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61,
   604  	0x32, 0x2f, 0x61, 0x76, 0x72, 0x6f, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x31, 0x67, 0x6f,
   605  	0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x62, 0x69, 0x67, 0x71, 0x75,
   606  	0x65, 0x72, 0x79, 0x2f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2f, 0x76, 0x31, 0x62, 0x65,
   607  	0x74, 0x61, 0x32, 0x2f, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a,
   608  	0x1f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66,
   609  	0x2f, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f,
   610  	0x22, 0xa0, 0x09, 0x0a, 0x0b, 0x52, 0x65, 0x61, 0x64, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e,
   611  	0x12, 0x17, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x03,
   612  	0xe0, 0x41, 0x03, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x40, 0x0a, 0x0b, 0x65, 0x78, 0x70,
   613  	0x69, 0x72, 0x65, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a,
   614  	0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66,
   615  	0x2e, 0x54, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52,
   616  	0x0a, 0x65, 0x78, 0x70, 0x69, 0x72, 0x65, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x57, 0x0a, 0x0b, 0x64,
   617  	0x61, 0x74, 0x61, 0x5f, 0x66, 0x6f, 0x72, 0x6d, 0x61, 0x74, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0e,
   618  	0x32, 0x31, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e,
   619  	0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65,
   620  	0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x44, 0x61, 0x74, 0x61, 0x46, 0x6f, 0x72,
   621  	0x6d, 0x61, 0x74, 0x42, 0x03, 0xe0, 0x41, 0x05, 0x52, 0x0a, 0x64, 0x61, 0x74, 0x61, 0x46, 0x6f,
   622  	0x72, 0x6d, 0x61, 0x74, 0x12, 0x59, 0x0a, 0x0b, 0x61, 0x76, 0x72, 0x6f, 0x5f, 0x73, 0x63, 0x68,
   623  	0x65, 0x6d, 0x61, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x31, 0x2e, 0x67, 0x6f, 0x6f, 0x67,
   624  	0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72,
   625  	0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61,
   626  	0x32, 0x2e, 0x41, 0x76, 0x72, 0x6f, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x42, 0x03, 0xe0, 0x41,
   627  	0x03, 0x48, 0x00, 0x52, 0x0a, 0x61, 0x76, 0x72, 0x6f, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x12,
   628  	0x5c, 0x0a, 0x0c, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x5f, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x18,
   629  	0x05, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x32, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63,
   630  	0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74,
   631  	0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x41, 0x72,
   632  	0x72, 0x6f, 0x77, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x48, 0x00,
   633  	0x52, 0x0b, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x12, 0x3b, 0x0a,
   634  	0x05, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x42, 0x25, 0xe0, 0x41,
   635  	0x05, 0xfa, 0x41, 0x1f, 0x0a, 0x1d, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x67,
   636  	0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x54, 0x61,
   637  	0x62, 0x6c, 0x65, 0x52, 0x05, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x12, 0x6f, 0x0a, 0x0f, 0x74, 0x61,
   638  	0x62, 0x6c, 0x65, 0x5f, 0x6d, 0x6f, 0x64, 0x69, 0x66, 0x69, 0x65, 0x72, 0x73, 0x18, 0x07, 0x20,
   639  	0x01, 0x28, 0x0b, 0x32, 0x41, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f,
   640  	0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72,
   641  	0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x52, 0x65, 0x61, 0x64,
   642  	0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x2e, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x4d, 0x6f, 0x64,
   643  	0x69, 0x66, 0x69, 0x65, 0x72, 0x73, 0x42, 0x03, 0xe0, 0x41, 0x01, 0x52, 0x0e, 0x74, 0x61, 0x62,
   644  	0x6c, 0x65, 0x4d, 0x6f, 0x64, 0x69, 0x66, 0x69, 0x65, 0x72, 0x73, 0x12, 0x6b, 0x0a, 0x0c, 0x72,
   645  	0x65, 0x61, 0x64, 0x5f, 0x6f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x18, 0x08, 0x20, 0x01, 0x28,
   646  	0x0b, 0x32, 0x43, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64,
   647  	0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67,
   648  	0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x52, 0x65, 0x61, 0x64, 0x53, 0x65,
   649  	0x73, 0x73, 0x69, 0x6f, 0x6e, 0x2e, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x52, 0x65, 0x61, 0x64, 0x4f,
   650  	0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x42, 0x03, 0xe0, 0x41, 0x01, 0x52, 0x0b, 0x72, 0x65, 0x61,
   651  	0x64, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x50, 0x0a, 0x07, 0x73, 0x74, 0x72, 0x65,
   652  	0x61, 0x6d, 0x73, 0x18, 0x0a, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x31, 0x2e, 0x67, 0x6f, 0x6f, 0x67,
   653  	0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72,
   654  	0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61,
   655  	0x32, 0x2e, 0x52, 0x65, 0x61, 0x64, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x42, 0x03, 0xe0, 0x41,
   656  	0x03, 0x52, 0x07, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x1a, 0x51, 0x0a, 0x0e, 0x54, 0x61,
   657  	0x62, 0x6c, 0x65, 0x4d, 0x6f, 0x64, 0x69, 0x66, 0x69, 0x65, 0x72, 0x73, 0x12, 0x3f, 0x0a, 0x0d,
   658  	0x73, 0x6e, 0x61, 0x70, 0x73, 0x68, 0x6f, 0x74, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x01, 0x20,
   659  	0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f,
   660  	0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x52,
   661  	0x0c, 0x73, 0x6e, 0x61, 0x70, 0x73, 0x68, 0x6f, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x1a, 0xec, 0x01,
   662  	0x0a, 0x10, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x52, 0x65, 0x61, 0x64, 0x4f, 0x70, 0x74, 0x69, 0x6f,
   663  	0x6e, 0x73, 0x12, 0x27, 0x0a, 0x0f, 0x73, 0x65, 0x6c, 0x65, 0x63, 0x74, 0x65, 0x64, 0x5f, 0x66,
   664  	0x69, 0x65, 0x6c, 0x64, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x09, 0x52, 0x0e, 0x73, 0x65, 0x6c,
   665  	0x65, 0x63, 0x74, 0x65, 0x64, 0x46, 0x69, 0x65, 0x6c, 0x64, 0x73, 0x12, 0x27, 0x0a, 0x0f, 0x72,
   666  	0x6f, 0x77, 0x5f, 0x72, 0x65, 0x73, 0x74, 0x72, 0x69, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x02,
   667  	0x20, 0x01, 0x28, 0x09, 0x52, 0x0e, 0x72, 0x6f, 0x77, 0x52, 0x65, 0x73, 0x74, 0x72, 0x69, 0x63,
   668  	0x74, 0x69, 0x6f, 0x6e, 0x12, 0x85, 0x01, 0x0a, 0x1b, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x5f, 0x73,
   669  	0x65, 0x72, 0x69, 0x61, 0x6c, 0x69, 0x7a, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x6f, 0x70, 0x74,
   670  	0x69, 0x6f, 0x6e, 0x73, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x40, 0x2e, 0x67, 0x6f, 0x6f,
   671  	0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65,
   672  	0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74,
   673  	0x61, 0x32, 0x2e, 0x41, 0x72, 0x72, 0x6f, 0x77, 0x53, 0x65, 0x72, 0x69, 0x61, 0x6c, 0x69, 0x7a,
   674  	0x61, 0x74, 0x69, 0x6f, 0x6e, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x42, 0x03, 0xe0, 0x41,
   675  	0x01, 0x52, 0x19, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x53, 0x65, 0x72, 0x69, 0x61, 0x6c, 0x69, 0x7a,
   676  	0x61, 0x74, 0x69, 0x6f, 0x6e, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x3a, 0x6b, 0xea, 0x41,
   677  	0x68, 0x0a, 0x2a, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x73, 0x74, 0x6f, 0x72, 0x61,
   678  	0x67, 0x65, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f,
   679  	0x6d, 0x2f, 0x52, 0x65, 0x61, 0x64, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x3a, 0x70,
   680  	0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x7b, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74,
   681  	0x7d, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x7b, 0x6c, 0x6f, 0x63,
   682  	0x61, 0x74, 0x69, 0x6f, 0x6e, 0x7d, 0x2f, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x73, 0x2f,
   683  	0x7b, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x7d, 0x42, 0x08, 0x0a, 0x06, 0x73, 0x63, 0x68,
   684  	0x65, 0x6d, 0x61, 0x22, 0xa2, 0x01, 0x0a, 0x0a, 0x52, 0x65, 0x61, 0x64, 0x53, 0x74, 0x72, 0x65,
   685  	0x61, 0x6d, 0x12, 0x17, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09,
   686  	0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x3a, 0x7b, 0xea, 0x41, 0x78,
   687  	0x0a, 0x29, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67,
   688  	0x65, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d,
   689  	0x2f, 0x52, 0x65, 0x61, 0x64, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x12, 0x4b, 0x70, 0x72, 0x6f,
   690  	0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x7b, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x7d, 0x2f,
   691  	0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x7b, 0x6c, 0x6f, 0x63, 0x61, 0x74,
   692  	0x69, 0x6f, 0x6e, 0x7d, 0x2f, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x7b, 0x73,
   693  	0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x7d, 0x2f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x2f,
   694  	0x7b, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x7d, 0x22, 0x98, 0x04, 0x0a, 0x0b, 0x57, 0x72, 0x69,
   695  	0x74, 0x65, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x12, 0x17, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65,
   696  	0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x04, 0x6e, 0x61, 0x6d,
   697  	0x65, 0x12, 0x50, 0x0a, 0x04, 0x74, 0x79, 0x70, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0e, 0x32,
   698  	0x37, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62,
   699  	0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e,
   700  	0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x57, 0x72, 0x69, 0x74, 0x65, 0x53, 0x74, 0x72,
   701  	0x65, 0x61, 0x6d, 0x2e, 0x54, 0x79, 0x70, 0x65, 0x42, 0x03, 0xe0, 0x41, 0x05, 0x52, 0x04, 0x74,
   702  	0x79, 0x70, 0x65, 0x12, 0x40, 0x0a, 0x0b, 0x63, 0x72, 0x65, 0x61, 0x74, 0x65, 0x5f, 0x74, 0x69,
   703  	0x6d, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
   704  	0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x73,
   705  	0x74, 0x61, 0x6d, 0x70, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x0a, 0x63, 0x72, 0x65, 0x61, 0x74,
   706  	0x65, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x40, 0x0a, 0x0b, 0x63, 0x6f, 0x6d, 0x6d, 0x69, 0x74, 0x5f,
   707  	0x74, 0x69, 0x6d, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f,
   708  	0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x54, 0x69, 0x6d,
   709  	0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x0a, 0x63, 0x6f, 0x6d,
   710  	0x6d, 0x69, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x5a, 0x0a, 0x0c, 0x74, 0x61, 0x62, 0x6c, 0x65,
   711  	0x5f, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x18, 0x05, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x32, 0x2e,
   712  	0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67,
   713  	0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31,
   714  	0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x53, 0x63, 0x68, 0x65, 0x6d,
   715  	0x61, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x0b, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x53, 0x63, 0x68,
   716  	0x65, 0x6d, 0x61, 0x22, 0x46, 0x0a, 0x04, 0x54, 0x79, 0x70, 0x65, 0x12, 0x14, 0x0a, 0x10, 0x54,
   717  	0x59, 0x50, 0x45, 0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 0x49, 0x45, 0x44, 0x10,
   718  	0x00, 0x12, 0x0d, 0x0a, 0x09, 0x43, 0x4f, 0x4d, 0x4d, 0x49, 0x54, 0x54, 0x45, 0x44, 0x10, 0x01,
   719  	0x12, 0x0b, 0x0a, 0x07, 0x50, 0x45, 0x4e, 0x44, 0x49, 0x4e, 0x47, 0x10, 0x02, 0x12, 0x0c, 0x0a,
   720  	0x08, 0x42, 0x55, 0x46, 0x46, 0x45, 0x52, 0x45, 0x44, 0x10, 0x03, 0x3a, 0x76, 0xea, 0x41, 0x73,
   721  	0x0a, 0x2a, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67,
   722  	0x65, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d,
   723  	0x2f, 0x57, 0x72, 0x69, 0x74, 0x65, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x12, 0x45, 0x70, 0x72,
   724  	0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x7b, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x7d,
   725  	0x2f, 0x64, 0x61, 0x74, 0x61, 0x73, 0x65, 0x74, 0x73, 0x2f, 0x7b, 0x64, 0x61, 0x74, 0x61, 0x73,
   726  	0x65, 0x74, 0x7d, 0x2f, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x73, 0x2f, 0x7b, 0x74, 0x61, 0x62, 0x6c,
   727  	0x65, 0x7d, 0x2f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x2f, 0x7b, 0x73, 0x74, 0x72, 0x65,
   728  	0x61, 0x6d, 0x7d, 0x2a, 0x3e, 0x0a, 0x0a, 0x44, 0x61, 0x74, 0x61, 0x46, 0x6f, 0x72, 0x6d, 0x61,
   729  	0x74, 0x12, 0x1b, 0x0a, 0x17, 0x44, 0x41, 0x54, 0x41, 0x5f, 0x46, 0x4f, 0x52, 0x4d, 0x41, 0x54,
   730  	0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 0x49, 0x45, 0x44, 0x10, 0x00, 0x12, 0x08,
   731  	0x0a, 0x04, 0x41, 0x56, 0x52, 0x4f, 0x10, 0x01, 0x12, 0x09, 0x0a, 0x05, 0x41, 0x52, 0x52, 0x4f,
   732  	0x57, 0x10, 0x02, 0x42, 0xd7, 0x01, 0xea, 0x41, 0x55, 0x0a, 0x1d, 0x62, 0x69, 0x67, 0x71, 0x75,
   733  	0x65, 0x72, 0x79, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63,
   734  	0x6f, 0x6d, 0x2f, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x12, 0x34, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63,
   735  	0x74, 0x73, 0x2f, 0x7b, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x7d, 0x2f, 0x64, 0x61, 0x74,
   736  	0x61, 0x73, 0x65, 0x74, 0x73, 0x2f, 0x7b, 0x64, 0x61, 0x74, 0x61, 0x73, 0x65, 0x74, 0x7d, 0x2f,
   737  	0x74, 0x61, 0x62, 0x6c, 0x65, 0x73, 0x2f, 0x7b, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x7d, 0x0a, 0x29,
   738  	0x63, 0x6f, 0x6d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64,
   739  	0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67,
   740  	0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x42, 0x0b, 0x53, 0x74, 0x72, 0x65, 0x61,
   741  	0x6d, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x50, 0x01, 0x5a, 0x43, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e,
   742  	0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x67, 0x6f, 0x2f, 0x62, 0x69,
   743  	0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2f, 0x61,
   744  	0x70, 0x69, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67,
   745  	0x65, 0x70, 0x62, 0x3b, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x70, 0x62, 0x62, 0x06, 0x70,
   746  	0x72, 0x6f, 0x74, 0x6f, 0x33,
   747  }
   748  
   749  var (
   750  	file_google_cloud_bigquery_storage_v1beta2_stream_proto_rawDescOnce sync.Once
   751  	file_google_cloud_bigquery_storage_v1beta2_stream_proto_rawDescData = file_google_cloud_bigquery_storage_v1beta2_stream_proto_rawDesc
   752  )
   753  
   754  func file_google_cloud_bigquery_storage_v1beta2_stream_proto_rawDescGZIP() []byte {
   755  	file_google_cloud_bigquery_storage_v1beta2_stream_proto_rawDescOnce.Do(func() {
   756  		file_google_cloud_bigquery_storage_v1beta2_stream_proto_rawDescData = protoimpl.X.CompressGZIP(file_google_cloud_bigquery_storage_v1beta2_stream_proto_rawDescData)
   757  	})
   758  	return file_google_cloud_bigquery_storage_v1beta2_stream_proto_rawDescData
   759  }
   760  
   761  var file_google_cloud_bigquery_storage_v1beta2_stream_proto_enumTypes = make([]protoimpl.EnumInfo, 2)
   762  var file_google_cloud_bigquery_storage_v1beta2_stream_proto_msgTypes = make([]protoimpl.MessageInfo, 5)
   763  var file_google_cloud_bigquery_storage_v1beta2_stream_proto_goTypes = []interface{}{
   764  	(DataFormat)(0),                      // 0: google.cloud.bigquery.storage.v1beta2.DataFormat
   765  	(WriteStream_Type)(0),                // 1: google.cloud.bigquery.storage.v1beta2.WriteStream.Type
   766  	(*ReadSession)(nil),                  // 2: google.cloud.bigquery.storage.v1beta2.ReadSession
   767  	(*ReadStream)(nil),                   // 3: google.cloud.bigquery.storage.v1beta2.ReadStream
   768  	(*WriteStream)(nil),                  // 4: google.cloud.bigquery.storage.v1beta2.WriteStream
   769  	(*ReadSession_TableModifiers)(nil),   // 5: google.cloud.bigquery.storage.v1beta2.ReadSession.TableModifiers
   770  	(*ReadSession_TableReadOptions)(nil), // 6: google.cloud.bigquery.storage.v1beta2.ReadSession.TableReadOptions
   771  	(*timestamppb.Timestamp)(nil),        // 7: google.protobuf.Timestamp
   772  	(*AvroSchema)(nil),                   // 8: google.cloud.bigquery.storage.v1beta2.AvroSchema
   773  	(*ArrowSchema)(nil),                  // 9: google.cloud.bigquery.storage.v1beta2.ArrowSchema
   774  	(*TableSchema)(nil),                  // 10: google.cloud.bigquery.storage.v1beta2.TableSchema
   775  	(*ArrowSerializationOptions)(nil),    // 11: google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptions
   776  }
   777  var file_google_cloud_bigquery_storage_v1beta2_stream_proto_depIdxs = []int32{
   778  	7,  // 0: google.cloud.bigquery.storage.v1beta2.ReadSession.expire_time:type_name -> google.protobuf.Timestamp
   779  	0,  // 1: google.cloud.bigquery.storage.v1beta2.ReadSession.data_format:type_name -> google.cloud.bigquery.storage.v1beta2.DataFormat
   780  	8,  // 2: google.cloud.bigquery.storage.v1beta2.ReadSession.avro_schema:type_name -> google.cloud.bigquery.storage.v1beta2.AvroSchema
   781  	9,  // 3: google.cloud.bigquery.storage.v1beta2.ReadSession.arrow_schema:type_name -> google.cloud.bigquery.storage.v1beta2.ArrowSchema
   782  	5,  // 4: google.cloud.bigquery.storage.v1beta2.ReadSession.table_modifiers:type_name -> google.cloud.bigquery.storage.v1beta2.ReadSession.TableModifiers
   783  	6,  // 5: google.cloud.bigquery.storage.v1beta2.ReadSession.read_options:type_name -> google.cloud.bigquery.storage.v1beta2.ReadSession.TableReadOptions
   784  	3,  // 6: google.cloud.bigquery.storage.v1beta2.ReadSession.streams:type_name -> google.cloud.bigquery.storage.v1beta2.ReadStream
   785  	1,  // 7: google.cloud.bigquery.storage.v1beta2.WriteStream.type:type_name -> google.cloud.bigquery.storage.v1beta2.WriteStream.Type
   786  	7,  // 8: google.cloud.bigquery.storage.v1beta2.WriteStream.create_time:type_name -> google.protobuf.Timestamp
   787  	7,  // 9: google.cloud.bigquery.storage.v1beta2.WriteStream.commit_time:type_name -> google.protobuf.Timestamp
   788  	10, // 10: google.cloud.bigquery.storage.v1beta2.WriteStream.table_schema:type_name -> google.cloud.bigquery.storage.v1beta2.TableSchema
   789  	7,  // 11: google.cloud.bigquery.storage.v1beta2.ReadSession.TableModifiers.snapshot_time:type_name -> google.protobuf.Timestamp
   790  	11, // 12: google.cloud.bigquery.storage.v1beta2.ReadSession.TableReadOptions.arrow_serialization_options:type_name -> google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptions
   791  	13, // [13:13] is the sub-list for method output_type
   792  	13, // [13:13] is the sub-list for method input_type
   793  	13, // [13:13] is the sub-list for extension type_name
   794  	13, // [13:13] is the sub-list for extension extendee
   795  	0,  // [0:13] is the sub-list for field type_name
   796  }
   797  
   798  func init() { file_google_cloud_bigquery_storage_v1beta2_stream_proto_init() }
   799  func file_google_cloud_bigquery_storage_v1beta2_stream_proto_init() {
   800  	if File_google_cloud_bigquery_storage_v1beta2_stream_proto != nil {
   801  		return
   802  	}
   803  	file_google_cloud_bigquery_storage_v1beta2_arrow_proto_init()
   804  	file_google_cloud_bigquery_storage_v1beta2_avro_proto_init()
   805  	file_google_cloud_bigquery_storage_v1beta2_table_proto_init()
   806  	if !protoimpl.UnsafeEnabled {
   807  		file_google_cloud_bigquery_storage_v1beta2_stream_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
   808  			switch v := v.(*ReadSession); i {
   809  			case 0:
   810  				return &v.state
   811  			case 1:
   812  				return &v.sizeCache
   813  			case 2:
   814  				return &v.unknownFields
   815  			default:
   816  				return nil
   817  			}
   818  		}
   819  		file_google_cloud_bigquery_storage_v1beta2_stream_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
   820  			switch v := v.(*ReadStream); i {
   821  			case 0:
   822  				return &v.state
   823  			case 1:
   824  				return &v.sizeCache
   825  			case 2:
   826  				return &v.unknownFields
   827  			default:
   828  				return nil
   829  			}
   830  		}
   831  		file_google_cloud_bigquery_storage_v1beta2_stream_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
   832  			switch v := v.(*WriteStream); i {
   833  			case 0:
   834  				return &v.state
   835  			case 1:
   836  				return &v.sizeCache
   837  			case 2:
   838  				return &v.unknownFields
   839  			default:
   840  				return nil
   841  			}
   842  		}
   843  		file_google_cloud_bigquery_storage_v1beta2_stream_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
   844  			switch v := v.(*ReadSession_TableModifiers); i {
   845  			case 0:
   846  				return &v.state
   847  			case 1:
   848  				return &v.sizeCache
   849  			case 2:
   850  				return &v.unknownFields
   851  			default:
   852  				return nil
   853  			}
   854  		}
   855  		file_google_cloud_bigquery_storage_v1beta2_stream_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
   856  			switch v := v.(*ReadSession_TableReadOptions); i {
   857  			case 0:
   858  				return &v.state
   859  			case 1:
   860  				return &v.sizeCache
   861  			case 2:
   862  				return &v.unknownFields
   863  			default:
   864  				return nil
   865  			}
   866  		}
   867  	}
   868  	file_google_cloud_bigquery_storage_v1beta2_stream_proto_msgTypes[0].OneofWrappers = []interface{}{
   869  		(*ReadSession_AvroSchema)(nil),
   870  		(*ReadSession_ArrowSchema)(nil),
   871  	}
   872  	type x struct{}
   873  	out := protoimpl.TypeBuilder{
   874  		File: protoimpl.DescBuilder{
   875  			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
   876  			RawDescriptor: file_google_cloud_bigquery_storage_v1beta2_stream_proto_rawDesc,
   877  			NumEnums:      2,
   878  			NumMessages:   5,
   879  			NumExtensions: 0,
   880  			NumServices:   0,
   881  		},
   882  		GoTypes:           file_google_cloud_bigquery_storage_v1beta2_stream_proto_goTypes,
   883  		DependencyIndexes: file_google_cloud_bigquery_storage_v1beta2_stream_proto_depIdxs,
   884  		EnumInfos:         file_google_cloud_bigquery_storage_v1beta2_stream_proto_enumTypes,
   885  		MessageInfos:      file_google_cloud_bigquery_storage_v1beta2_stream_proto_msgTypes,
   886  	}.Build()
   887  	File_google_cloud_bigquery_storage_v1beta2_stream_proto = out.File
   888  	file_google_cloud_bigquery_storage_v1beta2_stream_proto_rawDesc = nil
   889  	file_google_cloud_bigquery_storage_v1beta2_stream_proto_goTypes = nil
   890  	file_google_cloud_bigquery_storage_v1beta2_stream_proto_depIdxs = nil
   891  }
   892  

View as plain text