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

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

     1  // Copyright 2023 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/v1/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  	// Data format is unspecified.
    45  	DataFormat_DATA_FORMAT_UNSPECIFIED DataFormat = 0
    46  	// Avro is a standard open source row based file format.
    47  	// See https://avro.apache.org/ for more details.
    48  	DataFormat_AVRO DataFormat = 1
    49  	// Arrow is a standard open source column-based message format.
    50  	// See https://arrow.apache.org/ for more details.
    51  	DataFormat_ARROW DataFormat = 2
    52  )
    53  
    54  // Enum value maps for DataFormat.
    55  var (
    56  	DataFormat_name = map[int32]string{
    57  		0: "DATA_FORMAT_UNSPECIFIED",
    58  		1: "AVRO",
    59  		2: "ARROW",
    60  	}
    61  	DataFormat_value = map[string]int32{
    62  		"DATA_FORMAT_UNSPECIFIED": 0,
    63  		"AVRO":                    1,
    64  		"ARROW":                   2,
    65  	}
    66  )
    67  
    68  func (x DataFormat) Enum() *DataFormat {
    69  	p := new(DataFormat)
    70  	*p = x
    71  	return p
    72  }
    73  
    74  func (x DataFormat) String() string {
    75  	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
    76  }
    77  
    78  func (DataFormat) Descriptor() protoreflect.EnumDescriptor {
    79  	return file_google_cloud_bigquery_storage_v1_stream_proto_enumTypes[0].Descriptor()
    80  }
    81  
    82  func (DataFormat) Type() protoreflect.EnumType {
    83  	return &file_google_cloud_bigquery_storage_v1_stream_proto_enumTypes[0]
    84  }
    85  
    86  func (x DataFormat) Number() protoreflect.EnumNumber {
    87  	return protoreflect.EnumNumber(x)
    88  }
    89  
    90  // Deprecated: Use DataFormat.Descriptor instead.
    91  func (DataFormat) EnumDescriptor() ([]byte, []int) {
    92  	return file_google_cloud_bigquery_storage_v1_stream_proto_rawDescGZIP(), []int{0}
    93  }
    94  
    95  // WriteStreamView is a view enum that controls what details about a write
    96  // stream should be returned.
    97  type WriteStreamView int32
    98  
    99  const (
   100  	// The default / unset value.
   101  	WriteStreamView_WRITE_STREAM_VIEW_UNSPECIFIED WriteStreamView = 0
   102  	// The BASIC projection returns basic metadata about a write stream.  The
   103  	// basic view does not include schema information.  This is the default view
   104  	// returned by GetWriteStream.
   105  	WriteStreamView_BASIC WriteStreamView = 1
   106  	// The FULL projection returns all available write stream metadata, including
   107  	// the schema.  CreateWriteStream returns the full projection of write stream
   108  	// metadata.
   109  	WriteStreamView_FULL WriteStreamView = 2
   110  )
   111  
   112  // Enum value maps for WriteStreamView.
   113  var (
   114  	WriteStreamView_name = map[int32]string{
   115  		0: "WRITE_STREAM_VIEW_UNSPECIFIED",
   116  		1: "BASIC",
   117  		2: "FULL",
   118  	}
   119  	WriteStreamView_value = map[string]int32{
   120  		"WRITE_STREAM_VIEW_UNSPECIFIED": 0,
   121  		"BASIC":                         1,
   122  		"FULL":                          2,
   123  	}
   124  )
   125  
   126  func (x WriteStreamView) Enum() *WriteStreamView {
   127  	p := new(WriteStreamView)
   128  	*p = x
   129  	return p
   130  }
   131  
   132  func (x WriteStreamView) String() string {
   133  	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
   134  }
   135  
   136  func (WriteStreamView) Descriptor() protoreflect.EnumDescriptor {
   137  	return file_google_cloud_bigquery_storage_v1_stream_proto_enumTypes[1].Descriptor()
   138  }
   139  
   140  func (WriteStreamView) Type() protoreflect.EnumType {
   141  	return &file_google_cloud_bigquery_storage_v1_stream_proto_enumTypes[1]
   142  }
   143  
   144  func (x WriteStreamView) Number() protoreflect.EnumNumber {
   145  	return protoreflect.EnumNumber(x)
   146  }
   147  
   148  // Deprecated: Use WriteStreamView.Descriptor instead.
   149  func (WriteStreamView) EnumDescriptor() ([]byte, []int) {
   150  	return file_google_cloud_bigquery_storage_v1_stream_proto_rawDescGZIP(), []int{1}
   151  }
   152  
   153  // Specifies which compression codec to attempt on the entire serialized
   154  // response payload (either Arrow record batch or Avro rows). This is
   155  // not to be confused with the Apache Arrow native compression codecs
   156  // specified in ArrowSerializationOptions. For performance reasons, when
   157  // creating a read session requesting Arrow responses, setting both native
   158  // Arrow compression and application-level response compression will not be
   159  // allowed - choose, at most, one kind of compression.
   160  type ReadSession_TableReadOptions_ResponseCompressionCodec int32
   161  
   162  const (
   163  	// Default is no compression.
   164  	ReadSession_TableReadOptions_RESPONSE_COMPRESSION_CODEC_UNSPECIFIED ReadSession_TableReadOptions_ResponseCompressionCodec = 0
   165  	// Use raw LZ4 compression.
   166  	ReadSession_TableReadOptions_RESPONSE_COMPRESSION_CODEC_LZ4 ReadSession_TableReadOptions_ResponseCompressionCodec = 2
   167  )
   168  
   169  // Enum value maps for ReadSession_TableReadOptions_ResponseCompressionCodec.
   170  var (
   171  	ReadSession_TableReadOptions_ResponseCompressionCodec_name = map[int32]string{
   172  		0: "RESPONSE_COMPRESSION_CODEC_UNSPECIFIED",
   173  		2: "RESPONSE_COMPRESSION_CODEC_LZ4",
   174  	}
   175  	ReadSession_TableReadOptions_ResponseCompressionCodec_value = map[string]int32{
   176  		"RESPONSE_COMPRESSION_CODEC_UNSPECIFIED": 0,
   177  		"RESPONSE_COMPRESSION_CODEC_LZ4":         2,
   178  	}
   179  )
   180  
   181  func (x ReadSession_TableReadOptions_ResponseCompressionCodec) Enum() *ReadSession_TableReadOptions_ResponseCompressionCodec {
   182  	p := new(ReadSession_TableReadOptions_ResponseCompressionCodec)
   183  	*p = x
   184  	return p
   185  }
   186  
   187  func (x ReadSession_TableReadOptions_ResponseCompressionCodec) String() string {
   188  	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
   189  }
   190  
   191  func (ReadSession_TableReadOptions_ResponseCompressionCodec) Descriptor() protoreflect.EnumDescriptor {
   192  	return file_google_cloud_bigquery_storage_v1_stream_proto_enumTypes[2].Descriptor()
   193  }
   194  
   195  func (ReadSession_TableReadOptions_ResponseCompressionCodec) Type() protoreflect.EnumType {
   196  	return &file_google_cloud_bigquery_storage_v1_stream_proto_enumTypes[2]
   197  }
   198  
   199  func (x ReadSession_TableReadOptions_ResponseCompressionCodec) Number() protoreflect.EnumNumber {
   200  	return protoreflect.EnumNumber(x)
   201  }
   202  
   203  // Deprecated: Use ReadSession_TableReadOptions_ResponseCompressionCodec.Descriptor instead.
   204  func (ReadSession_TableReadOptions_ResponseCompressionCodec) EnumDescriptor() ([]byte, []int) {
   205  	return file_google_cloud_bigquery_storage_v1_stream_proto_rawDescGZIP(), []int{0, 1, 0}
   206  }
   207  
   208  // Type enum of the stream.
   209  type WriteStream_Type int32
   210  
   211  const (
   212  	// Unknown type.
   213  	WriteStream_TYPE_UNSPECIFIED WriteStream_Type = 0
   214  	// Data will commit automatically and appear as soon as the write is
   215  	// acknowledged.
   216  	WriteStream_COMMITTED WriteStream_Type = 1
   217  	// Data is invisible until the stream is committed.
   218  	WriteStream_PENDING WriteStream_Type = 2
   219  	// Data is only visible up to the offset to which it was flushed.
   220  	WriteStream_BUFFERED WriteStream_Type = 3
   221  )
   222  
   223  // Enum value maps for WriteStream_Type.
   224  var (
   225  	WriteStream_Type_name = map[int32]string{
   226  		0: "TYPE_UNSPECIFIED",
   227  		1: "COMMITTED",
   228  		2: "PENDING",
   229  		3: "BUFFERED",
   230  	}
   231  	WriteStream_Type_value = map[string]int32{
   232  		"TYPE_UNSPECIFIED": 0,
   233  		"COMMITTED":        1,
   234  		"PENDING":          2,
   235  		"BUFFERED":         3,
   236  	}
   237  )
   238  
   239  func (x WriteStream_Type) Enum() *WriteStream_Type {
   240  	p := new(WriteStream_Type)
   241  	*p = x
   242  	return p
   243  }
   244  
   245  func (x WriteStream_Type) String() string {
   246  	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
   247  }
   248  
   249  func (WriteStream_Type) Descriptor() protoreflect.EnumDescriptor {
   250  	return file_google_cloud_bigquery_storage_v1_stream_proto_enumTypes[3].Descriptor()
   251  }
   252  
   253  func (WriteStream_Type) Type() protoreflect.EnumType {
   254  	return &file_google_cloud_bigquery_storage_v1_stream_proto_enumTypes[3]
   255  }
   256  
   257  func (x WriteStream_Type) Number() protoreflect.EnumNumber {
   258  	return protoreflect.EnumNumber(x)
   259  }
   260  
   261  // Deprecated: Use WriteStream_Type.Descriptor instead.
   262  func (WriteStream_Type) EnumDescriptor() ([]byte, []int) {
   263  	return file_google_cloud_bigquery_storage_v1_stream_proto_rawDescGZIP(), []int{2, 0}
   264  }
   265  
   266  // Mode enum of the stream.
   267  type WriteStream_WriteMode int32
   268  
   269  const (
   270  	// Unknown type.
   271  	WriteStream_WRITE_MODE_UNSPECIFIED WriteStream_WriteMode = 0
   272  	// Insert new records into the table.
   273  	// It is the default value if customers do not specify it.
   274  	WriteStream_INSERT WriteStream_WriteMode = 1
   275  )
   276  
   277  // Enum value maps for WriteStream_WriteMode.
   278  var (
   279  	WriteStream_WriteMode_name = map[int32]string{
   280  		0: "WRITE_MODE_UNSPECIFIED",
   281  		1: "INSERT",
   282  	}
   283  	WriteStream_WriteMode_value = map[string]int32{
   284  		"WRITE_MODE_UNSPECIFIED": 0,
   285  		"INSERT":                 1,
   286  	}
   287  )
   288  
   289  func (x WriteStream_WriteMode) Enum() *WriteStream_WriteMode {
   290  	p := new(WriteStream_WriteMode)
   291  	*p = x
   292  	return p
   293  }
   294  
   295  func (x WriteStream_WriteMode) String() string {
   296  	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
   297  }
   298  
   299  func (WriteStream_WriteMode) Descriptor() protoreflect.EnumDescriptor {
   300  	return file_google_cloud_bigquery_storage_v1_stream_proto_enumTypes[4].Descriptor()
   301  }
   302  
   303  func (WriteStream_WriteMode) Type() protoreflect.EnumType {
   304  	return &file_google_cloud_bigquery_storage_v1_stream_proto_enumTypes[4]
   305  }
   306  
   307  func (x WriteStream_WriteMode) Number() protoreflect.EnumNumber {
   308  	return protoreflect.EnumNumber(x)
   309  }
   310  
   311  // Deprecated: Use WriteStream_WriteMode.Descriptor instead.
   312  func (WriteStream_WriteMode) EnumDescriptor() ([]byte, []int) {
   313  	return file_google_cloud_bigquery_storage_v1_stream_proto_rawDescGZIP(), []int{2, 1}
   314  }
   315  
   316  // Information about the ReadSession.
   317  type ReadSession struct {
   318  	state         protoimpl.MessageState
   319  	sizeCache     protoimpl.SizeCache
   320  	unknownFields protoimpl.UnknownFields
   321  
   322  	// Output only. Unique identifier for the session, in the form
   323  	// `projects/{project_id}/locations/{location}/sessions/{session_id}`.
   324  	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
   325  	// Output only. Time at which the session becomes invalid. After this time,
   326  	// subsequent requests to read this Session will return errors. The
   327  	// expire_time is automatically assigned and currently cannot be specified or
   328  	// updated.
   329  	ExpireTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=expire_time,json=expireTime,proto3" json:"expire_time,omitempty"`
   330  	// Immutable. Data format of the output data. DATA_FORMAT_UNSPECIFIED not
   331  	// supported.
   332  	DataFormat DataFormat `protobuf:"varint,3,opt,name=data_format,json=dataFormat,proto3,enum=google.cloud.bigquery.storage.v1.DataFormat" json:"data_format,omitempty"`
   333  	// The schema for the read. If read_options.selected_fields is set, the
   334  	// schema may be different from the table schema as it will only contain
   335  	// the selected fields.
   336  	//
   337  	// Types that are assignable to Schema:
   338  	//
   339  	//	*ReadSession_AvroSchema
   340  	//	*ReadSession_ArrowSchema
   341  	Schema isReadSession_Schema `protobuf_oneof:"schema"`
   342  	// Immutable. Table that this ReadSession is reading from, in the form
   343  	// `projects/{project_id}/datasets/{dataset_id}/tables/{table_id}`
   344  	Table string `protobuf:"bytes,6,opt,name=table,proto3" json:"table,omitempty"`
   345  	// Optional. Any modifiers which are applied when reading from the specified
   346  	// table.
   347  	TableModifiers *ReadSession_TableModifiers `protobuf:"bytes,7,opt,name=table_modifiers,json=tableModifiers,proto3" json:"table_modifiers,omitempty"`
   348  	// Optional. Read options for this session (e.g. column selection, filters).
   349  	ReadOptions *ReadSession_TableReadOptions `protobuf:"bytes,8,opt,name=read_options,json=readOptions,proto3" json:"read_options,omitempty"`
   350  	// Output only. A list of streams created with the session.
   351  	//
   352  	// At least one stream is created with the session. In the future, larger
   353  	// request_stream_count values *may* result in this list being unpopulated,
   354  	// in that case, the user will need to use a List method to get the streams
   355  	// instead, which is not yet available.
   356  	Streams []*ReadStream `protobuf:"bytes,10,rep,name=streams,proto3" json:"streams,omitempty"`
   357  	// Output only. An estimate on the number of bytes this session will scan when
   358  	// all streams are completely consumed. This estimate is based on
   359  	// metadata from the table which might be incomplete or stale.
   360  	EstimatedTotalBytesScanned int64 `protobuf:"varint,12,opt,name=estimated_total_bytes_scanned,json=estimatedTotalBytesScanned,proto3" json:"estimated_total_bytes_scanned,omitempty"`
   361  	// Output only. A pre-projected estimate of the total physical size of files
   362  	// (in bytes) that this session will scan when all streams are consumed. This
   363  	// estimate is independent of the selected columns and can be based on
   364  	// incomplete or stale metadata from the table.  This field is only set for
   365  	// BigLake tables.
   366  	EstimatedTotalPhysicalFileSize int64 `protobuf:"varint,15,opt,name=estimated_total_physical_file_size,json=estimatedTotalPhysicalFileSize,proto3" json:"estimated_total_physical_file_size,omitempty"`
   367  	// Output only. An estimate on the number of rows present in this session's
   368  	// streams. This estimate is based on metadata from the table which might be
   369  	// incomplete or stale.
   370  	EstimatedRowCount int64 `protobuf:"varint,14,opt,name=estimated_row_count,json=estimatedRowCount,proto3" json:"estimated_row_count,omitempty"`
   371  	// Optional. ID set by client to annotate a session identity.  This does not
   372  	// need to be strictly unique, but instead the same ID should be used to group
   373  	// logically connected sessions (e.g. All using the same ID for all sessions
   374  	// needed to complete a Spark SQL query is reasonable).
   375  	//
   376  	// Maximum length is 256 bytes.
   377  	TraceId string `protobuf:"bytes,13,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`
   378  }
   379  
   380  func (x *ReadSession) Reset() {
   381  	*x = ReadSession{}
   382  	if protoimpl.UnsafeEnabled {
   383  		mi := &file_google_cloud_bigquery_storage_v1_stream_proto_msgTypes[0]
   384  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   385  		ms.StoreMessageInfo(mi)
   386  	}
   387  }
   388  
   389  func (x *ReadSession) String() string {
   390  	return protoimpl.X.MessageStringOf(x)
   391  }
   392  
   393  func (*ReadSession) ProtoMessage() {}
   394  
   395  func (x *ReadSession) ProtoReflect() protoreflect.Message {
   396  	mi := &file_google_cloud_bigquery_storage_v1_stream_proto_msgTypes[0]
   397  	if protoimpl.UnsafeEnabled && x != nil {
   398  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   399  		if ms.LoadMessageInfo() == nil {
   400  			ms.StoreMessageInfo(mi)
   401  		}
   402  		return ms
   403  	}
   404  	return mi.MessageOf(x)
   405  }
   406  
   407  // Deprecated: Use ReadSession.ProtoReflect.Descriptor instead.
   408  func (*ReadSession) Descriptor() ([]byte, []int) {
   409  	return file_google_cloud_bigquery_storage_v1_stream_proto_rawDescGZIP(), []int{0}
   410  }
   411  
   412  func (x *ReadSession) GetName() string {
   413  	if x != nil {
   414  		return x.Name
   415  	}
   416  	return ""
   417  }
   418  
   419  func (x *ReadSession) GetExpireTime() *timestamppb.Timestamp {
   420  	if x != nil {
   421  		return x.ExpireTime
   422  	}
   423  	return nil
   424  }
   425  
   426  func (x *ReadSession) GetDataFormat() DataFormat {
   427  	if x != nil {
   428  		return x.DataFormat
   429  	}
   430  	return DataFormat_DATA_FORMAT_UNSPECIFIED
   431  }
   432  
   433  func (m *ReadSession) GetSchema() isReadSession_Schema {
   434  	if m != nil {
   435  		return m.Schema
   436  	}
   437  	return nil
   438  }
   439  
   440  func (x *ReadSession) GetAvroSchema() *AvroSchema {
   441  	if x, ok := x.GetSchema().(*ReadSession_AvroSchema); ok {
   442  		return x.AvroSchema
   443  	}
   444  	return nil
   445  }
   446  
   447  func (x *ReadSession) GetArrowSchema() *ArrowSchema {
   448  	if x, ok := x.GetSchema().(*ReadSession_ArrowSchema); ok {
   449  		return x.ArrowSchema
   450  	}
   451  	return nil
   452  }
   453  
   454  func (x *ReadSession) GetTable() string {
   455  	if x != nil {
   456  		return x.Table
   457  	}
   458  	return ""
   459  }
   460  
   461  func (x *ReadSession) GetTableModifiers() *ReadSession_TableModifiers {
   462  	if x != nil {
   463  		return x.TableModifiers
   464  	}
   465  	return nil
   466  }
   467  
   468  func (x *ReadSession) GetReadOptions() *ReadSession_TableReadOptions {
   469  	if x != nil {
   470  		return x.ReadOptions
   471  	}
   472  	return nil
   473  }
   474  
   475  func (x *ReadSession) GetStreams() []*ReadStream {
   476  	if x != nil {
   477  		return x.Streams
   478  	}
   479  	return nil
   480  }
   481  
   482  func (x *ReadSession) GetEstimatedTotalBytesScanned() int64 {
   483  	if x != nil {
   484  		return x.EstimatedTotalBytesScanned
   485  	}
   486  	return 0
   487  }
   488  
   489  func (x *ReadSession) GetEstimatedTotalPhysicalFileSize() int64 {
   490  	if x != nil {
   491  		return x.EstimatedTotalPhysicalFileSize
   492  	}
   493  	return 0
   494  }
   495  
   496  func (x *ReadSession) GetEstimatedRowCount() int64 {
   497  	if x != nil {
   498  		return x.EstimatedRowCount
   499  	}
   500  	return 0
   501  }
   502  
   503  func (x *ReadSession) GetTraceId() string {
   504  	if x != nil {
   505  		return x.TraceId
   506  	}
   507  	return ""
   508  }
   509  
   510  type isReadSession_Schema interface {
   511  	isReadSession_Schema()
   512  }
   513  
   514  type ReadSession_AvroSchema struct {
   515  	// Output only. Avro schema.
   516  	AvroSchema *AvroSchema `protobuf:"bytes,4,opt,name=avro_schema,json=avroSchema,proto3,oneof"`
   517  }
   518  
   519  type ReadSession_ArrowSchema struct {
   520  	// Output only. Arrow schema.
   521  	ArrowSchema *ArrowSchema `protobuf:"bytes,5,opt,name=arrow_schema,json=arrowSchema,proto3,oneof"`
   522  }
   523  
   524  func (*ReadSession_AvroSchema) isReadSession_Schema() {}
   525  
   526  func (*ReadSession_ArrowSchema) isReadSession_Schema() {}
   527  
   528  // Information about a single stream that gets data out of the storage system.
   529  // Most of the information about `ReadStream` instances is aggregated, making
   530  // `ReadStream` lightweight.
   531  type ReadStream struct {
   532  	state         protoimpl.MessageState
   533  	sizeCache     protoimpl.SizeCache
   534  	unknownFields protoimpl.UnknownFields
   535  
   536  	// Output only. Name of the stream, in the form
   537  	// `projects/{project_id}/locations/{location}/sessions/{session_id}/streams/{stream_id}`.
   538  	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
   539  }
   540  
   541  func (x *ReadStream) Reset() {
   542  	*x = ReadStream{}
   543  	if protoimpl.UnsafeEnabled {
   544  		mi := &file_google_cloud_bigquery_storage_v1_stream_proto_msgTypes[1]
   545  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   546  		ms.StoreMessageInfo(mi)
   547  	}
   548  }
   549  
   550  func (x *ReadStream) String() string {
   551  	return protoimpl.X.MessageStringOf(x)
   552  }
   553  
   554  func (*ReadStream) ProtoMessage() {}
   555  
   556  func (x *ReadStream) ProtoReflect() protoreflect.Message {
   557  	mi := &file_google_cloud_bigquery_storage_v1_stream_proto_msgTypes[1]
   558  	if protoimpl.UnsafeEnabled && x != nil {
   559  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   560  		if ms.LoadMessageInfo() == nil {
   561  			ms.StoreMessageInfo(mi)
   562  		}
   563  		return ms
   564  	}
   565  	return mi.MessageOf(x)
   566  }
   567  
   568  // Deprecated: Use ReadStream.ProtoReflect.Descriptor instead.
   569  func (*ReadStream) Descriptor() ([]byte, []int) {
   570  	return file_google_cloud_bigquery_storage_v1_stream_proto_rawDescGZIP(), []int{1}
   571  }
   572  
   573  func (x *ReadStream) GetName() string {
   574  	if x != nil {
   575  		return x.Name
   576  	}
   577  	return ""
   578  }
   579  
   580  // Information about a single stream that gets data inside the storage system.
   581  type WriteStream struct {
   582  	state         protoimpl.MessageState
   583  	sizeCache     protoimpl.SizeCache
   584  	unknownFields protoimpl.UnknownFields
   585  
   586  	// Output only. Name of the stream, in the form
   587  	// `projects/{project}/datasets/{dataset}/tables/{table}/streams/{stream}`.
   588  	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
   589  	// Immutable. Type of the stream.
   590  	Type WriteStream_Type `protobuf:"varint,2,opt,name=type,proto3,enum=google.cloud.bigquery.storage.v1.WriteStream_Type" json:"type,omitempty"`
   591  	// Output only. Create time of the stream. For the _default stream, this is
   592  	// the creation_time of the table.
   593  	CreateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
   594  	// Output only. Commit time of the stream.
   595  	// If a stream is of `COMMITTED` type, then it will have a commit_time same as
   596  	// `create_time`. If the stream is of `PENDING` type, empty commit_time
   597  	// means it is not committed.
   598  	CommitTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=commit_time,json=commitTime,proto3" json:"commit_time,omitempty"`
   599  	// Output only. The schema of the destination table. It is only returned in
   600  	// `CreateWriteStream` response. Caller should generate data that's
   601  	// compatible with this schema to send in initial `AppendRowsRequest`.
   602  	// The table schema could go out of date during the life time of the stream.
   603  	TableSchema *TableSchema `protobuf:"bytes,5,opt,name=table_schema,json=tableSchema,proto3" json:"table_schema,omitempty"`
   604  	// Immutable. Mode of the stream.
   605  	WriteMode WriteStream_WriteMode `protobuf:"varint,7,opt,name=write_mode,json=writeMode,proto3,enum=google.cloud.bigquery.storage.v1.WriteStream_WriteMode" json:"write_mode,omitempty"`
   606  	// Immutable. The geographic location where the stream's dataset resides. See
   607  	// https://cloud.google.com/bigquery/docs/locations for supported
   608  	// locations.
   609  	Location string `protobuf:"bytes,8,opt,name=location,proto3" json:"location,omitempty"`
   610  }
   611  
   612  func (x *WriteStream) Reset() {
   613  	*x = WriteStream{}
   614  	if protoimpl.UnsafeEnabled {
   615  		mi := &file_google_cloud_bigquery_storage_v1_stream_proto_msgTypes[2]
   616  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   617  		ms.StoreMessageInfo(mi)
   618  	}
   619  }
   620  
   621  func (x *WriteStream) String() string {
   622  	return protoimpl.X.MessageStringOf(x)
   623  }
   624  
   625  func (*WriteStream) ProtoMessage() {}
   626  
   627  func (x *WriteStream) ProtoReflect() protoreflect.Message {
   628  	mi := &file_google_cloud_bigquery_storage_v1_stream_proto_msgTypes[2]
   629  	if protoimpl.UnsafeEnabled && x != nil {
   630  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   631  		if ms.LoadMessageInfo() == nil {
   632  			ms.StoreMessageInfo(mi)
   633  		}
   634  		return ms
   635  	}
   636  	return mi.MessageOf(x)
   637  }
   638  
   639  // Deprecated: Use WriteStream.ProtoReflect.Descriptor instead.
   640  func (*WriteStream) Descriptor() ([]byte, []int) {
   641  	return file_google_cloud_bigquery_storage_v1_stream_proto_rawDescGZIP(), []int{2}
   642  }
   643  
   644  func (x *WriteStream) GetName() string {
   645  	if x != nil {
   646  		return x.Name
   647  	}
   648  	return ""
   649  }
   650  
   651  func (x *WriteStream) GetType() WriteStream_Type {
   652  	if x != nil {
   653  		return x.Type
   654  	}
   655  	return WriteStream_TYPE_UNSPECIFIED
   656  }
   657  
   658  func (x *WriteStream) GetCreateTime() *timestamppb.Timestamp {
   659  	if x != nil {
   660  		return x.CreateTime
   661  	}
   662  	return nil
   663  }
   664  
   665  func (x *WriteStream) GetCommitTime() *timestamppb.Timestamp {
   666  	if x != nil {
   667  		return x.CommitTime
   668  	}
   669  	return nil
   670  }
   671  
   672  func (x *WriteStream) GetTableSchema() *TableSchema {
   673  	if x != nil {
   674  		return x.TableSchema
   675  	}
   676  	return nil
   677  }
   678  
   679  func (x *WriteStream) GetWriteMode() WriteStream_WriteMode {
   680  	if x != nil {
   681  		return x.WriteMode
   682  	}
   683  	return WriteStream_WRITE_MODE_UNSPECIFIED
   684  }
   685  
   686  func (x *WriteStream) GetLocation() string {
   687  	if x != nil {
   688  		return x.Location
   689  	}
   690  	return ""
   691  }
   692  
   693  // Additional attributes when reading a table.
   694  type ReadSession_TableModifiers struct {
   695  	state         protoimpl.MessageState
   696  	sizeCache     protoimpl.SizeCache
   697  	unknownFields protoimpl.UnknownFields
   698  
   699  	// The snapshot time of the table. If not set, interpreted as now.
   700  	SnapshotTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=snapshot_time,json=snapshotTime,proto3" json:"snapshot_time,omitempty"`
   701  }
   702  
   703  func (x *ReadSession_TableModifiers) Reset() {
   704  	*x = ReadSession_TableModifiers{}
   705  	if protoimpl.UnsafeEnabled {
   706  		mi := &file_google_cloud_bigquery_storage_v1_stream_proto_msgTypes[3]
   707  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   708  		ms.StoreMessageInfo(mi)
   709  	}
   710  }
   711  
   712  func (x *ReadSession_TableModifiers) String() string {
   713  	return protoimpl.X.MessageStringOf(x)
   714  }
   715  
   716  func (*ReadSession_TableModifiers) ProtoMessage() {}
   717  
   718  func (x *ReadSession_TableModifiers) ProtoReflect() protoreflect.Message {
   719  	mi := &file_google_cloud_bigquery_storage_v1_stream_proto_msgTypes[3]
   720  	if protoimpl.UnsafeEnabled && x != nil {
   721  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   722  		if ms.LoadMessageInfo() == nil {
   723  			ms.StoreMessageInfo(mi)
   724  		}
   725  		return ms
   726  	}
   727  	return mi.MessageOf(x)
   728  }
   729  
   730  // Deprecated: Use ReadSession_TableModifiers.ProtoReflect.Descriptor instead.
   731  func (*ReadSession_TableModifiers) Descriptor() ([]byte, []int) {
   732  	return file_google_cloud_bigquery_storage_v1_stream_proto_rawDescGZIP(), []int{0, 0}
   733  }
   734  
   735  func (x *ReadSession_TableModifiers) GetSnapshotTime() *timestamppb.Timestamp {
   736  	if x != nil {
   737  		return x.SnapshotTime
   738  	}
   739  	return nil
   740  }
   741  
   742  // Options dictating how we read a table.
   743  type ReadSession_TableReadOptions struct {
   744  	state         protoimpl.MessageState
   745  	sizeCache     protoimpl.SizeCache
   746  	unknownFields protoimpl.UnknownFields
   747  
   748  	// Optional. The names of the fields in the table to be returned. If no
   749  	// field names are specified, then all fields in the table are returned.
   750  	//
   751  	// Nested fields -- the child elements of a STRUCT field -- can be selected
   752  	// individually using their fully-qualified names, and will be returned as
   753  	// record fields containing only the selected nested fields. If a STRUCT
   754  	// field is specified in the selected fields list, all of the child elements
   755  	// will be returned.
   756  	//
   757  	// As an example, consider a table with the following schema:
   758  	//
   759  	//	{
   760  	//	    "name": "struct_field",
   761  	//	    "type": "RECORD",
   762  	//	    "mode": "NULLABLE",
   763  	//	    "fields": [
   764  	//	        {
   765  	//	            "name": "string_field1",
   766  	//	            "type": "STRING",
   767  	//
   768  	// .              "mode": "NULLABLE"
   769  	//
   770  	//	        },
   771  	//	        {
   772  	//	            "name": "string_field2",
   773  	//	            "type": "STRING",
   774  	//	            "mode": "NULLABLE"
   775  	//	        }
   776  	//	    ]
   777  	//	}
   778  	//
   779  	// Specifying "struct_field" in the selected fields list will result in a
   780  	// read session schema with the following logical structure:
   781  	//
   782  	//	struct_field {
   783  	//	    string_field1
   784  	//	    string_field2
   785  	//	}
   786  	//
   787  	// Specifying "struct_field.string_field1" in the selected fields list will
   788  	// result in a read session schema with the following logical structure:
   789  	//
   790  	//	struct_field {
   791  	//	    string_field1
   792  	//	}
   793  	//
   794  	// The order of the fields in the read session schema is derived from the
   795  	// table schema and does not correspond to the order in which the fields are
   796  	// specified in this list.
   797  	SelectedFields []string `protobuf:"bytes,1,rep,name=selected_fields,json=selectedFields,proto3" json:"selected_fields,omitempty"`
   798  	// SQL text filtering statement, similar to a WHERE clause in a query.
   799  	// Aggregates are not supported.
   800  	//
   801  	// Examples: "int_field > 5"
   802  	//
   803  	//	"date_field = CAST('2014-9-27' as DATE)"
   804  	//	"nullable_field is not NULL"
   805  	//	"st_equals(geo_field, st_geofromtext("POINT(2, 2)"))"
   806  	//	"numeric_field BETWEEN 1.0 AND 5.0"
   807  	//
   808  	// Restricted to a maximum length for 1 MB.
   809  	RowRestriction string `protobuf:"bytes,2,opt,name=row_restriction,json=rowRestriction,proto3" json:"row_restriction,omitempty"`
   810  	// Types that are assignable to OutputFormatSerializationOptions:
   811  	//
   812  	//	*ReadSession_TableReadOptions_ArrowSerializationOptions
   813  	//	*ReadSession_TableReadOptions_AvroSerializationOptions
   814  	OutputFormatSerializationOptions isReadSession_TableReadOptions_OutputFormatSerializationOptions `protobuf_oneof:"output_format_serialization_options"`
   815  	// Optional. Specifies a table sampling percentage. Specifically, the query
   816  	// planner will use TABLESAMPLE SYSTEM (sample_percentage PERCENT). The
   817  	// sampling percentage is applied at the data block granularity. It will
   818  	// randomly choose for each data block whether to read the rows in that data
   819  	// block. For more details, see
   820  	// https://cloud.google.com/bigquery/docs/table-sampling)
   821  	SamplePercentage *float64 `protobuf:"fixed64,5,opt,name=sample_percentage,json=samplePercentage,proto3,oneof" json:"sample_percentage,omitempty"`
   822  	// Optional. Set response_compression_codec when creating a read session to
   823  	// enable application-level compression of ReadRows responses.
   824  	ResponseCompressionCodec *ReadSession_TableReadOptions_ResponseCompressionCodec `protobuf:"varint,6,opt,name=response_compression_codec,json=responseCompressionCodec,proto3,enum=google.cloud.bigquery.storage.v1.ReadSession_TableReadOptions_ResponseCompressionCodec,oneof" json:"response_compression_codec,omitempty"`
   825  }
   826  
   827  func (x *ReadSession_TableReadOptions) Reset() {
   828  	*x = ReadSession_TableReadOptions{}
   829  	if protoimpl.UnsafeEnabled {
   830  		mi := &file_google_cloud_bigquery_storage_v1_stream_proto_msgTypes[4]
   831  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   832  		ms.StoreMessageInfo(mi)
   833  	}
   834  }
   835  
   836  func (x *ReadSession_TableReadOptions) String() string {
   837  	return protoimpl.X.MessageStringOf(x)
   838  }
   839  
   840  func (*ReadSession_TableReadOptions) ProtoMessage() {}
   841  
   842  func (x *ReadSession_TableReadOptions) ProtoReflect() protoreflect.Message {
   843  	mi := &file_google_cloud_bigquery_storage_v1_stream_proto_msgTypes[4]
   844  	if protoimpl.UnsafeEnabled && x != nil {
   845  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   846  		if ms.LoadMessageInfo() == nil {
   847  			ms.StoreMessageInfo(mi)
   848  		}
   849  		return ms
   850  	}
   851  	return mi.MessageOf(x)
   852  }
   853  
   854  // Deprecated: Use ReadSession_TableReadOptions.ProtoReflect.Descriptor instead.
   855  func (*ReadSession_TableReadOptions) Descriptor() ([]byte, []int) {
   856  	return file_google_cloud_bigquery_storage_v1_stream_proto_rawDescGZIP(), []int{0, 1}
   857  }
   858  
   859  func (x *ReadSession_TableReadOptions) GetSelectedFields() []string {
   860  	if x != nil {
   861  		return x.SelectedFields
   862  	}
   863  	return nil
   864  }
   865  
   866  func (x *ReadSession_TableReadOptions) GetRowRestriction() string {
   867  	if x != nil {
   868  		return x.RowRestriction
   869  	}
   870  	return ""
   871  }
   872  
   873  func (m *ReadSession_TableReadOptions) GetOutputFormatSerializationOptions() isReadSession_TableReadOptions_OutputFormatSerializationOptions {
   874  	if m != nil {
   875  		return m.OutputFormatSerializationOptions
   876  	}
   877  	return nil
   878  }
   879  
   880  func (x *ReadSession_TableReadOptions) GetArrowSerializationOptions() *ArrowSerializationOptions {
   881  	if x, ok := x.GetOutputFormatSerializationOptions().(*ReadSession_TableReadOptions_ArrowSerializationOptions); ok {
   882  		return x.ArrowSerializationOptions
   883  	}
   884  	return nil
   885  }
   886  
   887  func (x *ReadSession_TableReadOptions) GetAvroSerializationOptions() *AvroSerializationOptions {
   888  	if x, ok := x.GetOutputFormatSerializationOptions().(*ReadSession_TableReadOptions_AvroSerializationOptions); ok {
   889  		return x.AvroSerializationOptions
   890  	}
   891  	return nil
   892  }
   893  
   894  func (x *ReadSession_TableReadOptions) GetSamplePercentage() float64 {
   895  	if x != nil && x.SamplePercentage != nil {
   896  		return *x.SamplePercentage
   897  	}
   898  	return 0
   899  }
   900  
   901  func (x *ReadSession_TableReadOptions) GetResponseCompressionCodec() ReadSession_TableReadOptions_ResponseCompressionCodec {
   902  	if x != nil && x.ResponseCompressionCodec != nil {
   903  		return *x.ResponseCompressionCodec
   904  	}
   905  	return ReadSession_TableReadOptions_RESPONSE_COMPRESSION_CODEC_UNSPECIFIED
   906  }
   907  
   908  type isReadSession_TableReadOptions_OutputFormatSerializationOptions interface {
   909  	isReadSession_TableReadOptions_OutputFormatSerializationOptions()
   910  }
   911  
   912  type ReadSession_TableReadOptions_ArrowSerializationOptions struct {
   913  	// Optional. Options specific to the Apache Arrow output format.
   914  	ArrowSerializationOptions *ArrowSerializationOptions `protobuf:"bytes,3,opt,name=arrow_serialization_options,json=arrowSerializationOptions,proto3,oneof"`
   915  }
   916  
   917  type ReadSession_TableReadOptions_AvroSerializationOptions struct {
   918  	// Optional. Options specific to the Apache Avro output format
   919  	AvroSerializationOptions *AvroSerializationOptions `protobuf:"bytes,4,opt,name=avro_serialization_options,json=avroSerializationOptions,proto3,oneof"`
   920  }
   921  
   922  func (*ReadSession_TableReadOptions_ArrowSerializationOptions) isReadSession_TableReadOptions_OutputFormatSerializationOptions() {
   923  }
   924  
   925  func (*ReadSession_TableReadOptions_AvroSerializationOptions) isReadSession_TableReadOptions_OutputFormatSerializationOptions() {
   926  }
   927  
   928  var File_google_cloud_bigquery_storage_v1_stream_proto protoreflect.FileDescriptor
   929  
   930  var file_google_cloud_bigquery_storage_v1_stream_proto_rawDesc = []byte{
   931  	0x0a, 0x2d, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x62,
   932  	0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2f,
   933  	0x76, 0x31, 0x2f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12,
   934  	0x20, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69,
   935  	0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76,
   936  	0x31, 0x1a, 0x1f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x66, 0x69,
   937  	0x65, 0x6c, 0x64, 0x5f, 0x62, 0x65, 0x68, 0x61, 0x76, 0x69, 0x6f, 0x72, 0x2e, 0x70, 0x72, 0x6f,
   938  	0x74, 0x6f, 0x1a, 0x19, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x72,
   939  	0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x2c, 0x67,
   940  	0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x62, 0x69, 0x67, 0x71,
   941  	0x75, 0x65, 0x72, 0x79, 0x2f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2f, 0x76, 0x31, 0x2f,
   942  	0x61, 0x72, 0x72, 0x6f, 0x77, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x2b, 0x67, 0x6f, 0x6f,
   943  	0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65,
   944  	0x72, 0x79, 0x2f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2f, 0x76, 0x31, 0x2f, 0x61, 0x76,
   945  	0x72, 0x6f, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x2c, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
   946  	0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2f,
   947  	0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2f, 0x76, 0x31, 0x2f, 0x74, 0x61, 0x62, 0x6c, 0x65,
   948  	0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x70,
   949  	0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d,
   950  	0x70, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0x8f, 0x0f, 0x0a, 0x0b, 0x52, 0x65, 0x61, 0x64,
   951  	0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x17, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18,
   952  	0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65,
   953  	0x12, 0x40, 0x0a, 0x0b, 0x65, 0x78, 0x70, 0x69, 0x72, 0x65, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18,
   954  	0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70,
   955  	0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d,
   956  	0x70, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x0a, 0x65, 0x78, 0x70, 0x69, 0x72, 0x65, 0x54, 0x69,
   957  	0x6d, 0x65, 0x12, 0x52, 0x0a, 0x0b, 0x64, 0x61, 0x74, 0x61, 0x5f, 0x66, 0x6f, 0x72, 0x6d, 0x61,
   958  	0x74, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x2c, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
   959  	0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e,
   960  	0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x44, 0x61, 0x74, 0x61, 0x46,
   961  	0x6f, 0x72, 0x6d, 0x61, 0x74, 0x42, 0x03, 0xe0, 0x41, 0x05, 0x52, 0x0a, 0x64, 0x61, 0x74, 0x61,
   962  	0x46, 0x6f, 0x72, 0x6d, 0x61, 0x74, 0x12, 0x54, 0x0a, 0x0b, 0x61, 0x76, 0x72, 0x6f, 0x5f, 0x73,
   963  	0x63, 0x68, 0x65, 0x6d, 0x61, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2c, 0x2e, 0x67, 0x6f,
   964  	0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75,
   965  	0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x41,
   966  	0x76, 0x72, 0x6f, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x48, 0x00,
   967  	0x52, 0x0a, 0x61, 0x76, 0x72, 0x6f, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x12, 0x57, 0x0a, 0x0c,
   968  	0x61, 0x72, 0x72, 0x6f, 0x77, 0x5f, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x18, 0x05, 0x20, 0x01,
   969  	0x28, 0x0b, 0x32, 0x2d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75,
   970  	0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61,
   971  	0x67, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x41, 0x72, 0x72, 0x6f, 0x77, 0x53, 0x63, 0x68, 0x65, 0x6d,
   972  	0x61, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x48, 0x00, 0x52, 0x0b, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x53,
   973  	0x63, 0x68, 0x65, 0x6d, 0x61, 0x12, 0x3b, 0x0a, 0x05, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x18, 0x06,
   974  	0x20, 0x01, 0x28, 0x09, 0x42, 0x25, 0xe0, 0x41, 0x05, 0xfa, 0x41, 0x1f, 0x0a, 0x1d, 0x62, 0x69,
   975  	0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69,
   976  	0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x52, 0x05, 0x74, 0x61, 0x62,
   977  	0x6c, 0x65, 0x12, 0x6a, 0x0a, 0x0f, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x5f, 0x6d, 0x6f, 0x64, 0x69,
   978  	0x66, 0x69, 0x65, 0x72, 0x73, 0x18, 0x07, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x3c, 0x2e, 0x67, 0x6f,
   979  	0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75,
   980  	0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x52,
   981  	0x65, 0x61, 0x64, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x2e, 0x54, 0x61, 0x62, 0x6c, 0x65,
   982  	0x4d, 0x6f, 0x64, 0x69, 0x66, 0x69, 0x65, 0x72, 0x73, 0x42, 0x03, 0xe0, 0x41, 0x01, 0x52, 0x0e,
   983  	0x74, 0x61, 0x62, 0x6c, 0x65, 0x4d, 0x6f, 0x64, 0x69, 0x66, 0x69, 0x65, 0x72, 0x73, 0x12, 0x66,
   984  	0x0a, 0x0c, 0x72, 0x65, 0x61, 0x64, 0x5f, 0x6f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x18, 0x08,
   985  	0x20, 0x01, 0x28, 0x0b, 0x32, 0x3e, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c,
   986  	0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f,
   987  	0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x52, 0x65, 0x61, 0x64, 0x53, 0x65, 0x73, 0x73,
   988  	0x69, 0x6f, 0x6e, 0x2e, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x52, 0x65, 0x61, 0x64, 0x4f, 0x70, 0x74,
   989  	0x69, 0x6f, 0x6e, 0x73, 0x42, 0x03, 0xe0, 0x41, 0x01, 0x52, 0x0b, 0x72, 0x65, 0x61, 0x64, 0x4f,
   990  	0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x4b, 0x0a, 0x07, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d,
   991  	0x73, 0x18, 0x0a, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x2c, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
   992  	0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e,
   993  	0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x52, 0x65, 0x61, 0x64, 0x53,
   994  	0x74, 0x72, 0x65, 0x61, 0x6d, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x07, 0x73, 0x74, 0x72, 0x65,
   995  	0x61, 0x6d, 0x73, 0x12, 0x46, 0x0a, 0x1d, 0x65, 0x73, 0x74, 0x69, 0x6d, 0x61, 0x74, 0x65, 0x64,
   996  	0x5f, 0x74, 0x6f, 0x74, 0x61, 0x6c, 0x5f, 0x62, 0x79, 0x74, 0x65, 0x73, 0x5f, 0x73, 0x63, 0x61,
   997  	0x6e, 0x6e, 0x65, 0x64, 0x18, 0x0c, 0x20, 0x01, 0x28, 0x03, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52,
   998  	0x1a, 0x65, 0x73, 0x74, 0x69, 0x6d, 0x61, 0x74, 0x65, 0x64, 0x54, 0x6f, 0x74, 0x61, 0x6c, 0x42,
   999  	0x79, 0x74, 0x65, 0x73, 0x53, 0x63, 0x61, 0x6e, 0x6e, 0x65, 0x64, 0x12, 0x4f, 0x0a, 0x22, 0x65,
  1000  	0x73, 0x74, 0x69, 0x6d, 0x61, 0x74, 0x65, 0x64, 0x5f, 0x74, 0x6f, 0x74, 0x61, 0x6c, 0x5f, 0x70,
  1001  	0x68, 0x79, 0x73, 0x69, 0x63, 0x61, 0x6c, 0x5f, 0x66, 0x69, 0x6c, 0x65, 0x5f, 0x73, 0x69, 0x7a,
  1002  	0x65, 0x18, 0x0f, 0x20, 0x01, 0x28, 0x03, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x1e, 0x65, 0x73,
  1003  	0x74, 0x69, 0x6d, 0x61, 0x74, 0x65, 0x64, 0x54, 0x6f, 0x74, 0x61, 0x6c, 0x50, 0x68, 0x79, 0x73,
  1004  	0x69, 0x63, 0x61, 0x6c, 0x46, 0x69, 0x6c, 0x65, 0x53, 0x69, 0x7a, 0x65, 0x12, 0x33, 0x0a, 0x13,
  1005  	0x65, 0x73, 0x74, 0x69, 0x6d, 0x61, 0x74, 0x65, 0x64, 0x5f, 0x72, 0x6f, 0x77, 0x5f, 0x63, 0x6f,
  1006  	0x75, 0x6e, 0x74, 0x18, 0x0e, 0x20, 0x01, 0x28, 0x03, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x11,
  1007  	0x65, 0x73, 0x74, 0x69, 0x6d, 0x61, 0x74, 0x65, 0x64, 0x52, 0x6f, 0x77, 0x43, 0x6f, 0x75, 0x6e,
  1008  	0x74, 0x12, 0x1e, 0x0a, 0x08, 0x74, 0x72, 0x61, 0x63, 0x65, 0x5f, 0x69, 0x64, 0x18, 0x0d, 0x20,
  1009  	0x01, 0x28, 0x09, 0x42, 0x03, 0xe0, 0x41, 0x01, 0x52, 0x07, 0x74, 0x72, 0x61, 0x63, 0x65, 0x49,
  1010  	0x64, 0x1a, 0x51, 0x0a, 0x0e, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x4d, 0x6f, 0x64, 0x69, 0x66, 0x69,
  1011  	0x65, 0x72, 0x73, 0x12, 0x3f, 0x0a, 0x0d, 0x73, 0x6e, 0x61, 0x70, 0x73, 0x68, 0x6f, 0x74, 0x5f,
  1012  	0x74, 0x69, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f,
  1013  	0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x54, 0x69, 0x6d,
  1014  	0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x52, 0x0c, 0x73, 0x6e, 0x61, 0x70, 0x73, 0x68, 0x6f, 0x74,
  1015  	0x54, 0x69, 0x6d, 0x65, 0x1a, 0x8b, 0x06, 0x0a, 0x10, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x52, 0x65,
  1016  	0x61, 0x64, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x27, 0x0a, 0x0f, 0x73, 0x65, 0x6c,
  1017  	0x65, 0x63, 0x74, 0x65, 0x64, 0x5f, 0x66, 0x69, 0x65, 0x6c, 0x64, 0x73, 0x18, 0x01, 0x20, 0x03,
  1018  	0x28, 0x09, 0x52, 0x0e, 0x73, 0x65, 0x6c, 0x65, 0x63, 0x74, 0x65, 0x64, 0x46, 0x69, 0x65, 0x6c,
  1019  	0x64, 0x73, 0x12, 0x27, 0x0a, 0x0f, 0x72, 0x6f, 0x77, 0x5f, 0x72, 0x65, 0x73, 0x74, 0x72, 0x69,
  1020  	0x63, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0e, 0x72, 0x6f, 0x77,
  1021  	0x52, 0x65, 0x73, 0x74, 0x72, 0x69, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x82, 0x01, 0x0a, 0x1b,
  1022  	0x61, 0x72, 0x72, 0x6f, 0x77, 0x5f, 0x73, 0x65, 0x72, 0x69, 0x61, 0x6c, 0x69, 0x7a, 0x61, 0x74,
  1023  	0x69, 0x6f, 0x6e, 0x5f, 0x6f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x18, 0x03, 0x20, 0x01, 0x28,
  1024  	0x0b, 0x32, 0x3b, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64,
  1025  	0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67,
  1026  	0x65, 0x2e, 0x76, 0x31, 0x2e, 0x41, 0x72, 0x72, 0x6f, 0x77, 0x53, 0x65, 0x72, 0x69, 0x61, 0x6c,
  1027  	0x69, 0x7a, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x42, 0x03,
  1028  	0xe0, 0x41, 0x01, 0x48, 0x00, 0x52, 0x19, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x53, 0x65, 0x72, 0x69,
  1029  	0x61, 0x6c, 0x69, 0x7a, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73,
  1030  	0x12, 0x7f, 0x0a, 0x1a, 0x61, 0x76, 0x72, 0x6f, 0x5f, 0x73, 0x65, 0x72, 0x69, 0x61, 0x6c, 0x69,
  1031  	0x7a, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x6f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x18, 0x04,
  1032  	0x20, 0x01, 0x28, 0x0b, 0x32, 0x3a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c,
  1033  	0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f,
  1034  	0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x41, 0x76, 0x72, 0x6f, 0x53, 0x65, 0x72, 0x69,
  1035  	0x61, 0x6c, 0x69, 0x7a, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73,
  1036  	0x42, 0x03, 0xe0, 0x41, 0x01, 0x48, 0x00, 0x52, 0x18, 0x61, 0x76, 0x72, 0x6f, 0x53, 0x65, 0x72,
  1037  	0x69, 0x61, 0x6c, 0x69, 0x7a, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e,
  1038  	0x73, 0x12, 0x35, 0x0a, 0x11, 0x73, 0x61, 0x6d, 0x70, 0x6c, 0x65, 0x5f, 0x70, 0x65, 0x72, 0x63,
  1039  	0x65, 0x6e, 0x74, 0x61, 0x67, 0x65, 0x18, 0x05, 0x20, 0x01, 0x28, 0x01, 0x42, 0x03, 0xe0, 0x41,
  1040  	0x01, 0x48, 0x01, 0x52, 0x10, 0x73, 0x61, 0x6d, 0x70, 0x6c, 0x65, 0x50, 0x65, 0x72, 0x63, 0x65,
  1041  	0x6e, 0x74, 0x61, 0x67, 0x65, 0x88, 0x01, 0x01, 0x12, 0x9f, 0x01, 0x0a, 0x1a, 0x72, 0x65, 0x73,
  1042  	0x70, 0x6f, 0x6e, 0x73, 0x65, 0x5f, 0x63, 0x6f, 0x6d, 0x70, 0x72, 0x65, 0x73, 0x73, 0x69, 0x6f,
  1043  	0x6e, 0x5f, 0x63, 0x6f, 0x64, 0x65, 0x63, 0x18, 0x06, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x57, 0x2e,
  1044  	0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67,
  1045  	0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31,
  1046  	0x2e, 0x52, 0x65, 0x61, 0x64, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x2e, 0x54, 0x61, 0x62,
  1047  	0x6c, 0x65, 0x52, 0x65, 0x61, 0x64, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x52, 0x65,
  1048  	0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x43, 0x6f, 0x6d, 0x70, 0x72, 0x65, 0x73, 0x73, 0x69, 0x6f,
  1049  	0x6e, 0x43, 0x6f, 0x64, 0x65, 0x63, 0x42, 0x03, 0xe0, 0x41, 0x01, 0x48, 0x02, 0x52, 0x18, 0x72,
  1050  	0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x43, 0x6f, 0x6d, 0x70, 0x72, 0x65, 0x73, 0x73, 0x69,
  1051  	0x6f, 0x6e, 0x43, 0x6f, 0x64, 0x65, 0x63, 0x88, 0x01, 0x01, 0x22, 0x6a, 0x0a, 0x18, 0x52, 0x65,
  1052  	0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x43, 0x6f, 0x6d, 0x70, 0x72, 0x65, 0x73, 0x73, 0x69, 0x6f,
  1053  	0x6e, 0x43, 0x6f, 0x64, 0x65, 0x63, 0x12, 0x2a, 0x0a, 0x26, 0x52, 0x45, 0x53, 0x50, 0x4f, 0x4e,
  1054  	0x53, 0x45, 0x5f, 0x43, 0x4f, 0x4d, 0x50, 0x52, 0x45, 0x53, 0x53, 0x49, 0x4f, 0x4e, 0x5f, 0x43,
  1055  	0x4f, 0x44, 0x45, 0x43, 0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 0x49, 0x45, 0x44,
  1056  	0x10, 0x00, 0x12, 0x22, 0x0a, 0x1e, 0x52, 0x45, 0x53, 0x50, 0x4f, 0x4e, 0x53, 0x45, 0x5f, 0x43,
  1057  	0x4f, 0x4d, 0x50, 0x52, 0x45, 0x53, 0x53, 0x49, 0x4f, 0x4e, 0x5f, 0x43, 0x4f, 0x44, 0x45, 0x43,
  1058  	0x5f, 0x4c, 0x5a, 0x34, 0x10, 0x02, 0x42, 0x25, 0x0a, 0x23, 0x6f, 0x75, 0x74, 0x70, 0x75, 0x74,
  1059  	0x5f, 0x66, 0x6f, 0x72, 0x6d, 0x61, 0x74, 0x5f, 0x73, 0x65, 0x72, 0x69, 0x61, 0x6c, 0x69, 0x7a,
  1060  	0x61, 0x74, 0x69, 0x6f, 0x6e, 0x5f, 0x6f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x42, 0x14, 0x0a,
  1061  	0x12, 0x5f, 0x73, 0x61, 0x6d, 0x70, 0x6c, 0x65, 0x5f, 0x70, 0x65, 0x72, 0x63, 0x65, 0x6e, 0x74,
  1062  	0x61, 0x67, 0x65, 0x42, 0x1d, 0x0a, 0x1b, 0x5f, 0x72, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65,
  1063  	0x5f, 0x63, 0x6f, 0x6d, 0x70, 0x72, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x5f, 0x63, 0x6f, 0x64,
  1064  	0x65, 0x63, 0x3a, 0x6b, 0xea, 0x41, 0x68, 0x0a, 0x2a, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72,
  1065  	0x79, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61,
  1066  	0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x52, 0x65, 0x61, 0x64, 0x53, 0x65, 0x73, 0x73,
  1067  	0x69, 0x6f, 0x6e, 0x12, 0x3a, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x7b, 0x70,
  1068  	0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x7d, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e,
  1069  	0x73, 0x2f, 0x7b, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x7d, 0x2f, 0x73, 0x65, 0x73,
  1070  	0x73, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x7b, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x7d, 0x42,
  1071  	0x08, 0x0a, 0x06, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x22, 0xa2, 0x01, 0x0a, 0x0a, 0x52, 0x65,
  1072  	0x61, 0x64, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x12, 0x17, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65,
  1073  	0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x04, 0x6e, 0x61, 0x6d,
  1074  	0x65, 0x3a, 0x7b, 0xea, 0x41, 0x78, 0x0a, 0x29, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79,
  1075  	0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70,
  1076  	0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x52, 0x65, 0x61, 0x64, 0x53, 0x74, 0x72, 0x65, 0x61,
  1077  	0x6d, 0x12, 0x4b, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x7b, 0x70, 0x72, 0x6f,
  1078  	0x6a, 0x65, 0x63, 0x74, 0x7d, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f,
  1079  	0x7b, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x7d, 0x2f, 0x73, 0x65, 0x73, 0x73, 0x69,
  1080  	0x6f, 0x6e, 0x73, 0x2f, 0x7b, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x7d, 0x2f, 0x73, 0x74,
  1081  	0x72, 0x65, 0x61, 0x6d, 0x73, 0x2f, 0x7b, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x7d, 0x22, 0xc1,
  1082  	0x05, 0x0a, 0x0b, 0x57, 0x72, 0x69, 0x74, 0x65, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x12, 0x17,
  1083  	0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x03, 0xe0, 0x41,
  1084  	0x03, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x4b, 0x0a, 0x04, 0x74, 0x79, 0x70, 0x65, 0x18,
  1085  	0x02, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x32, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63,
  1086  	0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74,
  1087  	0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x57, 0x72, 0x69, 0x74, 0x65, 0x53, 0x74,
  1088  	0x72, 0x65, 0x61, 0x6d, 0x2e, 0x54, 0x79, 0x70, 0x65, 0x42, 0x03, 0xe0, 0x41, 0x05, 0x52, 0x04,
  1089  	0x74, 0x79, 0x70, 0x65, 0x12, 0x40, 0x0a, 0x0b, 0x63, 0x72, 0x65, 0x61, 0x74, 0x65, 0x5f, 0x74,
  1090  	0x69, 0x6d, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 0x67,
  1091  	0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x54, 0x69, 0x6d, 0x65,
  1092  	0x73, 0x74, 0x61, 0x6d, 0x70, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x0a, 0x63, 0x72, 0x65, 0x61,
  1093  	0x74, 0x65, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x40, 0x0a, 0x0b, 0x63, 0x6f, 0x6d, 0x6d, 0x69, 0x74,
  1094  	0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f,
  1095  	0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x54, 0x69,
  1096  	0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x0a, 0x63, 0x6f,
  1097  	0x6d, 0x6d, 0x69, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x55, 0x0a, 0x0c, 0x74, 0x61, 0x62, 0x6c,
  1098  	0x65, 0x5f, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x18, 0x05, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2d,
  1099  	0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69,
  1100  	0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76,
  1101  	0x31, 0x2e, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x42, 0x03, 0xe0,
  1102  	0x41, 0x03, 0x52, 0x0b, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x12,
  1103  	0x5b, 0x0a, 0x0a, 0x77, 0x72, 0x69, 0x74, 0x65, 0x5f, 0x6d, 0x6f, 0x64, 0x65, 0x18, 0x07, 0x20,
  1104  	0x01, 0x28, 0x0e, 0x32, 0x37, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f,
  1105  	0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72,
  1106  	0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x57, 0x72, 0x69, 0x74, 0x65, 0x53, 0x74, 0x72, 0x65,
  1107  	0x61, 0x6d, 0x2e, 0x57, 0x72, 0x69, 0x74, 0x65, 0x4d, 0x6f, 0x64, 0x65, 0x42, 0x03, 0xe0, 0x41,
  1108  	0x05, 0x52, 0x09, 0x77, 0x72, 0x69, 0x74, 0x65, 0x4d, 0x6f, 0x64, 0x65, 0x12, 0x1f, 0x0a, 0x08,
  1109  	0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x08, 0x20, 0x01, 0x28, 0x09, 0x42, 0x03,
  1110  	0xe0, 0x41, 0x05, 0x52, 0x08, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x22, 0x46, 0x0a,
  1111  	0x04, 0x54, 0x79, 0x70, 0x65, 0x12, 0x14, 0x0a, 0x10, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x55, 0x4e,
  1112  	0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 0x49, 0x45, 0x44, 0x10, 0x00, 0x12, 0x0d, 0x0a, 0x09, 0x43,
  1113  	0x4f, 0x4d, 0x4d, 0x49, 0x54, 0x54, 0x45, 0x44, 0x10, 0x01, 0x12, 0x0b, 0x0a, 0x07, 0x50, 0x45,
  1114  	0x4e, 0x44, 0x49, 0x4e, 0x47, 0x10, 0x02, 0x12, 0x0c, 0x0a, 0x08, 0x42, 0x55, 0x46, 0x46, 0x45,
  1115  	0x52, 0x45, 0x44, 0x10, 0x03, 0x22, 0x33, 0x0a, 0x09, 0x57, 0x72, 0x69, 0x74, 0x65, 0x4d, 0x6f,
  1116  	0x64, 0x65, 0x12, 0x1a, 0x0a, 0x16, 0x57, 0x52, 0x49, 0x54, 0x45, 0x5f, 0x4d, 0x4f, 0x44, 0x45,
  1117  	0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 0x49, 0x45, 0x44, 0x10, 0x00, 0x12, 0x0a,
  1118  	0x0a, 0x06, 0x49, 0x4e, 0x53, 0x45, 0x52, 0x54, 0x10, 0x01, 0x3a, 0x76, 0xea, 0x41, 0x73, 0x0a,
  1119  	0x2a, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65,
  1120  	0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f,
  1121  	0x57, 0x72, 0x69, 0x74, 0x65, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x12, 0x45, 0x70, 0x72, 0x6f,
  1122  	0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x7b, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x7d, 0x2f,
  1123  	0x64, 0x61, 0x74, 0x61, 0x73, 0x65, 0x74, 0x73, 0x2f, 0x7b, 0x64, 0x61, 0x74, 0x61, 0x73, 0x65,
  1124  	0x74, 0x7d, 0x2f, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x73, 0x2f, 0x7b, 0x74, 0x61, 0x62, 0x6c, 0x65,
  1125  	0x7d, 0x2f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x2f, 0x7b, 0x73, 0x74, 0x72, 0x65, 0x61,
  1126  	0x6d, 0x7d, 0x2a, 0x3e, 0x0a, 0x0a, 0x44, 0x61, 0x74, 0x61, 0x46, 0x6f, 0x72, 0x6d, 0x61, 0x74,
  1127  	0x12, 0x1b, 0x0a, 0x17, 0x44, 0x41, 0x54, 0x41, 0x5f, 0x46, 0x4f, 0x52, 0x4d, 0x41, 0x54, 0x5f,
  1128  	0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 0x49, 0x45, 0x44, 0x10, 0x00, 0x12, 0x08, 0x0a,
  1129  	0x04, 0x41, 0x56, 0x52, 0x4f, 0x10, 0x01, 0x12, 0x09, 0x0a, 0x05, 0x41, 0x52, 0x52, 0x4f, 0x57,
  1130  	0x10, 0x02, 0x2a, 0x49, 0x0a, 0x0f, 0x57, 0x72, 0x69, 0x74, 0x65, 0x53, 0x74, 0x72, 0x65, 0x61,
  1131  	0x6d, 0x56, 0x69, 0x65, 0x77, 0x12, 0x21, 0x0a, 0x1d, 0x57, 0x52, 0x49, 0x54, 0x45, 0x5f, 0x53,
  1132  	0x54, 0x52, 0x45, 0x41, 0x4d, 0x5f, 0x56, 0x49, 0x45, 0x57, 0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45,
  1133  	0x43, 0x49, 0x46, 0x49, 0x45, 0x44, 0x10, 0x00, 0x12, 0x09, 0x0a, 0x05, 0x42, 0x41, 0x53, 0x49,
  1134  	0x43, 0x10, 0x01, 0x12, 0x08, 0x0a, 0x04, 0x46, 0x55, 0x4c, 0x4c, 0x10, 0x02, 0x42, 0xbb, 0x01,
  1135  	0x0a, 0x24, 0x63, 0x6f, 0x6d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f,
  1136  	0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72,
  1137  	0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x42, 0x0b, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x50, 0x72,
  1138  	0x6f, 0x74, 0x6f, 0x50, 0x01, 0x5a, 0x3e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x67, 0x6f, 0x6f,
  1139  	0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x67, 0x6f, 0x2f, 0x62, 0x69, 0x67, 0x71, 0x75,
  1140  	0x65, 0x72, 0x79, 0x2f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x76,
  1141  	0x31, 0x2f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x70, 0x62, 0x3b, 0x73, 0x74, 0x6f, 0x72,
  1142  	0x61, 0x67, 0x65, 0x70, 0x62, 0xaa, 0x02, 0x20, 0x47, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x43,
  1143  	0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x42, 0x69, 0x67, 0x51, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x53, 0x74,
  1144  	0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x56, 0x31, 0xca, 0x02, 0x20, 0x47, 0x6f, 0x6f, 0x67, 0x6c,
  1145  	0x65, 0x5c, 0x43, 0x6c, 0x6f, 0x75, 0x64, 0x5c, 0x42, 0x69, 0x67, 0x51, 0x75, 0x65, 0x72, 0x79,
  1146  	0x5c, 0x53, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x5c, 0x56, 0x31, 0x62, 0x06, 0x70, 0x72, 0x6f,
  1147  	0x74, 0x6f, 0x33,
  1148  }
  1149  
  1150  var (
  1151  	file_google_cloud_bigquery_storage_v1_stream_proto_rawDescOnce sync.Once
  1152  	file_google_cloud_bigquery_storage_v1_stream_proto_rawDescData = file_google_cloud_bigquery_storage_v1_stream_proto_rawDesc
  1153  )
  1154  
  1155  func file_google_cloud_bigquery_storage_v1_stream_proto_rawDescGZIP() []byte {
  1156  	file_google_cloud_bigquery_storage_v1_stream_proto_rawDescOnce.Do(func() {
  1157  		file_google_cloud_bigquery_storage_v1_stream_proto_rawDescData = protoimpl.X.CompressGZIP(file_google_cloud_bigquery_storage_v1_stream_proto_rawDescData)
  1158  	})
  1159  	return file_google_cloud_bigquery_storage_v1_stream_proto_rawDescData
  1160  }
  1161  
  1162  var file_google_cloud_bigquery_storage_v1_stream_proto_enumTypes = make([]protoimpl.EnumInfo, 5)
  1163  var file_google_cloud_bigquery_storage_v1_stream_proto_msgTypes = make([]protoimpl.MessageInfo, 5)
  1164  var file_google_cloud_bigquery_storage_v1_stream_proto_goTypes = []interface{}{
  1165  	(DataFormat)(0),      // 0: google.cloud.bigquery.storage.v1.DataFormat
  1166  	(WriteStreamView)(0), // 1: google.cloud.bigquery.storage.v1.WriteStreamView
  1167  	(ReadSession_TableReadOptions_ResponseCompressionCodec)(0), // 2: google.cloud.bigquery.storage.v1.ReadSession.TableReadOptions.ResponseCompressionCodec
  1168  	(WriteStream_Type)(0),                // 3: google.cloud.bigquery.storage.v1.WriteStream.Type
  1169  	(WriteStream_WriteMode)(0),           // 4: google.cloud.bigquery.storage.v1.WriteStream.WriteMode
  1170  	(*ReadSession)(nil),                  // 5: google.cloud.bigquery.storage.v1.ReadSession
  1171  	(*ReadStream)(nil),                   // 6: google.cloud.bigquery.storage.v1.ReadStream
  1172  	(*WriteStream)(nil),                  // 7: google.cloud.bigquery.storage.v1.WriteStream
  1173  	(*ReadSession_TableModifiers)(nil),   // 8: google.cloud.bigquery.storage.v1.ReadSession.TableModifiers
  1174  	(*ReadSession_TableReadOptions)(nil), // 9: google.cloud.bigquery.storage.v1.ReadSession.TableReadOptions
  1175  	(*timestamppb.Timestamp)(nil),        // 10: google.protobuf.Timestamp
  1176  	(*AvroSchema)(nil),                   // 11: google.cloud.bigquery.storage.v1.AvroSchema
  1177  	(*ArrowSchema)(nil),                  // 12: google.cloud.bigquery.storage.v1.ArrowSchema
  1178  	(*TableSchema)(nil),                  // 13: google.cloud.bigquery.storage.v1.TableSchema
  1179  	(*ArrowSerializationOptions)(nil),    // 14: google.cloud.bigquery.storage.v1.ArrowSerializationOptions
  1180  	(*AvroSerializationOptions)(nil),     // 15: google.cloud.bigquery.storage.v1.AvroSerializationOptions
  1181  }
  1182  var file_google_cloud_bigquery_storage_v1_stream_proto_depIdxs = []int32{
  1183  	10, // 0: google.cloud.bigquery.storage.v1.ReadSession.expire_time:type_name -> google.protobuf.Timestamp
  1184  	0,  // 1: google.cloud.bigquery.storage.v1.ReadSession.data_format:type_name -> google.cloud.bigquery.storage.v1.DataFormat
  1185  	11, // 2: google.cloud.bigquery.storage.v1.ReadSession.avro_schema:type_name -> google.cloud.bigquery.storage.v1.AvroSchema
  1186  	12, // 3: google.cloud.bigquery.storage.v1.ReadSession.arrow_schema:type_name -> google.cloud.bigquery.storage.v1.ArrowSchema
  1187  	8,  // 4: google.cloud.bigquery.storage.v1.ReadSession.table_modifiers:type_name -> google.cloud.bigquery.storage.v1.ReadSession.TableModifiers
  1188  	9,  // 5: google.cloud.bigquery.storage.v1.ReadSession.read_options:type_name -> google.cloud.bigquery.storage.v1.ReadSession.TableReadOptions
  1189  	6,  // 6: google.cloud.bigquery.storage.v1.ReadSession.streams:type_name -> google.cloud.bigquery.storage.v1.ReadStream
  1190  	3,  // 7: google.cloud.bigquery.storage.v1.WriteStream.type:type_name -> google.cloud.bigquery.storage.v1.WriteStream.Type
  1191  	10, // 8: google.cloud.bigquery.storage.v1.WriteStream.create_time:type_name -> google.protobuf.Timestamp
  1192  	10, // 9: google.cloud.bigquery.storage.v1.WriteStream.commit_time:type_name -> google.protobuf.Timestamp
  1193  	13, // 10: google.cloud.bigquery.storage.v1.WriteStream.table_schema:type_name -> google.cloud.bigquery.storage.v1.TableSchema
  1194  	4,  // 11: google.cloud.bigquery.storage.v1.WriteStream.write_mode:type_name -> google.cloud.bigquery.storage.v1.WriteStream.WriteMode
  1195  	10, // 12: google.cloud.bigquery.storage.v1.ReadSession.TableModifiers.snapshot_time:type_name -> google.protobuf.Timestamp
  1196  	14, // 13: google.cloud.bigquery.storage.v1.ReadSession.TableReadOptions.arrow_serialization_options:type_name -> google.cloud.bigquery.storage.v1.ArrowSerializationOptions
  1197  	15, // 14: google.cloud.bigquery.storage.v1.ReadSession.TableReadOptions.avro_serialization_options:type_name -> google.cloud.bigquery.storage.v1.AvroSerializationOptions
  1198  	2,  // 15: google.cloud.bigquery.storage.v1.ReadSession.TableReadOptions.response_compression_codec:type_name -> google.cloud.bigquery.storage.v1.ReadSession.TableReadOptions.ResponseCompressionCodec
  1199  	16, // [16:16] is the sub-list for method output_type
  1200  	16, // [16:16] is the sub-list for method input_type
  1201  	16, // [16:16] is the sub-list for extension type_name
  1202  	16, // [16:16] is the sub-list for extension extendee
  1203  	0,  // [0:16] is the sub-list for field type_name
  1204  }
  1205  
  1206  func init() { file_google_cloud_bigquery_storage_v1_stream_proto_init() }
  1207  func file_google_cloud_bigquery_storage_v1_stream_proto_init() {
  1208  	if File_google_cloud_bigquery_storage_v1_stream_proto != nil {
  1209  		return
  1210  	}
  1211  	file_google_cloud_bigquery_storage_v1_arrow_proto_init()
  1212  	file_google_cloud_bigquery_storage_v1_avro_proto_init()
  1213  	file_google_cloud_bigquery_storage_v1_table_proto_init()
  1214  	if !protoimpl.UnsafeEnabled {
  1215  		file_google_cloud_bigquery_storage_v1_stream_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
  1216  			switch v := v.(*ReadSession); i {
  1217  			case 0:
  1218  				return &v.state
  1219  			case 1:
  1220  				return &v.sizeCache
  1221  			case 2:
  1222  				return &v.unknownFields
  1223  			default:
  1224  				return nil
  1225  			}
  1226  		}
  1227  		file_google_cloud_bigquery_storage_v1_stream_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
  1228  			switch v := v.(*ReadStream); i {
  1229  			case 0:
  1230  				return &v.state
  1231  			case 1:
  1232  				return &v.sizeCache
  1233  			case 2:
  1234  				return &v.unknownFields
  1235  			default:
  1236  				return nil
  1237  			}
  1238  		}
  1239  		file_google_cloud_bigquery_storage_v1_stream_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
  1240  			switch v := v.(*WriteStream); i {
  1241  			case 0:
  1242  				return &v.state
  1243  			case 1:
  1244  				return &v.sizeCache
  1245  			case 2:
  1246  				return &v.unknownFields
  1247  			default:
  1248  				return nil
  1249  			}
  1250  		}
  1251  		file_google_cloud_bigquery_storage_v1_stream_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
  1252  			switch v := v.(*ReadSession_TableModifiers); i {
  1253  			case 0:
  1254  				return &v.state
  1255  			case 1:
  1256  				return &v.sizeCache
  1257  			case 2:
  1258  				return &v.unknownFields
  1259  			default:
  1260  				return nil
  1261  			}
  1262  		}
  1263  		file_google_cloud_bigquery_storage_v1_stream_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
  1264  			switch v := v.(*ReadSession_TableReadOptions); i {
  1265  			case 0:
  1266  				return &v.state
  1267  			case 1:
  1268  				return &v.sizeCache
  1269  			case 2:
  1270  				return &v.unknownFields
  1271  			default:
  1272  				return nil
  1273  			}
  1274  		}
  1275  	}
  1276  	file_google_cloud_bigquery_storage_v1_stream_proto_msgTypes[0].OneofWrappers = []interface{}{
  1277  		(*ReadSession_AvroSchema)(nil),
  1278  		(*ReadSession_ArrowSchema)(nil),
  1279  	}
  1280  	file_google_cloud_bigquery_storage_v1_stream_proto_msgTypes[4].OneofWrappers = []interface{}{
  1281  		(*ReadSession_TableReadOptions_ArrowSerializationOptions)(nil),
  1282  		(*ReadSession_TableReadOptions_AvroSerializationOptions)(nil),
  1283  	}
  1284  	type x struct{}
  1285  	out := protoimpl.TypeBuilder{
  1286  		File: protoimpl.DescBuilder{
  1287  			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
  1288  			RawDescriptor: file_google_cloud_bigquery_storage_v1_stream_proto_rawDesc,
  1289  			NumEnums:      5,
  1290  			NumMessages:   5,
  1291  			NumExtensions: 0,
  1292  			NumServices:   0,
  1293  		},
  1294  		GoTypes:           file_google_cloud_bigquery_storage_v1_stream_proto_goTypes,
  1295  		DependencyIndexes: file_google_cloud_bigquery_storage_v1_stream_proto_depIdxs,
  1296  		EnumInfos:         file_google_cloud_bigquery_storage_v1_stream_proto_enumTypes,
  1297  		MessageInfos:      file_google_cloud_bigquery_storage_v1_stream_proto_msgTypes,
  1298  	}.Build()
  1299  	File_google_cloud_bigquery_storage_v1_stream_proto = out.File
  1300  	file_google_cloud_bigquery_storage_v1_stream_proto_rawDesc = nil
  1301  	file_google_cloud_bigquery_storage_v1_stream_proto_goTypes = nil
  1302  	file_google_cloud_bigquery_storage_v1_stream_proto_depIdxs = nil
  1303  }
  1304  

View as plain text