storage.pb.go

Documentation: cloud.google.com/go/bigquery/storage/apiv1beta1/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/v1beta1/storage.proto
    20  
    21  package storagepb
    22  
    23  import (
    24  	context "context"
    25  	reflect "reflect"
    26  	sync "sync"
    27  
    28  	_ "google.golang.org/genproto/googleapis/api/annotations"
    29  	grpc "google.golang.org/grpc"
    30  	codes "google.golang.org/grpc/codes"
    31  	status "google.golang.org/grpc/status"
    32  	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
    33  	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
    34  	emptypb "google.golang.org/protobuf/types/known/emptypb"
    35  	timestamppb "google.golang.org/protobuf/types/known/timestamppb"
    36  )
    37  
    38  const (
    39  	// Verify that this generated code is sufficiently up-to-date.
    40  	_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
    41  	// Verify that runtime/protoimpl is sufficiently up-to-date.
    42  	_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
    43  )
    44  
    45  // Data format for input or output data.
    46  type DataFormat int32
    47  
    48  const (
    49  	// Data format is unspecified.
    50  	DataFormat_DATA_FORMAT_UNSPECIFIED DataFormat = 0
    51  	// Avro is a standard open source row based file format.
    52  	// See https://avro.apache.org/ for more details.
    53  	DataFormat_AVRO DataFormat = 1
    54  	// Arrow is a standard open source column-based message format.
    55  	// See https://arrow.apache.org/ for more details.
    56  	DataFormat_ARROW DataFormat = 3
    57  )
    58  
    59  // Enum value maps for DataFormat.
    60  var (
    61  	DataFormat_name = map[int32]string{
    62  		0: "DATA_FORMAT_UNSPECIFIED",
    63  		1: "AVRO",
    64  		3: "ARROW",
    65  	}
    66  	DataFormat_value = map[string]int32{
    67  		"DATA_FORMAT_UNSPECIFIED": 0,
    68  		"AVRO":                    1,
    69  		"ARROW":                   3,
    70  	}
    71  )
    72  
    73  func (x DataFormat) Enum() *DataFormat {
    74  	p := new(DataFormat)
    75  	*p = x
    76  	return p
    77  }
    78  
    79  func (x DataFormat) String() string {
    80  	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
    81  }
    82  
    83  func (DataFormat) Descriptor() protoreflect.EnumDescriptor {
    84  	return file_google_cloud_bigquery_storage_v1beta1_storage_proto_enumTypes[0].Descriptor()
    85  }
    86  
    87  func (DataFormat) Type() protoreflect.EnumType {
    88  	return &file_google_cloud_bigquery_storage_v1beta1_storage_proto_enumTypes[0]
    89  }
    90  
    91  func (x DataFormat) Number() protoreflect.EnumNumber {
    92  	return protoreflect.EnumNumber(x)
    93  }
    94  
    95  // Deprecated: Use DataFormat.Descriptor instead.
    96  func (DataFormat) EnumDescriptor() ([]byte, []int) {
    97  	return file_google_cloud_bigquery_storage_v1beta1_storage_proto_rawDescGZIP(), []int{0}
    98  }
    99  
   100  // Strategy for distributing data among multiple streams in a read session.
   101  type ShardingStrategy int32
   102  
   103  const (
   104  	// Same as LIQUID.
   105  	ShardingStrategy_SHARDING_STRATEGY_UNSPECIFIED ShardingStrategy = 0
   106  	// Assigns data to each stream based on the client's read rate. The faster the
   107  	// client reads from a stream, the more data is assigned to the stream. In
   108  	// this strategy, it's possible to read all data from a single stream even if
   109  	// there are other streams present.
   110  	ShardingStrategy_LIQUID ShardingStrategy = 1
   111  	// Assigns data to each stream such that roughly the same number of rows can
   112  	// be read from each stream. Because the server-side unit for assigning data
   113  	// is collections of rows, the API does not guarantee that each stream will
   114  	// return the same number or rows. Additionally, the limits are enforced based
   115  	// on the number of pre-filtering rows, so some filters can lead to lopsided
   116  	// assignments.
   117  	ShardingStrategy_BALANCED ShardingStrategy = 2
   118  )
   119  
   120  // Enum value maps for ShardingStrategy.
   121  var (
   122  	ShardingStrategy_name = map[int32]string{
   123  		0: "SHARDING_STRATEGY_UNSPECIFIED",
   124  		1: "LIQUID",
   125  		2: "BALANCED",
   126  	}
   127  	ShardingStrategy_value = map[string]int32{
   128  		"SHARDING_STRATEGY_UNSPECIFIED": 0,
   129  		"LIQUID":                        1,
   130  		"BALANCED":                      2,
   131  	}
   132  )
   133  
   134  func (x ShardingStrategy) Enum() *ShardingStrategy {
   135  	p := new(ShardingStrategy)
   136  	*p = x
   137  	return p
   138  }
   139  
   140  func (x ShardingStrategy) String() string {
   141  	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
   142  }
   143  
   144  func (ShardingStrategy) Descriptor() protoreflect.EnumDescriptor {
   145  	return file_google_cloud_bigquery_storage_v1beta1_storage_proto_enumTypes[1].Descriptor()
   146  }
   147  
   148  func (ShardingStrategy) Type() protoreflect.EnumType {
   149  	return &file_google_cloud_bigquery_storage_v1beta1_storage_proto_enumTypes[1]
   150  }
   151  
   152  func (x ShardingStrategy) Number() protoreflect.EnumNumber {
   153  	return protoreflect.EnumNumber(x)
   154  }
   155  
   156  // Deprecated: Use ShardingStrategy.Descriptor instead.
   157  func (ShardingStrategy) EnumDescriptor() ([]byte, []int) {
   158  	return file_google_cloud_bigquery_storage_v1beta1_storage_proto_rawDescGZIP(), []int{1}
   159  }
   160  
   161  // Information about a single data stream within a read session.
   162  type Stream struct {
   163  	state         protoimpl.MessageState
   164  	sizeCache     protoimpl.SizeCache
   165  	unknownFields protoimpl.UnknownFields
   166  
   167  	// Name of the stream, in the form
   168  	// `projects/{project_id}/locations/{location}/streams/{stream_id}`.
   169  	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
   170  }
   171  
   172  func (x *Stream) Reset() {
   173  	*x = Stream{}
   174  	if protoimpl.UnsafeEnabled {
   175  		mi := &file_google_cloud_bigquery_storage_v1beta1_storage_proto_msgTypes[0]
   176  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   177  		ms.StoreMessageInfo(mi)
   178  	}
   179  }
   180  
   181  func (x *Stream) String() string {
   182  	return protoimpl.X.MessageStringOf(x)
   183  }
   184  
   185  func (*Stream) ProtoMessage() {}
   186  
   187  func (x *Stream) ProtoReflect() protoreflect.Message {
   188  	mi := &file_google_cloud_bigquery_storage_v1beta1_storage_proto_msgTypes[0]
   189  	if protoimpl.UnsafeEnabled && x != nil {
   190  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   191  		if ms.LoadMessageInfo() == nil {
   192  			ms.StoreMessageInfo(mi)
   193  		}
   194  		return ms
   195  	}
   196  	return mi.MessageOf(x)
   197  }
   198  
   199  // Deprecated: Use Stream.ProtoReflect.Descriptor instead.
   200  func (*Stream) Descriptor() ([]byte, []int) {
   201  	return file_google_cloud_bigquery_storage_v1beta1_storage_proto_rawDescGZIP(), []int{0}
   202  }
   203  
   204  func (x *Stream) GetName() string {
   205  	if x != nil {
   206  		return x.Name
   207  	}
   208  	return ""
   209  }
   210  
   211  // Expresses a point within a given stream using an offset position.
   212  type StreamPosition struct {
   213  	state         protoimpl.MessageState
   214  	sizeCache     protoimpl.SizeCache
   215  	unknownFields protoimpl.UnknownFields
   216  
   217  	// Identifier for a given Stream.
   218  	Stream *Stream `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"`
   219  	// Position in the stream.
   220  	Offset int64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
   221  }
   222  
   223  func (x *StreamPosition) Reset() {
   224  	*x = StreamPosition{}
   225  	if protoimpl.UnsafeEnabled {
   226  		mi := &file_google_cloud_bigquery_storage_v1beta1_storage_proto_msgTypes[1]
   227  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   228  		ms.StoreMessageInfo(mi)
   229  	}
   230  }
   231  
   232  func (x *StreamPosition) String() string {
   233  	return protoimpl.X.MessageStringOf(x)
   234  }
   235  
   236  func (*StreamPosition) ProtoMessage() {}
   237  
   238  func (x *StreamPosition) ProtoReflect() protoreflect.Message {
   239  	mi := &file_google_cloud_bigquery_storage_v1beta1_storage_proto_msgTypes[1]
   240  	if protoimpl.UnsafeEnabled && x != nil {
   241  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   242  		if ms.LoadMessageInfo() == nil {
   243  			ms.StoreMessageInfo(mi)
   244  		}
   245  		return ms
   246  	}
   247  	return mi.MessageOf(x)
   248  }
   249  
   250  // Deprecated: Use StreamPosition.ProtoReflect.Descriptor instead.
   251  func (*StreamPosition) Descriptor() ([]byte, []int) {
   252  	return file_google_cloud_bigquery_storage_v1beta1_storage_proto_rawDescGZIP(), []int{1}
   253  }
   254  
   255  func (x *StreamPosition) GetStream() *Stream {
   256  	if x != nil {
   257  		return x.Stream
   258  	}
   259  	return nil
   260  }
   261  
   262  func (x *StreamPosition) GetOffset() int64 {
   263  	if x != nil {
   264  		return x.Offset
   265  	}
   266  	return 0
   267  }
   268  
   269  // Information returned from a `CreateReadSession` request.
   270  type ReadSession struct {
   271  	state         protoimpl.MessageState
   272  	sizeCache     protoimpl.SizeCache
   273  	unknownFields protoimpl.UnknownFields
   274  
   275  	// Unique identifier for the session, in the form
   276  	// `projects/{project_id}/locations/{location}/sessions/{session_id}`.
   277  	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
   278  	// Time at which the session becomes invalid. After this time, subsequent
   279  	// requests to read this Session will return errors.
   280  	ExpireTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=expire_time,json=expireTime,proto3" json:"expire_time,omitempty"`
   281  	// The schema for the read. If read_options.selected_fields is set, the
   282  	// schema may be different from the table schema as it will only contain
   283  	// the selected fields.
   284  	//
   285  	// Types that are assignable to Schema:
   286  	//
   287  	//	*ReadSession_AvroSchema
   288  	//	*ReadSession_ArrowSchema
   289  	Schema isReadSession_Schema `protobuf_oneof:"schema"`
   290  	// Streams associated with this session.
   291  	Streams []*Stream `protobuf:"bytes,4,rep,name=streams,proto3" json:"streams,omitempty"`
   292  	// Table that this ReadSession is reading from.
   293  	TableReference *TableReference `protobuf:"bytes,7,opt,name=table_reference,json=tableReference,proto3" json:"table_reference,omitempty"`
   294  	// Any modifiers which are applied when reading from the specified table.
   295  	TableModifiers *TableModifiers `protobuf:"bytes,8,opt,name=table_modifiers,json=tableModifiers,proto3" json:"table_modifiers,omitempty"`
   296  	// The strategy to use for distributing data among the streams.
   297  	ShardingStrategy ShardingStrategy `protobuf:"varint,9,opt,name=sharding_strategy,json=shardingStrategy,proto3,enum=google.cloud.bigquery.storage.v1beta1.ShardingStrategy" json:"sharding_strategy,omitempty"`
   298  }
   299  
   300  func (x *ReadSession) Reset() {
   301  	*x = ReadSession{}
   302  	if protoimpl.UnsafeEnabled {
   303  		mi := &file_google_cloud_bigquery_storage_v1beta1_storage_proto_msgTypes[2]
   304  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   305  		ms.StoreMessageInfo(mi)
   306  	}
   307  }
   308  
   309  func (x *ReadSession) String() string {
   310  	return protoimpl.X.MessageStringOf(x)
   311  }
   312  
   313  func (*ReadSession) ProtoMessage() {}
   314  
   315  func (x *ReadSession) ProtoReflect() protoreflect.Message {
   316  	mi := &file_google_cloud_bigquery_storage_v1beta1_storage_proto_msgTypes[2]
   317  	if protoimpl.UnsafeEnabled && x != nil {
   318  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   319  		if ms.LoadMessageInfo() == nil {
   320  			ms.StoreMessageInfo(mi)
   321  		}
   322  		return ms
   323  	}
   324  	return mi.MessageOf(x)
   325  }
   326  
   327  // Deprecated: Use ReadSession.ProtoReflect.Descriptor instead.
   328  func (*ReadSession) Descriptor() ([]byte, []int) {
   329  	return file_google_cloud_bigquery_storage_v1beta1_storage_proto_rawDescGZIP(), []int{2}
   330  }
   331  
   332  func (x *ReadSession) GetName() string {
   333  	if x != nil {
   334  		return x.Name
   335  	}
   336  	return ""
   337  }
   338  
   339  func (x *ReadSession) GetExpireTime() *timestamppb.Timestamp {
   340  	if x != nil {
   341  		return x.ExpireTime
   342  	}
   343  	return nil
   344  }
   345  
   346  func (m *ReadSession) GetSchema() isReadSession_Schema {
   347  	if m != nil {
   348  		return m.Schema
   349  	}
   350  	return nil
   351  }
   352  
   353  func (x *ReadSession) GetAvroSchema() *AvroSchema {
   354  	if x, ok := x.GetSchema().(*ReadSession_AvroSchema); ok {
   355  		return x.AvroSchema
   356  	}
   357  	return nil
   358  }
   359  
   360  func (x *ReadSession) GetArrowSchema() *ArrowSchema {
   361  	if x, ok := x.GetSchema().(*ReadSession_ArrowSchema); ok {
   362  		return x.ArrowSchema
   363  	}
   364  	return nil
   365  }
   366  
   367  func (x *ReadSession) GetStreams() []*Stream {
   368  	if x != nil {
   369  		return x.Streams
   370  	}
   371  	return nil
   372  }
   373  
   374  func (x *ReadSession) GetTableReference() *TableReference {
   375  	if x != nil {
   376  		return x.TableReference
   377  	}
   378  	return nil
   379  }
   380  
   381  func (x *ReadSession) GetTableModifiers() *TableModifiers {
   382  	if x != nil {
   383  		return x.TableModifiers
   384  	}
   385  	return nil
   386  }
   387  
   388  func (x *ReadSession) GetShardingStrategy() ShardingStrategy {
   389  	if x != nil {
   390  		return x.ShardingStrategy
   391  	}
   392  	return ShardingStrategy_SHARDING_STRATEGY_UNSPECIFIED
   393  }
   394  
   395  type isReadSession_Schema interface {
   396  	isReadSession_Schema()
   397  }
   398  
   399  type ReadSession_AvroSchema struct {
   400  	// Avro schema.
   401  	AvroSchema *AvroSchema `protobuf:"bytes,5,opt,name=avro_schema,json=avroSchema,proto3,oneof"`
   402  }
   403  
   404  type ReadSession_ArrowSchema struct {
   405  	// Arrow schema.
   406  	ArrowSchema *ArrowSchema `protobuf:"bytes,6,opt,name=arrow_schema,json=arrowSchema,proto3,oneof"`
   407  }
   408  
   409  func (*ReadSession_AvroSchema) isReadSession_Schema() {}
   410  
   411  func (*ReadSession_ArrowSchema) isReadSession_Schema() {}
   412  
   413  // Creates a new read session, which may include additional options such as
   414  // requested parallelism, projection filters and constraints.
   415  type CreateReadSessionRequest struct {
   416  	state         protoimpl.MessageState
   417  	sizeCache     protoimpl.SizeCache
   418  	unknownFields protoimpl.UnknownFields
   419  
   420  	// Required. Reference to the table to read.
   421  	TableReference *TableReference `protobuf:"bytes,1,opt,name=table_reference,json=tableReference,proto3" json:"table_reference,omitempty"`
   422  	// Required. String of the form `projects/{project_id}` indicating the
   423  	// project this ReadSession is associated with. This is the project that will
   424  	// be billed for usage.
   425  	Parent string `protobuf:"bytes,6,opt,name=parent,proto3" json:"parent,omitempty"`
   426  	// Any modifiers to the Table (e.g. snapshot timestamp).
   427  	TableModifiers *TableModifiers `protobuf:"bytes,2,opt,name=table_modifiers,json=tableModifiers,proto3" json:"table_modifiers,omitempty"`
   428  	// Initial number of streams. If unset or 0, we will
   429  	// provide a value of streams so as to produce reasonable throughput. Must be
   430  	// non-negative. The number of streams may be lower than the requested number,
   431  	// depending on the amount parallelism that is reasonable for the table and
   432  	// the maximum amount of parallelism allowed by the system.
   433  	//
   434  	// Streams must be read starting from offset 0.
   435  	RequestedStreams int32 `protobuf:"varint,3,opt,name=requested_streams,json=requestedStreams,proto3" json:"requested_streams,omitempty"`
   436  	// Read options for this session (e.g. column selection, filters).
   437  	ReadOptions *TableReadOptions `protobuf:"bytes,4,opt,name=read_options,json=readOptions,proto3" json:"read_options,omitempty"`
   438  	// Data output format. Currently default to Avro.
   439  	// DATA_FORMAT_UNSPECIFIED not supported.
   440  	Format DataFormat `protobuf:"varint,5,opt,name=format,proto3,enum=google.cloud.bigquery.storage.v1beta1.DataFormat" json:"format,omitempty"`
   441  	// The strategy to use for distributing data among multiple streams. Currently
   442  	// defaults to liquid sharding.
   443  	ShardingStrategy ShardingStrategy `protobuf:"varint,7,opt,name=sharding_strategy,json=shardingStrategy,proto3,enum=google.cloud.bigquery.storage.v1beta1.ShardingStrategy" json:"sharding_strategy,omitempty"`
   444  }
   445  
   446  func (x *CreateReadSessionRequest) Reset() {
   447  	*x = CreateReadSessionRequest{}
   448  	if protoimpl.UnsafeEnabled {
   449  		mi := &file_google_cloud_bigquery_storage_v1beta1_storage_proto_msgTypes[3]
   450  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   451  		ms.StoreMessageInfo(mi)
   452  	}
   453  }
   454  
   455  func (x *CreateReadSessionRequest) String() string {
   456  	return protoimpl.X.MessageStringOf(x)
   457  }
   458  
   459  func (*CreateReadSessionRequest) ProtoMessage() {}
   460  
   461  func (x *CreateReadSessionRequest) ProtoReflect() protoreflect.Message {
   462  	mi := &file_google_cloud_bigquery_storage_v1beta1_storage_proto_msgTypes[3]
   463  	if protoimpl.UnsafeEnabled && x != nil {
   464  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   465  		if ms.LoadMessageInfo() == nil {
   466  			ms.StoreMessageInfo(mi)
   467  		}
   468  		return ms
   469  	}
   470  	return mi.MessageOf(x)
   471  }
   472  
   473  // Deprecated: Use CreateReadSessionRequest.ProtoReflect.Descriptor instead.
   474  func (*CreateReadSessionRequest) Descriptor() ([]byte, []int) {
   475  	return file_google_cloud_bigquery_storage_v1beta1_storage_proto_rawDescGZIP(), []int{3}
   476  }
   477  
   478  func (x *CreateReadSessionRequest) GetTableReference() *TableReference {
   479  	if x != nil {
   480  		return x.TableReference
   481  	}
   482  	return nil
   483  }
   484  
   485  func (x *CreateReadSessionRequest) GetParent() string {
   486  	if x != nil {
   487  		return x.Parent
   488  	}
   489  	return ""
   490  }
   491  
   492  func (x *CreateReadSessionRequest) GetTableModifiers() *TableModifiers {
   493  	if x != nil {
   494  		return x.TableModifiers
   495  	}
   496  	return nil
   497  }
   498  
   499  func (x *CreateReadSessionRequest) GetRequestedStreams() int32 {
   500  	if x != nil {
   501  		return x.RequestedStreams
   502  	}
   503  	return 0
   504  }
   505  
   506  func (x *CreateReadSessionRequest) GetReadOptions() *TableReadOptions {
   507  	if x != nil {
   508  		return x.ReadOptions
   509  	}
   510  	return nil
   511  }
   512  
   513  func (x *CreateReadSessionRequest) GetFormat() DataFormat {
   514  	if x != nil {
   515  		return x.Format
   516  	}
   517  	return DataFormat_DATA_FORMAT_UNSPECIFIED
   518  }
   519  
   520  func (x *CreateReadSessionRequest) GetShardingStrategy() ShardingStrategy {
   521  	if x != nil {
   522  		return x.ShardingStrategy
   523  	}
   524  	return ShardingStrategy_SHARDING_STRATEGY_UNSPECIFIED
   525  }
   526  
   527  // Requesting row data via `ReadRows` must provide Stream position information.
   528  type ReadRowsRequest struct {
   529  	state         protoimpl.MessageState
   530  	sizeCache     protoimpl.SizeCache
   531  	unknownFields protoimpl.UnknownFields
   532  
   533  	// Required. Identifier of the position in the stream to start reading from.
   534  	// The offset requested must be less than the last row read from ReadRows.
   535  	// Requesting a larger offset is undefined.
   536  	ReadPosition *StreamPosition `protobuf:"bytes,1,opt,name=read_position,json=readPosition,proto3" json:"read_position,omitempty"`
   537  }
   538  
   539  func (x *ReadRowsRequest) Reset() {
   540  	*x = ReadRowsRequest{}
   541  	if protoimpl.UnsafeEnabled {
   542  		mi := &file_google_cloud_bigquery_storage_v1beta1_storage_proto_msgTypes[4]
   543  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   544  		ms.StoreMessageInfo(mi)
   545  	}
   546  }
   547  
   548  func (x *ReadRowsRequest) String() string {
   549  	return protoimpl.X.MessageStringOf(x)
   550  }
   551  
   552  func (*ReadRowsRequest) ProtoMessage() {}
   553  
   554  func (x *ReadRowsRequest) ProtoReflect() protoreflect.Message {
   555  	mi := &file_google_cloud_bigquery_storage_v1beta1_storage_proto_msgTypes[4]
   556  	if protoimpl.UnsafeEnabled && x != nil {
   557  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   558  		if ms.LoadMessageInfo() == nil {
   559  			ms.StoreMessageInfo(mi)
   560  		}
   561  		return ms
   562  	}
   563  	return mi.MessageOf(x)
   564  }
   565  
   566  // Deprecated: Use ReadRowsRequest.ProtoReflect.Descriptor instead.
   567  func (*ReadRowsRequest) Descriptor() ([]byte, []int) {
   568  	return file_google_cloud_bigquery_storage_v1beta1_storage_proto_rawDescGZIP(), []int{4}
   569  }
   570  
   571  func (x *ReadRowsRequest) GetReadPosition() *StreamPosition {
   572  	if x != nil {
   573  		return x.ReadPosition
   574  	}
   575  	return nil
   576  }
   577  
   578  // Progress information for a given Stream.
   579  type StreamStatus struct {
   580  	state         protoimpl.MessageState
   581  	sizeCache     protoimpl.SizeCache
   582  	unknownFields protoimpl.UnknownFields
   583  
   584  	// Number of estimated rows in the current stream. May change over time as
   585  	// different readers in the stream progress at rates which are relatively fast
   586  	// or slow.
   587  	EstimatedRowCount int64 `protobuf:"varint,1,opt,name=estimated_row_count,json=estimatedRowCount,proto3" json:"estimated_row_count,omitempty"`
   588  	// A value in the range [0.0, 1.0] that represents the fraction of rows
   589  	// assigned to this stream that have been processed by the server. In the
   590  	// presence of read filters, the server may process more rows than it returns,
   591  	// so this value reflects progress through the pre-filtering rows.
   592  	//
   593  	// This value is only populated for sessions created through the BALANCED
   594  	// sharding strategy.
   595  	FractionConsumed float32 `protobuf:"fixed32,2,opt,name=fraction_consumed,json=fractionConsumed,proto3" json:"fraction_consumed,omitempty"`
   596  	// Represents the progress of the current stream.
   597  	Progress *Progress `protobuf:"bytes,4,opt,name=progress,proto3" json:"progress,omitempty"`
   598  	// Whether this stream can be split. For sessions that use the LIQUID sharding
   599  	// strategy, this value is always false. For BALANCED sessions, this value is
   600  	// false when enough data have been read such that no more splits are possible
   601  	// at that point or beyond. For small tables or streams that are the result of
   602  	// a chain of splits, this value may never be true.
   603  	IsSplittable bool `protobuf:"varint,3,opt,name=is_splittable,json=isSplittable,proto3" json:"is_splittable,omitempty"`
   604  }
   605  
   606  func (x *StreamStatus) Reset() {
   607  	*x = StreamStatus{}
   608  	if protoimpl.UnsafeEnabled {
   609  		mi := &file_google_cloud_bigquery_storage_v1beta1_storage_proto_msgTypes[5]
   610  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   611  		ms.StoreMessageInfo(mi)
   612  	}
   613  }
   614  
   615  func (x *StreamStatus) String() string {
   616  	return protoimpl.X.MessageStringOf(x)
   617  }
   618  
   619  func (*StreamStatus) ProtoMessage() {}
   620  
   621  func (x *StreamStatus) ProtoReflect() protoreflect.Message {
   622  	mi := &file_google_cloud_bigquery_storage_v1beta1_storage_proto_msgTypes[5]
   623  	if protoimpl.UnsafeEnabled && x != nil {
   624  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   625  		if ms.LoadMessageInfo() == nil {
   626  			ms.StoreMessageInfo(mi)
   627  		}
   628  		return ms
   629  	}
   630  	return mi.MessageOf(x)
   631  }
   632  
   633  // Deprecated: Use StreamStatus.ProtoReflect.Descriptor instead.
   634  func (*StreamStatus) Descriptor() ([]byte, []int) {
   635  	return file_google_cloud_bigquery_storage_v1beta1_storage_proto_rawDescGZIP(), []int{5}
   636  }
   637  
   638  func (x *StreamStatus) GetEstimatedRowCount() int64 {
   639  	if x != nil {
   640  		return x.EstimatedRowCount
   641  	}
   642  	return 0
   643  }
   644  
   645  func (x *StreamStatus) GetFractionConsumed() float32 {
   646  	if x != nil {
   647  		return x.FractionConsumed
   648  	}
   649  	return 0
   650  }
   651  
   652  func (x *StreamStatus) GetProgress() *Progress {
   653  	if x != nil {
   654  		return x.Progress
   655  	}
   656  	return nil
   657  }
   658  
   659  func (x *StreamStatus) GetIsSplittable() bool {
   660  	if x != nil {
   661  		return x.IsSplittable
   662  	}
   663  	return false
   664  }
   665  
   666  type Progress struct {
   667  	state         protoimpl.MessageState
   668  	sizeCache     protoimpl.SizeCache
   669  	unknownFields protoimpl.UnknownFields
   670  
   671  	// The fraction of rows assigned to the stream that have been processed by the
   672  	// server so far, not including the rows in the current response message.
   673  	//
   674  	// This value, along with `at_response_end`, can be used to interpolate the
   675  	// progress made as the rows in the message are being processed using the
   676  	// following formula: `at_response_start + (at_response_end -
   677  	// at_response_start) * rows_processed_from_response / rows_in_response`.
   678  	//
   679  	// Note that if a filter is provided, the `at_response_end` value of the
   680  	// previous response may not necessarily be equal to the `at_response_start`
   681  	// value of the current response.
   682  	AtResponseStart float32 `protobuf:"fixed32,1,opt,name=at_response_start,json=atResponseStart,proto3" json:"at_response_start,omitempty"`
   683  	// Similar to `at_response_start`, except that this value includes the rows in
   684  	// the current response.
   685  	AtResponseEnd float32 `protobuf:"fixed32,2,opt,name=at_response_end,json=atResponseEnd,proto3" json:"at_response_end,omitempty"`
   686  }
   687  
   688  func (x *Progress) Reset() {
   689  	*x = Progress{}
   690  	if protoimpl.UnsafeEnabled {
   691  		mi := &file_google_cloud_bigquery_storage_v1beta1_storage_proto_msgTypes[6]
   692  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   693  		ms.StoreMessageInfo(mi)
   694  	}
   695  }
   696  
   697  func (x *Progress) String() string {
   698  	return protoimpl.X.MessageStringOf(x)
   699  }
   700  
   701  func (*Progress) ProtoMessage() {}
   702  
   703  func (x *Progress) ProtoReflect() protoreflect.Message {
   704  	mi := &file_google_cloud_bigquery_storage_v1beta1_storage_proto_msgTypes[6]
   705  	if protoimpl.UnsafeEnabled && x != nil {
   706  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   707  		if ms.LoadMessageInfo() == nil {
   708  			ms.StoreMessageInfo(mi)
   709  		}
   710  		return ms
   711  	}
   712  	return mi.MessageOf(x)
   713  }
   714  
   715  // Deprecated: Use Progress.ProtoReflect.Descriptor instead.
   716  func (*Progress) Descriptor() ([]byte, []int) {
   717  	return file_google_cloud_bigquery_storage_v1beta1_storage_proto_rawDescGZIP(), []int{6}
   718  }
   719  
   720  func (x *Progress) GetAtResponseStart() float32 {
   721  	if x != nil {
   722  		return x.AtResponseStart
   723  	}
   724  	return 0
   725  }
   726  
   727  func (x *Progress) GetAtResponseEnd() float32 {
   728  	if x != nil {
   729  		return x.AtResponseEnd
   730  	}
   731  	return 0
   732  }
   733  
   734  // Information on if the current connection is being throttled.
   735  type ThrottleStatus struct {
   736  	state         protoimpl.MessageState
   737  	sizeCache     protoimpl.SizeCache
   738  	unknownFields protoimpl.UnknownFields
   739  
   740  	// How much this connection is being throttled.
   741  	// 0 is no throttling, 100 is completely throttled.
   742  	ThrottlePercent int32 `protobuf:"varint,1,opt,name=throttle_percent,json=throttlePercent,proto3" json:"throttle_percent,omitempty"`
   743  }
   744  
   745  func (x *ThrottleStatus) Reset() {
   746  	*x = ThrottleStatus{}
   747  	if protoimpl.UnsafeEnabled {
   748  		mi := &file_google_cloud_bigquery_storage_v1beta1_storage_proto_msgTypes[7]
   749  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   750  		ms.StoreMessageInfo(mi)
   751  	}
   752  }
   753  
   754  func (x *ThrottleStatus) String() string {
   755  	return protoimpl.X.MessageStringOf(x)
   756  }
   757  
   758  func (*ThrottleStatus) ProtoMessage() {}
   759  
   760  func (x *ThrottleStatus) ProtoReflect() protoreflect.Message {
   761  	mi := &file_google_cloud_bigquery_storage_v1beta1_storage_proto_msgTypes[7]
   762  	if protoimpl.UnsafeEnabled && x != nil {
   763  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   764  		if ms.LoadMessageInfo() == nil {
   765  			ms.StoreMessageInfo(mi)
   766  		}
   767  		return ms
   768  	}
   769  	return mi.MessageOf(x)
   770  }
   771  
   772  // Deprecated: Use ThrottleStatus.ProtoReflect.Descriptor instead.
   773  func (*ThrottleStatus) Descriptor() ([]byte, []int) {
   774  	return file_google_cloud_bigquery_storage_v1beta1_storage_proto_rawDescGZIP(), []int{7}
   775  }
   776  
   777  func (x *ThrottleStatus) GetThrottlePercent() int32 {
   778  	if x != nil {
   779  		return x.ThrottlePercent
   780  	}
   781  	return 0
   782  }
   783  
   784  // Response from calling `ReadRows` may include row data, progress and
   785  // throttling information.
   786  type ReadRowsResponse struct {
   787  	state         protoimpl.MessageState
   788  	sizeCache     protoimpl.SizeCache
   789  	unknownFields protoimpl.UnknownFields
   790  
   791  	// Row data is returned in format specified during session creation.
   792  	//
   793  	// Types that are assignable to Rows:
   794  	//
   795  	//	*ReadRowsResponse_AvroRows
   796  	//	*ReadRowsResponse_ArrowRecordBatch
   797  	Rows isReadRowsResponse_Rows `protobuf_oneof:"rows"`
   798  	// Number of serialized rows in the rows block. This value is recorded here,
   799  	// in addition to the row_count values in the output-specific messages in
   800  	// `rows`, so that code which needs to record progress through the stream can
   801  	// do so in an output format-independent way.
   802  	RowCount int64 `protobuf:"varint,6,opt,name=row_count,json=rowCount,proto3" json:"row_count,omitempty"`
   803  	// Estimated stream statistics.
   804  	Status *StreamStatus `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
   805  	// Throttling status. If unset, the latest response still describes
   806  	// the current throttling status.
   807  	ThrottleStatus *ThrottleStatus `protobuf:"bytes,5,opt,name=throttle_status,json=throttleStatus,proto3" json:"throttle_status,omitempty"`
   808  	// The schema for the read. If read_options.selected_fields is set, the
   809  	// schema may be different from the table schema as it will only contain
   810  	// the selected fields. This schema is equivalent to the one returned by
   811  	// CreateSession. This field is only populated in the first ReadRowsResponse
   812  	// RPC.
   813  	//
   814  	// Types that are assignable to Schema:
   815  	//
   816  	//	*ReadRowsResponse_AvroSchema
   817  	//	*ReadRowsResponse_ArrowSchema
   818  	Schema isReadRowsResponse_Schema `protobuf_oneof:"schema"`
   819  }
   820  
   821  func (x *ReadRowsResponse) Reset() {
   822  	*x = ReadRowsResponse{}
   823  	if protoimpl.UnsafeEnabled {
   824  		mi := &file_google_cloud_bigquery_storage_v1beta1_storage_proto_msgTypes[8]
   825  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   826  		ms.StoreMessageInfo(mi)
   827  	}
   828  }
   829  
   830  func (x *ReadRowsResponse) String() string {
   831  	return protoimpl.X.MessageStringOf(x)
   832  }
   833  
   834  func (*ReadRowsResponse) ProtoMessage() {}
   835  
   836  func (x *ReadRowsResponse) ProtoReflect() protoreflect.Message {
   837  	mi := &file_google_cloud_bigquery_storage_v1beta1_storage_proto_msgTypes[8]
   838  	if protoimpl.UnsafeEnabled && x != nil {
   839  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   840  		if ms.LoadMessageInfo() == nil {
   841  			ms.StoreMessageInfo(mi)
   842  		}
   843  		return ms
   844  	}
   845  	return mi.MessageOf(x)
   846  }
   847  
   848  // Deprecated: Use ReadRowsResponse.ProtoReflect.Descriptor instead.
   849  func (*ReadRowsResponse) Descriptor() ([]byte, []int) {
   850  	return file_google_cloud_bigquery_storage_v1beta1_storage_proto_rawDescGZIP(), []int{8}
   851  }
   852  
   853  func (m *ReadRowsResponse) GetRows() isReadRowsResponse_Rows {
   854  	if m != nil {
   855  		return m.Rows
   856  	}
   857  	return nil
   858  }
   859  
   860  func (x *ReadRowsResponse) GetAvroRows() *AvroRows {
   861  	if x, ok := x.GetRows().(*ReadRowsResponse_AvroRows); ok {
   862  		return x.AvroRows
   863  	}
   864  	return nil
   865  }
   866  
   867  func (x *ReadRowsResponse) GetArrowRecordBatch() *ArrowRecordBatch {
   868  	if x, ok := x.GetRows().(*ReadRowsResponse_ArrowRecordBatch); ok {
   869  		return x.ArrowRecordBatch
   870  	}
   871  	return nil
   872  }
   873  
   874  func (x *ReadRowsResponse) GetRowCount() int64 {
   875  	if x != nil {
   876  		return x.RowCount
   877  	}
   878  	return 0
   879  }
   880  
   881  func (x *ReadRowsResponse) GetStatus() *StreamStatus {
   882  	if x != nil {
   883  		return x.Status
   884  	}
   885  	return nil
   886  }
   887  
   888  func (x *ReadRowsResponse) GetThrottleStatus() *ThrottleStatus {
   889  	if x != nil {
   890  		return x.ThrottleStatus
   891  	}
   892  	return nil
   893  }
   894  
   895  func (m *ReadRowsResponse) GetSchema() isReadRowsResponse_Schema {
   896  	if m != nil {
   897  		return m.Schema
   898  	}
   899  	return nil
   900  }
   901  
   902  func (x *ReadRowsResponse) GetAvroSchema() *AvroSchema {
   903  	if x, ok := x.GetSchema().(*ReadRowsResponse_AvroSchema); ok {
   904  		return x.AvroSchema
   905  	}
   906  	return nil
   907  }
   908  
   909  func (x *ReadRowsResponse) GetArrowSchema() *ArrowSchema {
   910  	if x, ok := x.GetSchema().(*ReadRowsResponse_ArrowSchema); ok {
   911  		return x.ArrowSchema
   912  	}
   913  	return nil
   914  }
   915  
   916  type isReadRowsResponse_Rows interface {
   917  	isReadRowsResponse_Rows()
   918  }
   919  
   920  type ReadRowsResponse_AvroRows struct {
   921  	// Serialized row data in AVRO format.
   922  	AvroRows *AvroRows `protobuf:"bytes,3,opt,name=avro_rows,json=avroRows,proto3,oneof"`
   923  }
   924  
   925  type ReadRowsResponse_ArrowRecordBatch struct {
   926  	// Serialized row data in Arrow RecordBatch format.
   927  	ArrowRecordBatch *ArrowRecordBatch `protobuf:"bytes,4,opt,name=arrow_record_batch,json=arrowRecordBatch,proto3,oneof"`
   928  }
   929  
   930  func (*ReadRowsResponse_AvroRows) isReadRowsResponse_Rows() {}
   931  
   932  func (*ReadRowsResponse_ArrowRecordBatch) isReadRowsResponse_Rows() {}
   933  
   934  type isReadRowsResponse_Schema interface {
   935  	isReadRowsResponse_Schema()
   936  }
   937  
   938  type ReadRowsResponse_AvroSchema struct {
   939  	// Output only. Avro schema.
   940  	AvroSchema *AvroSchema `protobuf:"bytes,7,opt,name=avro_schema,json=avroSchema,proto3,oneof"`
   941  }
   942  
   943  type ReadRowsResponse_ArrowSchema struct {
   944  	// Output only. Arrow schema.
   945  	ArrowSchema *ArrowSchema `protobuf:"bytes,8,opt,name=arrow_schema,json=arrowSchema,proto3,oneof"`
   946  }
   947  
   948  func (*ReadRowsResponse_AvroSchema) isReadRowsResponse_Schema() {}
   949  
   950  func (*ReadRowsResponse_ArrowSchema) isReadRowsResponse_Schema() {}
   951  
   952  // Information needed to request additional streams for an established read
   953  // session.
   954  type BatchCreateReadSessionStreamsRequest struct {
   955  	state         protoimpl.MessageState
   956  	sizeCache     protoimpl.SizeCache
   957  	unknownFields protoimpl.UnknownFields
   958  
   959  	// Required. Must be a non-expired session obtained from a call to
   960  	// CreateReadSession. Only the name field needs to be set.
   961  	Session *ReadSession `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
   962  	// Required. Number of new streams requested. Must be positive.
   963  	// Number of added streams may be less than this, see CreateReadSessionRequest
   964  	// for more information.
   965  	RequestedStreams int32 `protobuf:"varint,2,opt,name=requested_streams,json=requestedStreams,proto3" json:"requested_streams,omitempty"`
   966  }
   967  
   968  func (x *BatchCreateReadSessionStreamsRequest) Reset() {
   969  	*x = BatchCreateReadSessionStreamsRequest{}
   970  	if protoimpl.UnsafeEnabled {
   971  		mi := &file_google_cloud_bigquery_storage_v1beta1_storage_proto_msgTypes[9]
   972  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   973  		ms.StoreMessageInfo(mi)
   974  	}
   975  }
   976  
   977  func (x *BatchCreateReadSessionStreamsRequest) String() string {
   978  	return protoimpl.X.MessageStringOf(x)
   979  }
   980  
   981  func (*BatchCreateReadSessionStreamsRequest) ProtoMessage() {}
   982  
   983  func (x *BatchCreateReadSessionStreamsRequest) ProtoReflect() protoreflect.Message {
   984  	mi := &file_google_cloud_bigquery_storage_v1beta1_storage_proto_msgTypes[9]
   985  	if protoimpl.UnsafeEnabled && x != nil {
   986  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   987  		if ms.LoadMessageInfo() == nil {
   988  			ms.StoreMessageInfo(mi)
   989  		}
   990  		return ms
   991  	}
   992  	return mi.MessageOf(x)
   993  }
   994  
   995  // Deprecated: Use BatchCreateReadSessionStreamsRequest.ProtoReflect.Descriptor instead.
   996  func (*BatchCreateReadSessionStreamsRequest) Descriptor() ([]byte, []int) {
   997  	return file_google_cloud_bigquery_storage_v1beta1_storage_proto_rawDescGZIP(), []int{9}
   998  }
   999  
  1000  func (x *BatchCreateReadSessionStreamsRequest) GetSession() *ReadSession {
  1001  	if x != nil {
  1002  		return x.Session
  1003  	}
  1004  	return nil
  1005  }
  1006  
  1007  func (x *BatchCreateReadSessionStreamsRequest) GetRequestedStreams() int32 {
  1008  	if x != nil {
  1009  		return x.RequestedStreams
  1010  	}
  1011  	return 0
  1012  }
  1013  
  1014  // The response from `BatchCreateReadSessionStreams` returns the stream
  1015  // identifiers for the newly created streams.
  1016  type BatchCreateReadSessionStreamsResponse struct {
  1017  	state         protoimpl.MessageState
  1018  	sizeCache     protoimpl.SizeCache
  1019  	unknownFields protoimpl.UnknownFields
  1020  
  1021  	// Newly added streams.
  1022  	Streams []*Stream `protobuf:"bytes,1,rep,name=streams,proto3" json:"streams,omitempty"`
  1023  }
  1024  
  1025  func (x *BatchCreateReadSessionStreamsResponse) Reset() {
  1026  	*x = BatchCreateReadSessionStreamsResponse{}
  1027  	if protoimpl.UnsafeEnabled {
  1028  		mi := &file_google_cloud_bigquery_storage_v1beta1_storage_proto_msgTypes[10]
  1029  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1030  		ms.StoreMessageInfo(mi)
  1031  	}
  1032  }
  1033  
  1034  func (x *BatchCreateReadSessionStreamsResponse) String() string {
  1035  	return protoimpl.X.MessageStringOf(x)
  1036  }
  1037  
  1038  func (*BatchCreateReadSessionStreamsResponse) ProtoMessage() {}
  1039  
  1040  func (x *BatchCreateReadSessionStreamsResponse) ProtoReflect() protoreflect.Message {
  1041  	mi := &file_google_cloud_bigquery_storage_v1beta1_storage_proto_msgTypes[10]
  1042  	if protoimpl.UnsafeEnabled && x != nil {
  1043  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1044  		if ms.LoadMessageInfo() == nil {
  1045  			ms.StoreMessageInfo(mi)
  1046  		}
  1047  		return ms
  1048  	}
  1049  	return mi.MessageOf(x)
  1050  }
  1051  
  1052  // Deprecated: Use BatchCreateReadSessionStreamsResponse.ProtoReflect.Descriptor instead.
  1053  func (*BatchCreateReadSessionStreamsResponse) Descriptor() ([]byte, []int) {
  1054  	return file_google_cloud_bigquery_storage_v1beta1_storage_proto_rawDescGZIP(), []int{10}
  1055  }
  1056  
  1057  func (x *BatchCreateReadSessionStreamsResponse) GetStreams() []*Stream {
  1058  	if x != nil {
  1059  		return x.Streams
  1060  	}
  1061  	return nil
  1062  }
  1063  
  1064  // Request information for invoking `FinalizeStream`.
  1065  type FinalizeStreamRequest struct {
  1066  	state         protoimpl.MessageState
  1067  	sizeCache     protoimpl.SizeCache
  1068  	unknownFields protoimpl.UnknownFields
  1069  
  1070  	// Required. Stream to finalize.
  1071  	Stream *Stream `protobuf:"bytes,2,opt,name=stream,proto3" json:"stream,omitempty"`
  1072  }
  1073  
  1074  func (x *FinalizeStreamRequest) Reset() {
  1075  	*x = FinalizeStreamRequest{}
  1076  	if protoimpl.UnsafeEnabled {
  1077  		mi := &file_google_cloud_bigquery_storage_v1beta1_storage_proto_msgTypes[11]
  1078  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1079  		ms.StoreMessageInfo(mi)
  1080  	}
  1081  }
  1082  
  1083  func (x *FinalizeStreamRequest) String() string {
  1084  	return protoimpl.X.MessageStringOf(x)
  1085  }
  1086  
  1087  func (*FinalizeStreamRequest) ProtoMessage() {}
  1088  
  1089  func (x *FinalizeStreamRequest) ProtoReflect() protoreflect.Message {
  1090  	mi := &file_google_cloud_bigquery_storage_v1beta1_storage_proto_msgTypes[11]
  1091  	if protoimpl.UnsafeEnabled && x != nil {
  1092  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1093  		if ms.LoadMessageInfo() == nil {
  1094  			ms.StoreMessageInfo(mi)
  1095  		}
  1096  		return ms
  1097  	}
  1098  	return mi.MessageOf(x)
  1099  }
  1100  
  1101  // Deprecated: Use FinalizeStreamRequest.ProtoReflect.Descriptor instead.
  1102  func (*FinalizeStreamRequest) Descriptor() ([]byte, []int) {
  1103  	return file_google_cloud_bigquery_storage_v1beta1_storage_proto_rawDescGZIP(), []int{11}
  1104  }
  1105  
  1106  func (x *FinalizeStreamRequest) GetStream() *Stream {
  1107  	if x != nil {
  1108  		return x.Stream
  1109  	}
  1110  	return nil
  1111  }
  1112  
  1113  // Request information for `SplitReadStream`.
  1114  type SplitReadStreamRequest struct {
  1115  	state         protoimpl.MessageState
  1116  	sizeCache     protoimpl.SizeCache
  1117  	unknownFields protoimpl.UnknownFields
  1118  
  1119  	// Required. Stream to split.
  1120  	OriginalStream *Stream `protobuf:"bytes,1,opt,name=original_stream,json=originalStream,proto3" json:"original_stream,omitempty"`
  1121  	// A value in the range (0.0, 1.0) that specifies the fractional point at
  1122  	// which the original stream should be split. The actual split point is
  1123  	// evaluated on pre-filtered rows, so if a filter is provided, then there is
  1124  	// no guarantee that the division of the rows between the new child streams
  1125  	// will be proportional to this fractional value. Additionally, because the
  1126  	// server-side unit for assigning data is collections of rows, this fraction
  1127  	// will always map to to a data storage boundary on the server side.
  1128  	Fraction float32 `protobuf:"fixed32,2,opt,name=fraction,proto3" json:"fraction,omitempty"`
  1129  }
  1130  
  1131  func (x *SplitReadStreamRequest) Reset() {
  1132  	*x = SplitReadStreamRequest{}
  1133  	if protoimpl.UnsafeEnabled {
  1134  		mi := &file_google_cloud_bigquery_storage_v1beta1_storage_proto_msgTypes[12]
  1135  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1136  		ms.StoreMessageInfo(mi)
  1137  	}
  1138  }
  1139  
  1140  func (x *SplitReadStreamRequest) String() string {
  1141  	return protoimpl.X.MessageStringOf(x)
  1142  }
  1143  
  1144  func (*SplitReadStreamRequest) ProtoMessage() {}
  1145  
  1146  func (x *SplitReadStreamRequest) ProtoReflect() protoreflect.Message {
  1147  	mi := &file_google_cloud_bigquery_storage_v1beta1_storage_proto_msgTypes[12]
  1148  	if protoimpl.UnsafeEnabled && x != nil {
  1149  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1150  		if ms.LoadMessageInfo() == nil {
  1151  			ms.StoreMessageInfo(mi)
  1152  		}
  1153  		return ms
  1154  	}
  1155  	return mi.MessageOf(x)
  1156  }
  1157  
  1158  // Deprecated: Use SplitReadStreamRequest.ProtoReflect.Descriptor instead.
  1159  func (*SplitReadStreamRequest) Descriptor() ([]byte, []int) {
  1160  	return file_google_cloud_bigquery_storage_v1beta1_storage_proto_rawDescGZIP(), []int{12}
  1161  }
  1162  
  1163  func (x *SplitReadStreamRequest) GetOriginalStream() *Stream {
  1164  	if x != nil {
  1165  		return x.OriginalStream
  1166  	}
  1167  	return nil
  1168  }
  1169  
  1170  func (x *SplitReadStreamRequest) GetFraction() float32 {
  1171  	if x != nil {
  1172  		return x.Fraction
  1173  	}
  1174  	return 0
  1175  }
  1176  
  1177  // Response from `SplitReadStream`.
  1178  type SplitReadStreamResponse struct {
  1179  	state         protoimpl.MessageState
  1180  	sizeCache     protoimpl.SizeCache
  1181  	unknownFields protoimpl.UnknownFields
  1182  
  1183  	// Primary stream, which contains the beginning portion of
  1184  	// |original_stream|. An empty value indicates that the original stream can no
  1185  	// longer be split.
  1186  	PrimaryStream *Stream `protobuf:"bytes,1,opt,name=primary_stream,json=primaryStream,proto3" json:"primary_stream,omitempty"`
  1187  	// Remainder stream, which contains the tail of |original_stream|. An empty
  1188  	// value indicates that the original stream can no longer be split.
  1189  	RemainderStream *Stream `protobuf:"bytes,2,opt,name=remainder_stream,json=remainderStream,proto3" json:"remainder_stream,omitempty"`
  1190  }
  1191  
  1192  func (x *SplitReadStreamResponse) Reset() {
  1193  	*x = SplitReadStreamResponse{}
  1194  	if protoimpl.UnsafeEnabled {
  1195  		mi := &file_google_cloud_bigquery_storage_v1beta1_storage_proto_msgTypes[13]
  1196  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1197  		ms.StoreMessageInfo(mi)
  1198  	}
  1199  }
  1200  
  1201  func (x *SplitReadStreamResponse) String() string {
  1202  	return protoimpl.X.MessageStringOf(x)
  1203  }
  1204  
  1205  func (*SplitReadStreamResponse) ProtoMessage() {}
  1206  
  1207  func (x *SplitReadStreamResponse) ProtoReflect() protoreflect.Message {
  1208  	mi := &file_google_cloud_bigquery_storage_v1beta1_storage_proto_msgTypes[13]
  1209  	if protoimpl.UnsafeEnabled && x != nil {
  1210  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
  1211  		if ms.LoadMessageInfo() == nil {
  1212  			ms.StoreMessageInfo(mi)
  1213  		}
  1214  		return ms
  1215  	}
  1216  	return mi.MessageOf(x)
  1217  }
  1218  
  1219  // Deprecated: Use SplitReadStreamResponse.ProtoReflect.Descriptor instead.
  1220  func (*SplitReadStreamResponse) Descriptor() ([]byte, []int) {
  1221  	return file_google_cloud_bigquery_storage_v1beta1_storage_proto_rawDescGZIP(), []int{13}
  1222  }
  1223  
  1224  func (x *SplitReadStreamResponse) GetPrimaryStream() *Stream {
  1225  	if x != nil {
  1226  		return x.PrimaryStream
  1227  	}
  1228  	return nil
  1229  }
  1230  
  1231  func (x *SplitReadStreamResponse) GetRemainderStream() *Stream {
  1232  	if x != nil {
  1233  		return x.RemainderStream
  1234  	}
  1235  	return nil
  1236  }
  1237  
  1238  var File_google_cloud_bigquery_storage_v1beta1_storage_proto protoreflect.FileDescriptor
  1239  
  1240  var file_google_cloud_bigquery_storage_v1beta1_storage_proto_rawDesc = []byte{
  1241  	0x0a, 0x33, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x62,
  1242  	0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2f,
  1243  	0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e,
  1244  	0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x25, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c,
  1245  	0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f,
  1246  	0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x1a, 0x1c, 0x67, 0x6f,
  1247  	0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74,
  1248  	0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x17, 0x67, 0x6f, 0x6f, 0x67,
  1249  	0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x63, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x2e, 0x70, 0x72,
  1250  	0x6f, 0x74, 0x6f, 0x1a, 0x1f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f,
  1251  	0x66, 0x69, 0x65, 0x6c, 0x64, 0x5f, 0x62, 0x65, 0x68, 0x61, 0x76, 0x69, 0x6f, 0x72, 0x2e, 0x70,
  1252  	0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x19, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69,
  1253  	0x2f, 0x72, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a,
  1254  	0x31, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x62, 0x69,
  1255  	0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2f, 0x76,
  1256  	0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2f, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x2e, 0x70, 0x72, 0x6f,
  1257  	0x74, 0x6f, 0x1a, 0x30, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64,
  1258  	0x2f, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67,
  1259  	0x65, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2f, 0x61, 0x76, 0x72, 0x6f, 0x2e, 0x70,
  1260  	0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x38, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f,
  1261  	0x75, 0x64, 0x2f, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2f, 0x73, 0x74, 0x6f, 0x72,
  1262  	0x61, 0x67, 0x65, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2f, 0x72, 0x65, 0x61, 0x64,
  1263  	0x5f, 0x6f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x3b,
  1264  	0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x62, 0x69, 0x67,
  1265  	0x71, 0x75, 0x65, 0x72, 0x79, 0x2f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2f, 0x76, 0x31,
  1266  	0x62, 0x65, 0x74, 0x61, 0x31, 0x2f, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x5f, 0x72, 0x65, 0x66, 0x65,
  1267  	0x72, 0x65, 0x6e, 0x63, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1b, 0x67, 0x6f, 0x6f,
  1268  	0x67, 0x6c, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x65, 0x6d, 0x70,
  1269  	0x74, 0x79, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
  1270  	0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74,
  1271  	0x61, 0x6d, 0x70, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0x82, 0x01, 0x0a, 0x06, 0x53, 0x74,
  1272  	0x72, 0x65, 0x61, 0x6d, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01,
  1273  	0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x3a, 0x64, 0xea, 0x41, 0x61, 0x0a, 0x25, 0x62,
  1274  	0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x67,
  1275  	0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x53, 0x74,
  1276  	0x72, 0x65, 0x61, 0x6d, 0x12, 0x38, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x7b,
  1277  	0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x7d, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f,
  1278  	0x6e, 0x73, 0x2f, 0x7b, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x7d, 0x2f, 0x73, 0x74,
  1279  	0x72, 0x65, 0x61, 0x6d, 0x73, 0x2f, 0x7b, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x7d, 0x22, 0x6f,
  1280  	0x0a, 0x0e, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x50, 0x6f, 0x73, 0x69, 0x74, 0x69, 0x6f, 0x6e,
  1281  	0x12, 0x45, 0x0a, 0x06, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b,
  1282  	0x32, 0x2d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e,
  1283  	0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65,
  1284  	0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x52,
  1285  	0x06, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x12, 0x16, 0x0a, 0x06, 0x6f, 0x66, 0x66, 0x73, 0x65,
  1286  	0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x03, 0x52, 0x06, 0x6f, 0x66, 0x66, 0x73, 0x65, 0x74, 0x22,
  1287  	0xf3, 0x05, 0x0a, 0x0b, 0x52, 0x65, 0x61, 0x64, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x12,
  1288  	0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e,
  1289  	0x61, 0x6d, 0x65, 0x12, 0x3b, 0x0a, 0x0b, 0x65, 0x78, 0x70, 0x69, 0x72, 0x65, 0x5f, 0x74, 0x69,
  1290  	0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
  1291  	0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x73,
  1292  	0x74, 0x61, 0x6d, 0x70, 0x52, 0x0a, 0x65, 0x78, 0x70, 0x69, 0x72, 0x65, 0x54, 0x69, 0x6d, 0x65,
  1293  	0x12, 0x54, 0x0a, 0x0b, 0x61, 0x76, 0x72, 0x6f, 0x5f, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x18,
  1294  	0x05, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x31, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63,
  1295  	0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74,
  1296  	0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x41, 0x76,
  1297  	0x72, 0x6f, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x48, 0x00, 0x52, 0x0a, 0x61, 0x76, 0x72, 0x6f,
  1298  	0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x12, 0x57, 0x0a, 0x0c, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x5f,
  1299  	0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x18, 0x06, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x32, 0x2e, 0x67,
  1300  	0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71,
  1301  	0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62,
  1302  	0x65, 0x74, 0x61, 0x31, 0x2e, 0x41, 0x72, 0x72, 0x6f, 0x77, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61,
  1303  	0x48, 0x00, 0x52, 0x0b, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x12,
  1304  	0x47, 0x0a, 0x07, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x18, 0x04, 0x20, 0x03, 0x28, 0x0b,
  1305  	0x32, 0x2d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e,
  1306  	0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65,
  1307  	0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x52,
  1308  	0x07, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x12, 0x5e, 0x0a, 0x0f, 0x74, 0x61, 0x62, 0x6c,
  1309  	0x65, 0x5f, 0x72, 0x65, 0x66, 0x65, 0x72, 0x65, 0x6e, 0x63, 0x65, 0x18, 0x07, 0x20, 0x01, 0x28,
  1310  	0x0b, 0x32, 0x35, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64,
  1311  	0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67,
  1312  	0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x52,
  1313  	0x65, 0x66, 0x65, 0x72, 0x65, 0x6e, 0x63, 0x65, 0x52, 0x0e, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x52,
  1314  	0x65, 0x66, 0x65, 0x72, 0x65, 0x6e, 0x63, 0x65, 0x12, 0x5e, 0x0a, 0x0f, 0x74, 0x61, 0x62, 0x6c,
  1315  	0x65, 0x5f, 0x6d, 0x6f, 0x64, 0x69, 0x66, 0x69, 0x65, 0x72, 0x73, 0x18, 0x08, 0x20, 0x01, 0x28,
  1316  	0x0b, 0x32, 0x35, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64,
  1317  	0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67,
  1318  	0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x4d,
  1319  	0x6f, 0x64, 0x69, 0x66, 0x69, 0x65, 0x72, 0x73, 0x52, 0x0e, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x4d,
  1320  	0x6f, 0x64, 0x69, 0x66, 0x69, 0x65, 0x72, 0x73, 0x12, 0x64, 0x0a, 0x11, 0x73, 0x68, 0x61, 0x72,
  1321  	0x64, 0x69, 0x6e, 0x67, 0x5f, 0x73, 0x74, 0x72, 0x61, 0x74, 0x65, 0x67, 0x79, 0x18, 0x09, 0x20,
  1322  	0x01, 0x28, 0x0e, 0x32, 0x37, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f,
  1323  	0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72,
  1324  	0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x53, 0x68, 0x61, 0x72,
  1325  	0x64, 0x69, 0x6e, 0x67, 0x53, 0x74, 0x72, 0x61, 0x74, 0x65, 0x67, 0x79, 0x52, 0x10, 0x73, 0x68,
  1326  	0x61, 0x72, 0x64, 0x69, 0x6e, 0x67, 0x53, 0x74, 0x72, 0x61, 0x74, 0x65, 0x67, 0x79, 0x3a, 0x6b,
  1327  	0xea, 0x41, 0x68, 0x0a, 0x2a, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x73, 0x74, 0x6f,
  1328  	0x72, 0x61, 0x67, 0x65, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e,
  1329  	0x63, 0x6f, 0x6d, 0x2f, 0x52, 0x65, 0x61, 0x64, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x12,
  1330  	0x3a, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x7b, 0x70, 0x72, 0x6f, 0x6a, 0x65,
  1331  	0x63, 0x74, 0x7d, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x7b, 0x6c,
  1332  	0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x7d, 0x2f, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e,
  1333  	0x73, 0x2f, 0x7b, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x7d, 0x42, 0x08, 0x0a, 0x06, 0x73,
  1334  	0x63, 0x68, 0x65, 0x6d, 0x61, 0x22, 0xe6, 0x04, 0x0a, 0x18, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65,
  1335  	0x52, 0x65, 0x61, 0x64, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x71, 0x75, 0x65,
  1336  	0x73, 0x74, 0x12, 0x63, 0x0a, 0x0f, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x5f, 0x72, 0x65, 0x66, 0x65,
  1337  	0x72, 0x65, 0x6e, 0x63, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x35, 0x2e, 0x67, 0x6f,
  1338  	0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75,
  1339  	0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65,
  1340  	0x74, 0x61, 0x31, 0x2e, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x52, 0x65, 0x66, 0x65, 0x72, 0x65, 0x6e,
  1341  	0x63, 0x65, 0x42, 0x03, 0xe0, 0x41, 0x02, 0x52, 0x0e, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x52, 0x65,
  1342  	0x66, 0x65, 0x72, 0x65, 0x6e, 0x63, 0x65, 0x12, 0x4b, 0x0a, 0x06, 0x70, 0x61, 0x72, 0x65, 0x6e,
  1343  	0x74, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x42, 0x33, 0xe0, 0x41, 0x02, 0xfa, 0x41, 0x2d, 0x0a,
  1344  	0x2b, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x72, 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x6d, 0x61,
  1345  	0x6e, 0x61, 0x67, 0x65, 0x72, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73,
  1346  	0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x50, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x52, 0x06, 0x70, 0x61,
  1347  	0x72, 0x65, 0x6e, 0x74, 0x12, 0x5e, 0x0a, 0x0f, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x5f, 0x6d, 0x6f,
  1348  	0x64, 0x69, 0x66, 0x69, 0x65, 0x72, 0x73, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x35, 0x2e,
  1349  	0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67,
  1350  	0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31,
  1351  	0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x4d, 0x6f, 0x64, 0x69, 0x66,
  1352  	0x69, 0x65, 0x72, 0x73, 0x52, 0x0e, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x4d, 0x6f, 0x64, 0x69, 0x66,
  1353  	0x69, 0x65, 0x72, 0x73, 0x12, 0x2b, 0x0a, 0x11, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x65,
  1354  	0x64, 0x5f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x18, 0x03, 0x20, 0x01, 0x28, 0x05, 0x52,
  1355  	0x10, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x65, 0x64, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d,
  1356  	0x73, 0x12, 0x5a, 0x0a, 0x0c, 0x72, 0x65, 0x61, 0x64, 0x5f, 0x6f, 0x70, 0x74, 0x69, 0x6f, 0x6e,
  1357  	0x73, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x37, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
  1358  	0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e,
  1359  	0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e,
  1360  	0x54, 0x61, 0x62, 0x6c, 0x65, 0x52, 0x65, 0x61, 0x64, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73,
  1361  	0x52, 0x0b, 0x72, 0x65, 0x61, 0x64, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x49, 0x0a,
  1362  	0x06, 0x66, 0x6f, 0x72, 0x6d, 0x61, 0x74, 0x18, 0x05, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x31, 0x2e,
  1363  	0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67,
  1364  	0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31,
  1365  	0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x44, 0x61, 0x74, 0x61, 0x46, 0x6f, 0x72, 0x6d, 0x61, 0x74,
  1366  	0x52, 0x06, 0x66, 0x6f, 0x72, 0x6d, 0x61, 0x74, 0x12, 0x64, 0x0a, 0x11, 0x73, 0x68, 0x61, 0x72,
  1367  	0x64, 0x69, 0x6e, 0x67, 0x5f, 0x73, 0x74, 0x72, 0x61, 0x74, 0x65, 0x67, 0x79, 0x18, 0x07, 0x20,
  1368  	0x01, 0x28, 0x0e, 0x32, 0x37, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f,
  1369  	0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72,
  1370  	0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x53, 0x68, 0x61, 0x72,
  1371  	0x64, 0x69, 0x6e, 0x67, 0x53, 0x74, 0x72, 0x61, 0x74, 0x65, 0x67, 0x79, 0x52, 0x10, 0x73, 0x68,
  1372  	0x61, 0x72, 0x64, 0x69, 0x6e, 0x67, 0x53, 0x74, 0x72, 0x61, 0x74, 0x65, 0x67, 0x79, 0x22, 0x72,
  1373  	0x0a, 0x0f, 0x52, 0x65, 0x61, 0x64, 0x52, 0x6f, 0x77, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73,
  1374  	0x74, 0x12, 0x5f, 0x0a, 0x0d, 0x72, 0x65, 0x61, 0x64, 0x5f, 0x70, 0x6f, 0x73, 0x69, 0x74, 0x69,
  1375  	0x6f, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x35, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
  1376  	0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79,
  1377  	0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31,
  1378  	0x2e, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x50, 0x6f, 0x73, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x42,
  1379  	0x03, 0xe0, 0x41, 0x02, 0x52, 0x0c, 0x72, 0x65, 0x61, 0x64, 0x50, 0x6f, 0x73, 0x69, 0x74, 0x69,
  1380  	0x6f, 0x6e, 0x22, 0xdd, 0x01, 0x0a, 0x0c, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x53, 0x74, 0x61,
  1381  	0x74, 0x75, 0x73, 0x12, 0x2e, 0x0a, 0x13, 0x65, 0x73, 0x74, 0x69, 0x6d, 0x61, 0x74, 0x65, 0x64,
  1382  	0x5f, 0x72, 0x6f, 0x77, 0x5f, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03,
  1383  	0x52, 0x11, 0x65, 0x73, 0x74, 0x69, 0x6d, 0x61, 0x74, 0x65, 0x64, 0x52, 0x6f, 0x77, 0x43, 0x6f,
  1384  	0x75, 0x6e, 0x74, 0x12, 0x2b, 0x0a, 0x11, 0x66, 0x72, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x5f,
  1385  	0x63, 0x6f, 0x6e, 0x73, 0x75, 0x6d, 0x65, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x02, 0x52, 0x10,
  1386  	0x66, 0x72, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x43, 0x6f, 0x6e, 0x73, 0x75, 0x6d, 0x65, 0x64,
  1387  	0x12, 0x4b, 0x0a, 0x08, 0x70, 0x72, 0x6f, 0x67, 0x72, 0x65, 0x73, 0x73, 0x18, 0x04, 0x20, 0x01,
  1388  	0x28, 0x0b, 0x32, 0x2f, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75,
  1389  	0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61,
  1390  	0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x50, 0x72, 0x6f, 0x67, 0x72,
  1391  	0x65, 0x73, 0x73, 0x52, 0x08, 0x70, 0x72, 0x6f, 0x67, 0x72, 0x65, 0x73, 0x73, 0x12, 0x23, 0x0a,
  1392  	0x0d, 0x69, 0x73, 0x5f, 0x73, 0x70, 0x6c, 0x69, 0x74, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x18, 0x03,
  1393  	0x20, 0x01, 0x28, 0x08, 0x52, 0x0c, 0x69, 0x73, 0x53, 0x70, 0x6c, 0x69, 0x74, 0x74, 0x61, 0x62,
  1394  	0x6c, 0x65, 0x22, 0x5e, 0x0a, 0x08, 0x50, 0x72, 0x6f, 0x67, 0x72, 0x65, 0x73, 0x73, 0x12, 0x2a,
  1395  	0x0a, 0x11, 0x61, 0x74, 0x5f, 0x72, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x5f, 0x73, 0x74,
  1396  	0x61, 0x72, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x02, 0x52, 0x0f, 0x61, 0x74, 0x52, 0x65, 0x73,
  1397  	0x70, 0x6f, 0x6e, 0x73, 0x65, 0x53, 0x74, 0x61, 0x72, 0x74, 0x12, 0x26, 0x0a, 0x0f, 0x61, 0x74,
  1398  	0x5f, 0x72, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x5f, 0x65, 0x6e, 0x64, 0x18, 0x02, 0x20,
  1399  	0x01, 0x28, 0x02, 0x52, 0x0d, 0x61, 0x74, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x45,
  1400  	0x6e, 0x64, 0x22, 0x3b, 0x0a, 0x0e, 0x54, 0x68, 0x72, 0x6f, 0x74, 0x74, 0x6c, 0x65, 0x53, 0x74,
  1401  	0x61, 0x74, 0x75, 0x73, 0x12, 0x29, 0x0a, 0x10, 0x74, 0x68, 0x72, 0x6f, 0x74, 0x74, 0x6c, 0x65,
  1402  	0x5f, 0x70, 0x65, 0x72, 0x63, 0x65, 0x6e, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x05, 0x52, 0x0f,
  1403  	0x74, 0x68, 0x72, 0x6f, 0x74, 0x74, 0x6c, 0x65, 0x50, 0x65, 0x72, 0x63, 0x65, 0x6e, 0x74, 0x22,
  1404  	0xe0, 0x04, 0x0a, 0x10, 0x52, 0x65, 0x61, 0x64, 0x52, 0x6f, 0x77, 0x73, 0x52, 0x65, 0x73, 0x70,
  1405  	0x6f, 0x6e, 0x73, 0x65, 0x12, 0x4e, 0x0a, 0x09, 0x61, 0x76, 0x72, 0x6f, 0x5f, 0x72, 0x6f, 0x77,
  1406  	0x73, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2f, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
  1407  	0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e,
  1408  	0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e,
  1409  	0x41, 0x76, 0x72, 0x6f, 0x52, 0x6f, 0x77, 0x73, 0x48, 0x00, 0x52, 0x08, 0x61, 0x76, 0x72, 0x6f,
  1410  	0x52, 0x6f, 0x77, 0x73, 0x12, 0x67, 0x0a, 0x12, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x5f, 0x72, 0x65,
  1411  	0x63, 0x6f, 0x72, 0x64, 0x5f, 0x62, 0x61, 0x74, 0x63, 0x68, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b,
  1412  	0x32, 0x37, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e,
  1413  	0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65,
  1414  	0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x41, 0x72, 0x72, 0x6f, 0x77, 0x52, 0x65,
  1415  	0x63, 0x6f, 0x72, 0x64, 0x42, 0x61, 0x74, 0x63, 0x68, 0x48, 0x00, 0x52, 0x10, 0x61, 0x72, 0x72,
  1416  	0x6f, 0x77, 0x52, 0x65, 0x63, 0x6f, 0x72, 0x64, 0x42, 0x61, 0x74, 0x63, 0x68, 0x12, 0x1b, 0x0a,
  1417  	0x09, 0x72, 0x6f, 0x77, 0x5f, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x18, 0x06, 0x20, 0x01, 0x28, 0x03,
  1418  	0x52, 0x08, 0x72, 0x6f, 0x77, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x12, 0x4b, 0x0a, 0x06, 0x73, 0x74,
  1419  	0x61, 0x74, 0x75, 0x73, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x33, 0x2e, 0x67, 0x6f, 0x6f,
  1420  	0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65,
  1421  	0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74,
  1422  	0x61, 0x31, 0x2e, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x52,
  1423  	0x06, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x12, 0x5e, 0x0a, 0x0f, 0x74, 0x68, 0x72, 0x6f, 0x74,
  1424  	0x74, 0x6c, 0x65, 0x5f, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x18, 0x05, 0x20, 0x01, 0x28, 0x0b,
  1425  	0x32, 0x35, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e,
  1426  	0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65,
  1427  	0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x54, 0x68, 0x72, 0x6f, 0x74, 0x74, 0x6c,
  1428  	0x65, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x52, 0x0e, 0x74, 0x68, 0x72, 0x6f, 0x74, 0x74, 0x6c,
  1429  	0x65, 0x53, 0x74, 0x61, 0x74, 0x75, 0x73, 0x12, 0x59, 0x0a, 0x0b, 0x61, 0x76, 0x72, 0x6f, 0x5f,
  1430  	0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x18, 0x07, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x31, 0x2e, 0x67,
  1431  	0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71,
  1432  	0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62,
  1433  	0x65, 0x74, 0x61, 0x31, 0x2e, 0x41, 0x76, 0x72, 0x6f, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x42,
  1434  	0x03, 0xe0, 0x41, 0x03, 0x48, 0x01, 0x52, 0x0a, 0x61, 0x76, 0x72, 0x6f, 0x53, 0x63, 0x68, 0x65,
  1435  	0x6d, 0x61, 0x12, 0x5c, 0x0a, 0x0c, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x5f, 0x73, 0x63, 0x68, 0x65,
  1436  	0x6d, 0x61, 0x18, 0x08, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x32, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
  1437  	0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79,
  1438  	0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31,
  1439  	0x2e, 0x41, 0x72, 0x72, 0x6f, 0x77, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x42, 0x03, 0xe0, 0x41,
  1440  	0x03, 0x48, 0x01, 0x52, 0x0b, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61,
  1441  	0x42, 0x06, 0x0a, 0x04, 0x72, 0x6f, 0x77, 0x73, 0x42, 0x08, 0x0a, 0x06, 0x73, 0x63, 0x68, 0x65,
  1442  	0x6d, 0x61, 0x22, 0xab, 0x01, 0x0a, 0x24, 0x42, 0x61, 0x74, 0x63, 0x68, 0x43, 0x72, 0x65, 0x61,
  1443  	0x74, 0x65, 0x52, 0x65, 0x61, 0x64, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x53, 0x74, 0x72,
  1444  	0x65, 0x61, 0x6d, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x51, 0x0a, 0x07, 0x73,
  1445  	0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x32, 0x2e, 0x67,
  1446  	0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71,
  1447  	0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62,
  1448  	0x65, 0x74, 0x61, 0x31, 0x2e, 0x52, 0x65, 0x61, 0x64, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e,
  1449  	0x42, 0x03, 0xe0, 0x41, 0x02, 0x52, 0x07, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x30,
  1450  	0x0a, 0x11, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x65, 0x64, 0x5f, 0x73, 0x74, 0x72, 0x65,
  1451  	0x61, 0x6d, 0x73, 0x18, 0x02, 0x20, 0x01, 0x28, 0x05, 0x42, 0x03, 0xe0, 0x41, 0x02, 0x52, 0x10,
  1452  	0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x65, 0x64, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73,
  1453  	0x22, 0x70, 0x0a, 0x25, 0x42, 0x61, 0x74, 0x63, 0x68, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x52,
  1454  	0x65, 0x61, 0x64, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d,
  1455  	0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x47, 0x0a, 0x07, 0x73, 0x74, 0x72,
  1456  	0x65, 0x61, 0x6d, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x2d, 0x2e, 0x67, 0x6f, 0x6f,
  1457  	0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65,
  1458  	0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74,
  1459  	0x61, 0x31, 0x2e, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x52, 0x07, 0x73, 0x74, 0x72, 0x65, 0x61,
  1460  	0x6d, 0x73, 0x22, 0x63, 0x0a, 0x15, 0x46, 0x69, 0x6e, 0x61, 0x6c, 0x69, 0x7a, 0x65, 0x53, 0x74,
  1461  	0x72, 0x65, 0x61, 0x6d, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x4a, 0x0a, 0x06, 0x73,
  1462  	0x74, 0x72, 0x65, 0x61, 0x6d, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2d, 0x2e, 0x67, 0x6f,
  1463  	0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75,
  1464  	0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65,
  1465  	0x74, 0x61, 0x31, 0x2e, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x42, 0x03, 0xe0, 0x41, 0x02, 0x52,
  1466  	0x06, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x22, 0x91, 0x01, 0x0a, 0x16, 0x53, 0x70, 0x6c, 0x69,
  1467  	0x74, 0x52, 0x65, 0x61, 0x64, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x52, 0x65, 0x71, 0x75, 0x65,
  1468  	0x73, 0x74, 0x12, 0x5b, 0x0a, 0x0f, 0x6f, 0x72, 0x69, 0x67, 0x69, 0x6e, 0x61, 0x6c, 0x5f, 0x73,
  1469  	0x74, 0x72, 0x65, 0x61, 0x6d, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2d, 0x2e, 0x67, 0x6f,
  1470  	0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75,
  1471  	0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65,
  1472  	0x74, 0x61, 0x31, 0x2e, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x42, 0x03, 0xe0, 0x41, 0x02, 0x52,
  1473  	0x0e, 0x6f, 0x72, 0x69, 0x67, 0x69, 0x6e, 0x61, 0x6c, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x12,
  1474  	0x1a, 0x0a, 0x08, 0x66, 0x72, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28,
  1475  	0x02, 0x52, 0x08, 0x66, 0x72, 0x61, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x22, 0xc9, 0x01, 0x0a, 0x17,
  1476  	0x53, 0x70, 0x6c, 0x69, 0x74, 0x52, 0x65, 0x61, 0x64, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x52,
  1477  	0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x54, 0x0a, 0x0e, 0x70, 0x72, 0x69, 0x6d, 0x61,
  1478  	0x72, 0x79, 0x5f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32,
  1479  	0x2d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62,
  1480  	0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e,
  1481  	0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x52, 0x0d,
  1482  	0x70, 0x72, 0x69, 0x6d, 0x61, 0x72, 0x79, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x12, 0x58, 0x0a,
  1483  	0x10, 0x72, 0x65, 0x6d, 0x61, 0x69, 0x6e, 0x64, 0x65, 0x72, 0x5f, 0x73, 0x74, 0x72, 0x65, 0x61,
  1484  	0x6d, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
  1485  	0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e,
  1486  	0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e,
  1487  	0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x52, 0x0f, 0x72, 0x65, 0x6d, 0x61, 0x69, 0x6e, 0x64, 0x65,
  1488  	0x72, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x2a, 0x3e, 0x0a, 0x0a, 0x44, 0x61, 0x74, 0x61, 0x46,
  1489  	0x6f, 0x72, 0x6d, 0x61, 0x74, 0x12, 0x1b, 0x0a, 0x17, 0x44, 0x41, 0x54, 0x41, 0x5f, 0x46, 0x4f,
  1490  	0x52, 0x4d, 0x41, 0x54, 0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 0x49, 0x45, 0x44,
  1491  	0x10, 0x00, 0x12, 0x08, 0x0a, 0x04, 0x41, 0x56, 0x52, 0x4f, 0x10, 0x01, 0x12, 0x09, 0x0a, 0x05,
  1492  	0x41, 0x52, 0x52, 0x4f, 0x57, 0x10, 0x03, 0x2a, 0x4f, 0x0a, 0x10, 0x53, 0x68, 0x61, 0x72, 0x64,
  1493  	0x69, 0x6e, 0x67, 0x53, 0x74, 0x72, 0x61, 0x74, 0x65, 0x67, 0x79, 0x12, 0x21, 0x0a, 0x1d, 0x53,
  1494  	0x48, 0x41, 0x52, 0x44, 0x49, 0x4e, 0x47, 0x5f, 0x53, 0x54, 0x52, 0x41, 0x54, 0x45, 0x47, 0x59,
  1495  	0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 0x49, 0x45, 0x44, 0x10, 0x00, 0x12, 0x0a,
  1496  	0x0a, 0x06, 0x4c, 0x49, 0x51, 0x55, 0x49, 0x44, 0x10, 0x01, 0x12, 0x0c, 0x0a, 0x08, 0x42, 0x41,
  1497  	0x4c, 0x41, 0x4e, 0x43, 0x45, 0x44, 0x10, 0x02, 0x32, 0xb7, 0x0a, 0x0a, 0x0f, 0x42, 0x69, 0x67,
  1498  	0x51, 0x75, 0x65, 0x72, 0x79, 0x53, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x12, 0xb3, 0x02, 0x0a,
  1499  	0x11, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x52, 0x65, 0x61, 0x64, 0x53, 0x65, 0x73, 0x73, 0x69,
  1500  	0x6f, 0x6e, 0x12, 0x3f, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75,
  1501  	0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61,
  1502  	0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x43, 0x72, 0x65, 0x61, 0x74,
  1503  	0x65, 0x52, 0x65, 0x61, 0x64, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x52, 0x65, 0x71, 0x75,
  1504  	0x65, 0x73, 0x74, 0x1a, 0x32, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f,
  1505  	0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72,
  1506  	0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x52, 0x65, 0x61, 0x64,
  1507  	0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x22, 0xa8, 0x01, 0xda, 0x41, 0x28, 0x74, 0x61, 0x62,
  1508  	0x6c, 0x65, 0x5f, 0x72, 0x65, 0x66, 0x65, 0x72, 0x65, 0x6e, 0x63, 0x65, 0x2c, 0x70, 0x61, 0x72,
  1509  	0x65, 0x6e, 0x74, 0x2c, 0x72, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x65, 0x64, 0x5f, 0x73, 0x74,
  1510  	0x72, 0x65, 0x61, 0x6d, 0x73, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x77, 0x3a, 0x01, 0x2a, 0x5a, 0x40,
  1511  	0x3a, 0x01, 0x2a, 0x22, 0x3b, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2f, 0x7b, 0x74,
  1512  	0x61, 0x62, 0x6c, 0x65, 0x5f, 0x72, 0x65, 0x66, 0x65, 0x72, 0x65, 0x6e, 0x63, 0x65, 0x2e, 0x64,
  1513  	0x61, 0x74, 0x61, 0x73, 0x65, 0x74, 0x5f, 0x69, 0x64, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63,
  1514  	0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x64, 0x61, 0x74, 0x61, 0x73, 0x65, 0x74, 0x73, 0x2f, 0x2a, 0x7d,
  1515  	0x22, 0x30, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2f, 0x7b, 0x74, 0x61, 0x62, 0x6c,
  1516  	0x65, 0x5f, 0x72, 0x65, 0x66, 0x65, 0x72, 0x65, 0x6e, 0x63, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x6a,
  1517  	0x65, 0x63, 0x74, 0x5f, 0x69, 0x64, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f,
  1518  	0x2a, 0x7d, 0x12, 0xd0, 0x01, 0x0a, 0x08, 0x52, 0x65, 0x61, 0x64, 0x52, 0x6f, 0x77, 0x73, 0x12,
  1519  	0x36, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62,
  1520  	0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e,
  1521  	0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x52, 0x65, 0x61, 0x64, 0x52, 0x6f, 0x77, 0x73,
  1522  	0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x37, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
  1523  	0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e,
  1524  	0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e,
  1525  	0x52, 0x65, 0x61, 0x64, 0x52, 0x6f, 0x77, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65,
  1526  	0x22, 0x51, 0xda, 0x41, 0x0d, 0x72, 0x65, 0x61, 0x64, 0x5f, 0x70, 0x6f, 0x73, 0x69, 0x74, 0x69,
  1527  	0x6f, 0x6e, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x3b, 0x12, 0x39, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74,
  1528  	0x61, 0x31, 0x2f, 0x7b, 0x72, 0x65, 0x61, 0x64, 0x5f, 0x70, 0x6f, 0x73, 0x69, 0x74, 0x69, 0x6f,
  1529  	0x6e, 0x2e, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x2e, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72,
  1530  	0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73,
  1531  	0x2f, 0x2a, 0x7d, 0x30, 0x01, 0x12, 0x90, 0x02, 0x0a, 0x1d, 0x42, 0x61, 0x74, 0x63, 0x68, 0x43,
  1532  	0x72, 0x65, 0x61, 0x74, 0x65, 0x52, 0x65, 0x61, 0x64, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e,
  1533  	0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x12, 0x4b, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
  1534  	0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e,
  1535  	0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e,
  1536  	0x42, 0x61, 0x74, 0x63, 0x68, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x52, 0x65, 0x61, 0x64, 0x53,
  1537  	0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x52, 0x65, 0x71,
  1538  	0x75, 0x65, 0x73, 0x74, 0x1a, 0x4c, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c,
  1539  	0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f,
  1540  	0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x42, 0x61, 0x74,
  1541  	0x63, 0x68, 0x43, 0x72, 0x65, 0x61, 0x74, 0x65, 0x52, 0x65, 0x61, 0x64, 0x53, 0x65, 0x73, 0x73,
  1542  	0x69, 0x6f, 0x6e, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e,
  1543  	0x73, 0x65, 0x22, 0x54, 0xda, 0x41, 0x19, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x2c, 0x72,
  1544  	0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x65, 0x64, 0x5f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73,
  1545  	0x82, 0xd3, 0xe4, 0x93, 0x02, 0x32, 0x3a, 0x01, 0x2a, 0x22, 0x2d, 0x2f, 0x76, 0x31, 0x62, 0x65,
  1546  	0x74, 0x61, 0x31, 0x2f, 0x7b, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x2e, 0x6e, 0x61, 0x6d,
  1547  	0x65, 0x3d, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x73, 0x65, 0x73,
  1548  	0x73, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x2a, 0x7d, 0x12, 0xa7, 0x01, 0x0a, 0x0e, 0x46, 0x69, 0x6e,
  1549  	0x61, 0x6c, 0x69, 0x7a, 0x65, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x12, 0x3c, 0x2e, 0x67, 0x6f,
  1550  	0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75,
  1551  	0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65,
  1552  	0x74, 0x61, 0x31, 0x2e, 0x46, 0x69, 0x6e, 0x61, 0x6c, 0x69, 0x7a, 0x65, 0x53, 0x74, 0x72, 0x65,
  1553  	0x61, 0x6d, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x16, 0x2e, 0x67, 0x6f, 0x6f, 0x67,
  1554  	0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x45, 0x6d, 0x70, 0x74,
  1555  	0x79, 0x22, 0x3f, 0xda, 0x41, 0x06, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x82, 0xd3, 0xe4, 0x93,
  1556  	0x02, 0x30, 0x3a, 0x01, 0x2a, 0x22, 0x2b, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2f,
  1557  	0x7b, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x2e, 0x6e, 0x61, 0x6d, 0x65, 0x3d, 0x70, 0x72, 0x6f,
  1558  	0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x73, 0x2f,
  1559  	0x2a, 0x7d, 0x12, 0xe0, 0x01, 0x0a, 0x0f, 0x53, 0x70, 0x6c, 0x69, 0x74, 0x52, 0x65, 0x61, 0x64,
  1560  	0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x12, 0x3d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e,
  1561  	0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73,
  1562  	0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x53,
  1563  	0x70, 0x6c, 0x69, 0x74, 0x52, 0x65, 0x61, 0x64, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x52, 0x65,
  1564  	0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x3e, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63,
  1565  	0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74,
  1566  	0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2e, 0x53, 0x70,
  1567  	0x6c, 0x69, 0x74, 0x52, 0x65, 0x61, 0x64, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x52, 0x65, 0x73,
  1568  	0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x4e, 0xda, 0x41, 0x0f, 0x6f, 0x72, 0x69, 0x67, 0x69, 0x6e,
  1569  	0x61, 0x6c, 0x5f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x82, 0xd3, 0xe4, 0x93, 0x02, 0x36, 0x12,
  1570  	0x34, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2f, 0x7b, 0x6f, 0x72, 0x69, 0x67, 0x69,
  1571  	0x6e, 0x61, 0x6c, 0x5f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x2e, 0x6e, 0x61, 0x6d, 0x65, 0x3d,
  1572  	0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x2a, 0x2f, 0x73, 0x74, 0x72, 0x65, 0x61,
  1573  	0x6d, 0x73, 0x2f, 0x2a, 0x7d, 0x1a, 0x7b, 0xca, 0x41, 0x1e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65,
  1574  	0x72, 0x79, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
  1575  	0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0xd2, 0x41, 0x57, 0x68, 0x74, 0x74, 0x70, 0x73,
  1576  	0x3a, 0x2f, 0x2f, 0x77, 0x77, 0x77, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69,
  1577  	0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x61, 0x75, 0x74, 0x68, 0x2f, 0x62, 0x69, 0x67, 0x71, 0x75,
  1578  	0x65, 0x72, 0x79, 0x2c, 0x68, 0x74, 0x74, 0x70, 0x73, 0x3a, 0x2f, 0x2f, 0x77, 0x77, 0x77, 0x2e,
  1579  	0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x61,
  1580  	0x75, 0x74, 0x68, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2d, 0x70, 0x6c, 0x61, 0x74, 0x66, 0x6f,
  1581  	0x72, 0x6d, 0x42, 0x70, 0x0a, 0x29, 0x63, 0x6f, 0x6d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65,
  1582  	0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e,
  1583  	0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x5a,
  1584  	0x43, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6f,
  1585  	0x6d, 0x2f, 0x67, 0x6f, 0x2f, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2f, 0x73, 0x74,
  1586  	0x6f, 0x72, 0x61, 0x67, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31,
  1587  	0x2f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x70, 0x62, 0x3b, 0x73, 0x74, 0x6f, 0x72, 0x61,
  1588  	0x67, 0x65, 0x70, 0x62, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
  1589  }
  1590  
  1591  var (
  1592  	file_google_cloud_bigquery_storage_v1beta1_storage_proto_rawDescOnce sync.Once
  1593  	file_google_cloud_bigquery_storage_v1beta1_storage_proto_rawDescData = file_google_cloud_bigquery_storage_v1beta1_storage_proto_rawDesc
  1594  )
  1595  
  1596  func file_google_cloud_bigquery_storage_v1beta1_storage_proto_rawDescGZIP() []byte {
  1597  	file_google_cloud_bigquery_storage_v1beta1_storage_proto_rawDescOnce.Do(func() {
  1598  		file_google_cloud_bigquery_storage_v1beta1_storage_proto_rawDescData = protoimpl.X.CompressGZIP(file_google_cloud_bigquery_storage_v1beta1_storage_proto_rawDescData)
  1599  	})
  1600  	return file_google_cloud_bigquery_storage_v1beta1_storage_proto_rawDescData
  1601  }
  1602  
  1603  var file_google_cloud_bigquery_storage_v1beta1_storage_proto_enumTypes = make([]protoimpl.EnumInfo, 2)
  1604  var file_google_cloud_bigquery_storage_v1beta1_storage_proto_msgTypes = make([]protoimpl.MessageInfo, 14)
  1605  var file_google_cloud_bigquery_storage_v1beta1_storage_proto_goTypes = []interface{}{
  1606  	(DataFormat)(0),                               // 0: google.cloud.bigquery.storage.v1beta1.DataFormat
  1607  	(ShardingStrategy)(0),                         // 1: google.cloud.bigquery.storage.v1beta1.ShardingStrategy
  1608  	(*Stream)(nil),                                // 2: google.cloud.bigquery.storage.v1beta1.Stream
  1609  	(*StreamPosition)(nil),                        // 3: google.cloud.bigquery.storage.v1beta1.StreamPosition
  1610  	(*ReadSession)(nil),                           // 4: google.cloud.bigquery.storage.v1beta1.ReadSession
  1611  	(*CreateReadSessionRequest)(nil),              // 5: google.cloud.bigquery.storage.v1beta1.CreateReadSessionRequest
  1612  	(*ReadRowsRequest)(nil),                       // 6: google.cloud.bigquery.storage.v1beta1.ReadRowsRequest
  1613  	(*StreamStatus)(nil),                          // 7: google.cloud.bigquery.storage.v1beta1.StreamStatus
  1614  	(*Progress)(nil),                              // 8: google.cloud.bigquery.storage.v1beta1.Progress
  1615  	(*ThrottleStatus)(nil),                        // 9: google.cloud.bigquery.storage.v1beta1.ThrottleStatus
  1616  	(*ReadRowsResponse)(nil),                      // 10: google.cloud.bigquery.storage.v1beta1.ReadRowsResponse
  1617  	(*BatchCreateReadSessionStreamsRequest)(nil),  // 11: google.cloud.bigquery.storage.v1beta1.BatchCreateReadSessionStreamsRequest
  1618  	(*BatchCreateReadSessionStreamsResponse)(nil), // 12: google.cloud.bigquery.storage.v1beta1.BatchCreateReadSessionStreamsResponse
  1619  	(*FinalizeStreamRequest)(nil),                 // 13: google.cloud.bigquery.storage.v1beta1.FinalizeStreamRequest
  1620  	(*SplitReadStreamRequest)(nil),                // 14: google.cloud.bigquery.storage.v1beta1.SplitReadStreamRequest
  1621  	(*SplitReadStreamResponse)(nil),               // 15: google.cloud.bigquery.storage.v1beta1.SplitReadStreamResponse
  1622  	(*timestamppb.Timestamp)(nil),                 // 16: google.protobuf.Timestamp
  1623  	(*AvroSchema)(nil),                            // 17: google.cloud.bigquery.storage.v1beta1.AvroSchema
  1624  	(*ArrowSchema)(nil),                           // 18: google.cloud.bigquery.storage.v1beta1.ArrowSchema
  1625  	(*TableReference)(nil),                        // 19: google.cloud.bigquery.storage.v1beta1.TableReference
  1626  	(*TableModifiers)(nil),                        // 20: google.cloud.bigquery.storage.v1beta1.TableModifiers
  1627  	(*TableReadOptions)(nil),                      // 21: google.cloud.bigquery.storage.v1beta1.TableReadOptions
  1628  	(*AvroRows)(nil),                              // 22: google.cloud.bigquery.storage.v1beta1.AvroRows
  1629  	(*ArrowRecordBatch)(nil),                      // 23: google.cloud.bigquery.storage.v1beta1.ArrowRecordBatch
  1630  	(*emptypb.Empty)(nil),                         // 24: google.protobuf.Empty
  1631  }
  1632  var file_google_cloud_bigquery_storage_v1beta1_storage_proto_depIdxs = []int32{
  1633  	2,  // 0: google.cloud.bigquery.storage.v1beta1.StreamPosition.stream:type_name -> google.cloud.bigquery.storage.v1beta1.Stream
  1634  	16, // 1: google.cloud.bigquery.storage.v1beta1.ReadSession.expire_time:type_name -> google.protobuf.Timestamp
  1635  	17, // 2: google.cloud.bigquery.storage.v1beta1.ReadSession.avro_schema:type_name -> google.cloud.bigquery.storage.v1beta1.AvroSchema
  1636  	18, // 3: google.cloud.bigquery.storage.v1beta1.ReadSession.arrow_schema:type_name -> google.cloud.bigquery.storage.v1beta1.ArrowSchema
  1637  	2,  // 4: google.cloud.bigquery.storage.v1beta1.ReadSession.streams:type_name -> google.cloud.bigquery.storage.v1beta1.Stream
  1638  	19, // 5: google.cloud.bigquery.storage.v1beta1.ReadSession.table_reference:type_name -> google.cloud.bigquery.storage.v1beta1.TableReference
  1639  	20, // 6: google.cloud.bigquery.storage.v1beta1.ReadSession.table_modifiers:type_name -> google.cloud.bigquery.storage.v1beta1.TableModifiers
  1640  	1,  // 7: google.cloud.bigquery.storage.v1beta1.ReadSession.sharding_strategy:type_name -> google.cloud.bigquery.storage.v1beta1.ShardingStrategy
  1641  	19, // 8: google.cloud.bigquery.storage.v1beta1.CreateReadSessionRequest.table_reference:type_name -> google.cloud.bigquery.storage.v1beta1.TableReference
  1642  	20, // 9: google.cloud.bigquery.storage.v1beta1.CreateReadSessionRequest.table_modifiers:type_name -> google.cloud.bigquery.storage.v1beta1.TableModifiers
  1643  	21, // 10: google.cloud.bigquery.storage.v1beta1.CreateReadSessionRequest.read_options:type_name -> google.cloud.bigquery.storage.v1beta1.TableReadOptions
  1644  	0,  // 11: google.cloud.bigquery.storage.v1beta1.CreateReadSessionRequest.format:type_name -> google.cloud.bigquery.storage.v1beta1.DataFormat
  1645  	1,  // 12: google.cloud.bigquery.storage.v1beta1.CreateReadSessionRequest.sharding_strategy:type_name -> google.cloud.bigquery.storage.v1beta1.ShardingStrategy
  1646  	3,  // 13: google.cloud.bigquery.storage.v1beta1.ReadRowsRequest.read_position:type_name -> google.cloud.bigquery.storage.v1beta1.StreamPosition
  1647  	8,  // 14: google.cloud.bigquery.storage.v1beta1.StreamStatus.progress:type_name -> google.cloud.bigquery.storage.v1beta1.Progress
  1648  	22, // 15: google.cloud.bigquery.storage.v1beta1.ReadRowsResponse.avro_rows:type_name -> google.cloud.bigquery.storage.v1beta1.AvroRows
  1649  	23, // 16: google.cloud.bigquery.storage.v1beta1.ReadRowsResponse.arrow_record_batch:type_name -> google.cloud.bigquery.storage.v1beta1.ArrowRecordBatch
  1650  	7,  // 17: google.cloud.bigquery.storage.v1beta1.ReadRowsResponse.status:type_name -> google.cloud.bigquery.storage.v1beta1.StreamStatus
  1651  	9,  // 18: google.cloud.bigquery.storage.v1beta1.ReadRowsResponse.throttle_status:type_name -> google.cloud.bigquery.storage.v1beta1.ThrottleStatus
  1652  	17, // 19: google.cloud.bigquery.storage.v1beta1.ReadRowsResponse.avro_schema:type_name -> google.cloud.bigquery.storage.v1beta1.AvroSchema
  1653  	18, // 20: google.cloud.bigquery.storage.v1beta1.ReadRowsResponse.arrow_schema:type_name -> google.cloud.bigquery.storage.v1beta1.ArrowSchema
  1654  	4,  // 21: google.cloud.bigquery.storage.v1beta1.BatchCreateReadSessionStreamsRequest.session:type_name -> google.cloud.bigquery.storage.v1beta1.ReadSession
  1655  	2,  // 22: google.cloud.bigquery.storage.v1beta1.BatchCreateReadSessionStreamsResponse.streams:type_name -> google.cloud.bigquery.storage.v1beta1.Stream
  1656  	2,  // 23: google.cloud.bigquery.storage.v1beta1.FinalizeStreamRequest.stream:type_name -> google.cloud.bigquery.storage.v1beta1.Stream
  1657  	2,  // 24: google.cloud.bigquery.storage.v1beta1.SplitReadStreamRequest.original_stream:type_name -> google.cloud.bigquery.storage.v1beta1.Stream
  1658  	2,  // 25: google.cloud.bigquery.storage.v1beta1.SplitReadStreamResponse.primary_stream:type_name -> google.cloud.bigquery.storage.v1beta1.Stream
  1659  	2,  // 26: google.cloud.bigquery.storage.v1beta1.SplitReadStreamResponse.remainder_stream:type_name -> google.cloud.bigquery.storage.v1beta1.Stream
  1660  	5,  // 27: google.cloud.bigquery.storage.v1beta1.BigQueryStorage.CreateReadSession:input_type -> google.cloud.bigquery.storage.v1beta1.CreateReadSessionRequest
  1661  	6,  // 28: google.cloud.bigquery.storage.v1beta1.BigQueryStorage.ReadRows:input_type -> google.cloud.bigquery.storage.v1beta1.ReadRowsRequest
  1662  	11, // 29: google.cloud.bigquery.storage.v1beta1.BigQueryStorage.BatchCreateReadSessionStreams:input_type -> google.cloud.bigquery.storage.v1beta1.BatchCreateReadSessionStreamsRequest
  1663  	13, // 30: google.cloud.bigquery.storage.v1beta1.BigQueryStorage.FinalizeStream:input_type -> google.cloud.bigquery.storage.v1beta1.FinalizeStreamRequest
  1664  	14, // 31: google.cloud.bigquery.storage.v1beta1.BigQueryStorage.SplitReadStream:input_type -> google.cloud.bigquery.storage.v1beta1.SplitReadStreamRequest
  1665  	4,  // 32: google.cloud.bigquery.storage.v1beta1.BigQueryStorage.CreateReadSession:output_type -> google.cloud.bigquery.storage.v1beta1.ReadSession
  1666  	10, // 33: google.cloud.bigquery.storage.v1beta1.BigQueryStorage.ReadRows:output_type -> google.cloud.bigquery.storage.v1beta1.ReadRowsResponse
  1667  	12, // 34: google.cloud.bigquery.storage.v1beta1.BigQueryStorage.BatchCreateReadSessionStreams:output_type -> google.cloud.bigquery.storage.v1beta1.BatchCreateReadSessionStreamsResponse
  1668  	24, // 35: google.cloud.bigquery.storage.v1beta1.BigQueryStorage.FinalizeStream:output_type -> google.protobuf.Empty
  1669  	15, // 36: google.cloud.bigquery.storage.v1beta1.BigQueryStorage.SplitReadStream:output_type -> google.cloud.bigquery.storage.v1beta1.SplitReadStreamResponse
  1670  	32, // [32:37] is the sub-list for method output_type
  1671  	27, // [27:32] is the sub-list for method input_type
  1672  	27, // [27:27] is the sub-list for extension type_name
  1673  	27, // [27:27] is the sub-list for extension extendee
  1674  	0,  // [0:27] is the sub-list for field type_name
  1675  }
  1676  
  1677  func init() { file_google_cloud_bigquery_storage_v1beta1_storage_proto_init() }
  1678  func file_google_cloud_bigquery_storage_v1beta1_storage_proto_init() {
  1679  	if File_google_cloud_bigquery_storage_v1beta1_storage_proto != nil {
  1680  		return
  1681  	}
  1682  	file_google_cloud_bigquery_storage_v1beta1_arrow_proto_init()
  1683  	file_google_cloud_bigquery_storage_v1beta1_avro_proto_init()
  1684  	file_google_cloud_bigquery_storage_v1beta1_read_options_proto_init()
  1685  	file_google_cloud_bigquery_storage_v1beta1_table_reference_proto_init()
  1686  	if !protoimpl.UnsafeEnabled {
  1687  		file_google_cloud_bigquery_storage_v1beta1_storage_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
  1688  			switch v := v.(*Stream); i {
  1689  			case 0:
  1690  				return &v.state
  1691  			case 1:
  1692  				return &v.sizeCache
  1693  			case 2:
  1694  				return &v.unknownFields
  1695  			default:
  1696  				return nil
  1697  			}
  1698  		}
  1699  		file_google_cloud_bigquery_storage_v1beta1_storage_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
  1700  			switch v := v.(*StreamPosition); i {
  1701  			case 0:
  1702  				return &v.state
  1703  			case 1:
  1704  				return &v.sizeCache
  1705  			case 2:
  1706  				return &v.unknownFields
  1707  			default:
  1708  				return nil
  1709  			}
  1710  		}
  1711  		file_google_cloud_bigquery_storage_v1beta1_storage_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
  1712  			switch v := v.(*ReadSession); i {
  1713  			case 0:
  1714  				return &v.state
  1715  			case 1:
  1716  				return &v.sizeCache
  1717  			case 2:
  1718  				return &v.unknownFields
  1719  			default:
  1720  				return nil
  1721  			}
  1722  		}
  1723  		file_google_cloud_bigquery_storage_v1beta1_storage_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
  1724  			switch v := v.(*CreateReadSessionRequest); i {
  1725  			case 0:
  1726  				return &v.state
  1727  			case 1:
  1728  				return &v.sizeCache
  1729  			case 2:
  1730  				return &v.unknownFields
  1731  			default:
  1732  				return nil
  1733  			}
  1734  		}
  1735  		file_google_cloud_bigquery_storage_v1beta1_storage_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
  1736  			switch v := v.(*ReadRowsRequest); i {
  1737  			case 0:
  1738  				return &v.state
  1739  			case 1:
  1740  				return &v.sizeCache
  1741  			case 2:
  1742  				return &v.unknownFields
  1743  			default:
  1744  				return nil
  1745  			}
  1746  		}
  1747  		file_google_cloud_bigquery_storage_v1beta1_storage_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
  1748  			switch v := v.(*StreamStatus); i {
  1749  			case 0:
  1750  				return &v.state
  1751  			case 1:
  1752  				return &v.sizeCache
  1753  			case 2:
  1754  				return &v.unknownFields
  1755  			default:
  1756  				return nil
  1757  			}
  1758  		}
  1759  		file_google_cloud_bigquery_storage_v1beta1_storage_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
  1760  			switch v := v.(*Progress); i {
  1761  			case 0:
  1762  				return &v.state
  1763  			case 1:
  1764  				return &v.sizeCache
  1765  			case 2:
  1766  				return &v.unknownFields
  1767  			default:
  1768  				return nil
  1769  			}
  1770  		}
  1771  		file_google_cloud_bigquery_storage_v1beta1_storage_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} {
  1772  			switch v := v.(*ThrottleStatus); i {
  1773  			case 0:
  1774  				return &v.state
  1775  			case 1:
  1776  				return &v.sizeCache
  1777  			case 2:
  1778  				return &v.unknownFields
  1779  			default:
  1780  				return nil
  1781  			}
  1782  		}
  1783  		file_google_cloud_bigquery_storage_v1beta1_storage_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} {
  1784  			switch v := v.(*ReadRowsResponse); i {
  1785  			case 0:
  1786  				return &v.state
  1787  			case 1:
  1788  				return &v.sizeCache
  1789  			case 2:
  1790  				return &v.unknownFields
  1791  			default:
  1792  				return nil
  1793  			}
  1794  		}
  1795  		file_google_cloud_bigquery_storage_v1beta1_storage_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} {
  1796  			switch v := v.(*BatchCreateReadSessionStreamsRequest); i {
  1797  			case 0:
  1798  				return &v.state
  1799  			case 1:
  1800  				return &v.sizeCache
  1801  			case 2:
  1802  				return &v.unknownFields
  1803  			default:
  1804  				return nil
  1805  			}
  1806  		}
  1807  		file_google_cloud_bigquery_storage_v1beta1_storage_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} {
  1808  			switch v := v.(*BatchCreateReadSessionStreamsResponse); i {
  1809  			case 0:
  1810  				return &v.state
  1811  			case 1:
  1812  				return &v.sizeCache
  1813  			case 2:
  1814  				return &v.unknownFields
  1815  			default:
  1816  				return nil
  1817  			}
  1818  		}
  1819  		file_google_cloud_bigquery_storage_v1beta1_storage_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} {
  1820  			switch v := v.(*FinalizeStreamRequest); i {
  1821  			case 0:
  1822  				return &v.state
  1823  			case 1:
  1824  				return &v.sizeCache
  1825  			case 2:
  1826  				return &v.unknownFields
  1827  			default:
  1828  				return nil
  1829  			}
  1830  		}
  1831  		file_google_cloud_bigquery_storage_v1beta1_storage_proto_msgTypes[12].Exporter = func(v interface{}, i int) interface{} {
  1832  			switch v := v.(*SplitReadStreamRequest); i {
  1833  			case 0:
  1834  				return &v.state
  1835  			case 1:
  1836  				return &v.sizeCache
  1837  			case 2:
  1838  				return &v.unknownFields
  1839  			default:
  1840  				return nil
  1841  			}
  1842  		}
  1843  		file_google_cloud_bigquery_storage_v1beta1_storage_proto_msgTypes[13].Exporter = func(v interface{}, i int) interface{} {
  1844  			switch v := v.(*SplitReadStreamResponse); i {
  1845  			case 0:
  1846  				return &v.state
  1847  			case 1:
  1848  				return &v.sizeCache
  1849  			case 2:
  1850  				return &v.unknownFields
  1851  			default:
  1852  				return nil
  1853  			}
  1854  		}
  1855  	}
  1856  	file_google_cloud_bigquery_storage_v1beta1_storage_proto_msgTypes[2].OneofWrappers = []interface{}{
  1857  		(*ReadSession_AvroSchema)(nil),
  1858  		(*ReadSession_ArrowSchema)(nil),
  1859  	}
  1860  	file_google_cloud_bigquery_storage_v1beta1_storage_proto_msgTypes[8].OneofWrappers = []interface{}{
  1861  		(*ReadRowsResponse_AvroRows)(nil),
  1862  		(*ReadRowsResponse_ArrowRecordBatch)(nil),
  1863  		(*ReadRowsResponse_AvroSchema)(nil),
  1864  		(*ReadRowsResponse_ArrowSchema)(nil),
  1865  	}
  1866  	type x struct{}
  1867  	out := protoimpl.TypeBuilder{
  1868  		File: protoimpl.DescBuilder{
  1869  			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
  1870  			RawDescriptor: file_google_cloud_bigquery_storage_v1beta1_storage_proto_rawDesc,
  1871  			NumEnums:      2,
  1872  			NumMessages:   14,
  1873  			NumExtensions: 0,
  1874  			NumServices:   1,
  1875  		},
  1876  		GoTypes:           file_google_cloud_bigquery_storage_v1beta1_storage_proto_goTypes,
  1877  		DependencyIndexes: file_google_cloud_bigquery_storage_v1beta1_storage_proto_depIdxs,
  1878  		EnumInfos:         file_google_cloud_bigquery_storage_v1beta1_storage_proto_enumTypes,
  1879  		MessageInfos:      file_google_cloud_bigquery_storage_v1beta1_storage_proto_msgTypes,
  1880  	}.Build()
  1881  	File_google_cloud_bigquery_storage_v1beta1_storage_proto = out.File
  1882  	file_google_cloud_bigquery_storage_v1beta1_storage_proto_rawDesc = nil
  1883  	file_google_cloud_bigquery_storage_v1beta1_storage_proto_goTypes = nil
  1884  	file_google_cloud_bigquery_storage_v1beta1_storage_proto_depIdxs = nil
  1885  }
  1886  
  1887  // Reference imports to suppress errors if they are not otherwise used.
  1888  var _ context.Context
  1889  var _ grpc.ClientConnInterface
  1890  
  1891  // This is a compile-time assertion to ensure that this generated file
  1892  // is compatible with the grpc package it is being compiled against.
  1893  const _ = grpc.SupportPackageIsVersion6
  1894  
  1895  // BigQueryStorageClient is the client API for BigQueryStorage service.
  1896  //
  1897  // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
  1898  type BigQueryStorageClient interface {
  1899  	// Creates a new read session. A read session divides the contents of a
  1900  	// BigQuery table into one or more streams, which can then be used to read
  1901  	// data from the table. The read session also specifies properties of the
  1902  	// data to be read, such as a list of columns or a push-down filter describing
  1903  	// the rows to be returned.
  1904  	//
  1905  	// A particular row can be read by at most one stream. When the caller has
  1906  	// reached the end of each stream in the session, then all the data in the
  1907  	// table has been read.
  1908  	//
  1909  	// Read sessions automatically expire 6 hours after they are created and do
  1910  	// not require manual clean-up by the caller.
  1911  	CreateReadSession(ctx context.Context, in *CreateReadSessionRequest, opts ...grpc.CallOption) (*ReadSession, error)
  1912  	// Reads rows from the table in the format prescribed by the read session.
  1913  	// Each response contains one or more table rows, up to a maximum of 10 MiB
  1914  	// per response; read requests which attempt to read individual rows larger
  1915  	// than this will fail.
  1916  	//
  1917  	// Each request also returns a set of stream statistics reflecting the
  1918  	// estimated total number of rows in the read stream. This number is computed
  1919  	// based on the total table size and the number of active streams in the read
  1920  	// session, and may change as other streams continue to read data.
  1921  	ReadRows(ctx context.Context, in *ReadRowsRequest, opts ...grpc.CallOption) (BigQueryStorage_ReadRowsClient, error)
  1922  	// Creates additional streams for a ReadSession. This API can be used to
  1923  	// dynamically adjust the parallelism of a batch processing task upwards by
  1924  	// adding additional workers.
  1925  	BatchCreateReadSessionStreams(ctx context.Context, in *BatchCreateReadSessionStreamsRequest, opts ...grpc.CallOption) (*BatchCreateReadSessionStreamsResponse, error)
  1926  	// Causes a single stream in a ReadSession to gracefully stop. This
  1927  	// API can be used to dynamically adjust the parallelism of a batch processing
  1928  	// task downwards without losing data.
  1929  	//
  1930  	// This API does not delete the stream -- it remains visible in the
  1931  	// ReadSession, and any data processed by the stream is not released to other
  1932  	// streams. However, no additional data will be assigned to the stream once
  1933  	// this call completes. Callers must continue reading data on the stream until
  1934  	// the end of the stream is reached so that data which has already been
  1935  	// assigned to the stream will be processed.
  1936  	//
  1937  	// This method will return an error if there are no other live streams
  1938  	// in the Session, or if SplitReadStream() has been called on the given
  1939  	// Stream.
  1940  	FinalizeStream(ctx context.Context, in *FinalizeStreamRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
  1941  	// Splits a given read stream into two Streams. These streams are referred to
  1942  	// as the primary and the residual of the split. The original stream can still
  1943  	// be read from in the same manner as before. Both of the returned streams can
  1944  	// also be read from, and the total rows return by both child streams will be
  1945  	// the same as the rows read from the original stream.
  1946  	//
  1947  	// Moreover, the two child streams will be allocated back to back in the
  1948  	// original Stream. Concretely, it is guaranteed that for streams Original,
  1949  	// Primary, and Residual, that Original[0-j] = Primary[0-j] and
  1950  	// Original[j-n] = Residual[0-m] once the streams have been read to
  1951  	// completion.
  1952  	//
  1953  	// This method is guaranteed to be idempotent.
  1954  	SplitReadStream(ctx context.Context, in *SplitReadStreamRequest, opts ...grpc.CallOption) (*SplitReadStreamResponse, error)
  1955  }
  1956  
  1957  type bigQueryStorageClient struct {
  1958  	cc grpc.ClientConnInterface
  1959  }
  1960  
  1961  func NewBigQueryStorageClient(cc grpc.ClientConnInterface) BigQueryStorageClient {
  1962  	return &bigQueryStorageClient{cc}
  1963  }
  1964  
  1965  func (c *bigQueryStorageClient) CreateReadSession(ctx context.Context, in *CreateReadSessionRequest, opts ...grpc.CallOption) (*ReadSession, error) {
  1966  	out := new(ReadSession)
  1967  	err := c.cc.Invoke(ctx, "/google.cloud.bigquery.storage.v1beta1.BigQueryStorage/CreateReadSession", in, out, opts...)
  1968  	if err != nil {
  1969  		return nil, err
  1970  	}
  1971  	return out, nil
  1972  }
  1973  
  1974  func (c *bigQueryStorageClient) ReadRows(ctx context.Context, in *ReadRowsRequest, opts ...grpc.CallOption) (BigQueryStorage_ReadRowsClient, error) {
  1975  	stream, err := c.cc.NewStream(ctx, &_BigQueryStorage_serviceDesc.Streams[0], "/google.cloud.bigquery.storage.v1beta1.BigQueryStorage/ReadRows", opts...)
  1976  	if err != nil {
  1977  		return nil, err
  1978  	}
  1979  	x := &bigQueryStorageReadRowsClient{stream}
  1980  	if err := x.ClientStream.SendMsg(in); err != nil {
  1981  		return nil, err
  1982  	}
  1983  	if err := x.ClientStream.CloseSend(); err != nil {
  1984  		return nil, err
  1985  	}
  1986  	return x, nil
  1987  }
  1988  
  1989  type BigQueryStorage_ReadRowsClient interface {
  1990  	Recv() (*ReadRowsResponse, error)
  1991  	grpc.ClientStream
  1992  }
  1993  
  1994  type bigQueryStorageReadRowsClient struct {
  1995  	grpc.ClientStream
  1996  }
  1997  
  1998  func (x *bigQueryStorageReadRowsClient) Recv() (*ReadRowsResponse, error) {
  1999  	m := new(ReadRowsResponse)
  2000  	if err := x.ClientStream.RecvMsg(m); err != nil {
  2001  		return nil, err
  2002  	}
  2003  	return m, nil
  2004  }
  2005  
  2006  func (c *bigQueryStorageClient) BatchCreateReadSessionStreams(ctx context.Context, in *BatchCreateReadSessionStreamsRequest, opts ...grpc.CallOption) (*BatchCreateReadSessionStreamsResponse, error) {
  2007  	out := new(BatchCreateReadSessionStreamsResponse)
  2008  	err := c.cc.Invoke(ctx, "/google.cloud.bigquery.storage.v1beta1.BigQueryStorage/BatchCreateReadSessionStreams", in, out, opts...)
  2009  	if err != nil {
  2010  		return nil, err
  2011  	}
  2012  	return out, nil
  2013  }
  2014  
  2015  func (c *bigQueryStorageClient) FinalizeStream(ctx context.Context, in *FinalizeStreamRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) {
  2016  	out := new(emptypb.Empty)
  2017  	err := c.cc.Invoke(ctx, "/google.cloud.bigquery.storage.v1beta1.BigQueryStorage/FinalizeStream", in, out, opts...)
  2018  	if err != nil {
  2019  		return nil, err
  2020  	}
  2021  	return out, nil
  2022  }
  2023  
  2024  func (c *bigQueryStorageClient) SplitReadStream(ctx context.Context, in *SplitReadStreamRequest, opts ...grpc.CallOption) (*SplitReadStreamResponse, error) {
  2025  	out := new(SplitReadStreamResponse)
  2026  	err := c.cc.Invoke(ctx, "/google.cloud.bigquery.storage.v1beta1.BigQueryStorage/SplitReadStream", in, out, opts...)
  2027  	if err != nil {
  2028  		return nil, err
  2029  	}
  2030  	return out, nil
  2031  }
  2032  
  2033  // BigQueryStorageServer is the server API for BigQueryStorage service.
  2034  type BigQueryStorageServer interface {
  2035  	// Creates a new read session. A read session divides the contents of a
  2036  	// BigQuery table into one or more streams, which can then be used to read
  2037  	// data from the table. The read session also specifies properties of the
  2038  	// data to be read, such as a list of columns or a push-down filter describing
  2039  	// the rows to be returned.
  2040  	//
  2041  	// A particular row can be read by at most one stream. When the caller has
  2042  	// reached the end of each stream in the session, then all the data in the
  2043  	// table has been read.
  2044  	//
  2045  	// Read sessions automatically expire 6 hours after they are created and do
  2046  	// not require manual clean-up by the caller.
  2047  	CreateReadSession(context.Context, *CreateReadSessionRequest) (*ReadSession, error)
  2048  	// Reads rows from the table in the format prescribed by the read session.
  2049  	// Each response contains one or more table rows, up to a maximum of 10 MiB
  2050  	// per response; read requests which attempt to read individual rows larger
  2051  	// than this will fail.
  2052  	//
  2053  	// Each request also returns a set of stream statistics reflecting the
  2054  	// estimated total number of rows in the read stream. This number is computed
  2055  	// based on the total table size and the number of active streams in the read
  2056  	// session, and may change as other streams continue to read data.
  2057  	ReadRows(*ReadRowsRequest, BigQueryStorage_ReadRowsServer) error
  2058  	// Creates additional streams for a ReadSession. This API can be used to
  2059  	// dynamically adjust the parallelism of a batch processing task upwards by
  2060  	// adding additional workers.
  2061  	BatchCreateReadSessionStreams(context.Context, *BatchCreateReadSessionStreamsRequest) (*BatchCreateReadSessionStreamsResponse, error)
  2062  	// Causes a single stream in a ReadSession to gracefully stop. This
  2063  	// API can be used to dynamically adjust the parallelism of a batch processing
  2064  	// task downwards without losing data.
  2065  	//
  2066  	// This API does not delete the stream -- it remains visible in the
  2067  	// ReadSession, and any data processed by the stream is not released to other
  2068  	// streams. However, no additional data will be assigned to the stream once
  2069  	// this call completes. Callers must continue reading data on the stream until
  2070  	// the end of the stream is reached so that data which has already been
  2071  	// assigned to the stream will be processed.
  2072  	//
  2073  	// This method will return an error if there are no other live streams
  2074  	// in the Session, or if SplitReadStream() has been called on the given
  2075  	// Stream.
  2076  	FinalizeStream(context.Context, *FinalizeStreamRequest) (*emptypb.Empty, error)
  2077  	// Splits a given read stream into two Streams. These streams are referred to
  2078  	// as the primary and the residual of the split. The original stream can still
  2079  	// be read from in the same manner as before. Both of the returned streams can
  2080  	// also be read from, and the total rows return by both child streams will be
  2081  	// the same as the rows read from the original stream.
  2082  	//
  2083  	// Moreover, the two child streams will be allocated back to back in the
  2084  	// original Stream. Concretely, it is guaranteed that for streams Original,
  2085  	// Primary, and Residual, that Original[0-j] = Primary[0-j] and
  2086  	// Original[j-n] = Residual[0-m] once the streams have been read to
  2087  	// completion.
  2088  	//
  2089  	// This method is guaranteed to be idempotent.
  2090  	SplitReadStream(context.Context, *SplitReadStreamRequest) (*SplitReadStreamResponse, error)
  2091  }
  2092  
  2093  // UnimplementedBigQueryStorageServer can be embedded to have forward compatible implementations.
  2094  type UnimplementedBigQueryStorageServer struct {
  2095  }
  2096  
  2097  func (*UnimplementedBigQueryStorageServer) CreateReadSession(context.Context, *CreateReadSessionRequest) (*ReadSession, error) {
  2098  	return nil, status.Errorf(codes.Unimplemented, "method CreateReadSession not implemented")
  2099  }
  2100  func (*UnimplementedBigQueryStorageServer) ReadRows(*ReadRowsRequest, BigQueryStorage_ReadRowsServer) error {
  2101  	return status.Errorf(codes.Unimplemented, "method ReadRows not implemented")
  2102  }
  2103  func (*UnimplementedBigQueryStorageServer) BatchCreateReadSessionStreams(context.Context, *BatchCreateReadSessionStreamsRequest) (*BatchCreateReadSessionStreamsResponse, error) {
  2104  	return nil, status.Errorf(codes.Unimplemented, "method BatchCreateReadSessionStreams not implemented")
  2105  }
  2106  func (*UnimplementedBigQueryStorageServer) FinalizeStream(context.Context, *FinalizeStreamRequest) (*emptypb.Empty, error) {
  2107  	return nil, status.Errorf(codes.Unimplemented, "method FinalizeStream not implemented")
  2108  }
  2109  func (*UnimplementedBigQueryStorageServer) SplitReadStream(context.Context, *SplitReadStreamRequest) (*SplitReadStreamResponse, error) {
  2110  	return nil, status.Errorf(codes.Unimplemented, "method SplitReadStream not implemented")
  2111  }
  2112  
  2113  func RegisterBigQueryStorageServer(s *grpc.Server, srv BigQueryStorageServer) {
  2114  	s.RegisterService(&_BigQueryStorage_serviceDesc, srv)
  2115  }
  2116  
  2117  func _BigQueryStorage_CreateReadSession_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2118  	in := new(CreateReadSessionRequest)
  2119  	if err := dec(in); err != nil {
  2120  		return nil, err
  2121  	}
  2122  	if interceptor == nil {
  2123  		return srv.(BigQueryStorageServer).CreateReadSession(ctx, in)
  2124  	}
  2125  	info := &grpc.UnaryServerInfo{
  2126  		Server:     srv,
  2127  		FullMethod: "/google.cloud.bigquery.storage.v1beta1.BigQueryStorage/CreateReadSession",
  2128  	}
  2129  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2130  		return srv.(BigQueryStorageServer).CreateReadSession(ctx, req.(*CreateReadSessionRequest))
  2131  	}
  2132  	return interceptor(ctx, in, info, handler)
  2133  }
  2134  
  2135  func _BigQueryStorage_ReadRows_Handler(srv interface{}, stream grpc.ServerStream) error {
  2136  	m := new(ReadRowsRequest)
  2137  	if err := stream.RecvMsg(m); err != nil {
  2138  		return err
  2139  	}
  2140  	return srv.(BigQueryStorageServer).ReadRows(m, &bigQueryStorageReadRowsServer{stream})
  2141  }
  2142  
  2143  type BigQueryStorage_ReadRowsServer interface {
  2144  	Send(*ReadRowsResponse) error
  2145  	grpc.ServerStream
  2146  }
  2147  
  2148  type bigQueryStorageReadRowsServer struct {
  2149  	grpc.ServerStream
  2150  }
  2151  
  2152  func (x *bigQueryStorageReadRowsServer) Send(m *ReadRowsResponse) error {
  2153  	return x.ServerStream.SendMsg(m)
  2154  }
  2155  
  2156  func _BigQueryStorage_BatchCreateReadSessionStreams_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2157  	in := new(BatchCreateReadSessionStreamsRequest)
  2158  	if err := dec(in); err != nil {
  2159  		return nil, err
  2160  	}
  2161  	if interceptor == nil {
  2162  		return srv.(BigQueryStorageServer).BatchCreateReadSessionStreams(ctx, in)
  2163  	}
  2164  	info := &grpc.UnaryServerInfo{
  2165  		Server:     srv,
  2166  		FullMethod: "/google.cloud.bigquery.storage.v1beta1.BigQueryStorage/BatchCreateReadSessionStreams",
  2167  	}
  2168  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2169  		return srv.(BigQueryStorageServer).BatchCreateReadSessionStreams(ctx, req.(*BatchCreateReadSessionStreamsRequest))
  2170  	}
  2171  	return interceptor(ctx, in, info, handler)
  2172  }
  2173  
  2174  func _BigQueryStorage_FinalizeStream_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2175  	in := new(FinalizeStreamRequest)
  2176  	if err := dec(in); err != nil {
  2177  		return nil, err
  2178  	}
  2179  	if interceptor == nil {
  2180  		return srv.(BigQueryStorageServer).FinalizeStream(ctx, in)
  2181  	}
  2182  	info := &grpc.UnaryServerInfo{
  2183  		Server:     srv,
  2184  		FullMethod: "/google.cloud.bigquery.storage.v1beta1.BigQueryStorage/FinalizeStream",
  2185  	}
  2186  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2187  		return srv.(BigQueryStorageServer).FinalizeStream(ctx, req.(*FinalizeStreamRequest))
  2188  	}
  2189  	return interceptor(ctx, in, info, handler)
  2190  }
  2191  
  2192  func _BigQueryStorage_SplitReadStream_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
  2193  	in := new(SplitReadStreamRequest)
  2194  	if err := dec(in); err != nil {
  2195  		return nil, err
  2196  	}
  2197  	if interceptor == nil {
  2198  		return srv.(BigQueryStorageServer).SplitReadStream(ctx, in)
  2199  	}
  2200  	info := &grpc.UnaryServerInfo{
  2201  		Server:     srv,
  2202  		FullMethod: "/google.cloud.bigquery.storage.v1beta1.BigQueryStorage/SplitReadStream",
  2203  	}
  2204  	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
  2205  		return srv.(BigQueryStorageServer).SplitReadStream(ctx, req.(*SplitReadStreamRequest))
  2206  	}
  2207  	return interceptor(ctx, in, info, handler)
  2208  }
  2209  
  2210  var _BigQueryStorage_serviceDesc = grpc.ServiceDesc{
  2211  	ServiceName: "google.cloud.bigquery.storage.v1beta1.BigQueryStorage",
  2212  	HandlerType: (*BigQueryStorageServer)(nil),
  2213  	Methods: []grpc.MethodDesc{
  2214  		{
  2215  			MethodName: "CreateReadSession",
  2216  			Handler:    _BigQueryStorage_CreateReadSession_Handler,
  2217  		},
  2218  		{
  2219  			MethodName: "BatchCreateReadSessionStreams",
  2220  			Handler:    _BigQueryStorage_BatchCreateReadSessionStreams_Handler,
  2221  		},
  2222  		{
  2223  			MethodName: "FinalizeStream",
  2224  			Handler:    _BigQueryStorage_FinalizeStream_Handler,
  2225  		},
  2226  		{
  2227  			MethodName: "SplitReadStream",
  2228  			Handler:    _BigQueryStorage_SplitReadStream_Handler,
  2229  		},
  2230  	},
  2231  	Streams: []grpc.StreamDesc{
  2232  		{
  2233  			StreamName:    "ReadRows",
  2234  			Handler:       _BigQueryStorage_ReadRows_Handler,
  2235  			ServerStreams: true,
  2236  		},
  2237  	},
  2238  	Metadata: "google/cloud/bigquery/storage/v1beta1/storage.proto",
  2239  }
  2240
View as plain text