1// Copyright 2019 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 16// Code generated by protoc-gen-go. DO NOT EDIT. 17// versions: 18// protoc-gen-go v1.25.0 19// protoc v3.13.0 20// source: google/cloud/bigquery/storage/v1/stream.proto 21 22package storage 23 24import ( 25 reflect "reflect" 26 sync "sync" 27 28 proto "github.com/golang/protobuf/proto" 29 _ "google.golang.org/genproto/googleapis/api/annotations" 30 protoreflect "google.golang.org/protobuf/reflect/protoreflect" 31 protoimpl "google.golang.org/protobuf/runtime/protoimpl" 32 timestamppb "google.golang.org/protobuf/types/known/timestamppb" 33) 34 35const ( 36 // Verify that this generated code is sufficiently up-to-date. 37 _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) 38 // Verify that runtime/protoimpl is sufficiently up-to-date. 39 _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) 40) 41 42// This is a compile-time assertion that a sufficiently up-to-date version 43// of the legacy proto package is being used. 44const _ = proto.ProtoPackageIsVersion4 45 46// Data format for input or output data. 47type DataFormat int32 48 49const ( 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 = 2 57) 58 59// Enum value maps for DataFormat. 60var ( 61 DataFormat_name = map[int32]string{ 62 0: "DATA_FORMAT_UNSPECIFIED", 63 1: "AVRO", 64 2: "ARROW", 65 } 66 DataFormat_value = map[string]int32{ 67 "DATA_FORMAT_UNSPECIFIED": 0, 68 "AVRO": 1, 69 "ARROW": 2, 70 } 71) 72 73func (x DataFormat) Enum() *DataFormat { 74 p := new(DataFormat) 75 *p = x 76 return p 77} 78 79func (x DataFormat) String() string { 80 return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) 81} 82 83func (DataFormat) Descriptor() protoreflect.EnumDescriptor { 84 return file_google_cloud_bigquery_storage_v1_stream_proto_enumTypes[0].Descriptor() 85} 86 87func (DataFormat) Type() protoreflect.EnumType { 88 return &file_google_cloud_bigquery_storage_v1_stream_proto_enumTypes[0] 89} 90 91func (x DataFormat) Number() protoreflect.EnumNumber { 92 return protoreflect.EnumNumber(x) 93} 94 95// Deprecated: Use DataFormat.Descriptor instead. 96func (DataFormat) EnumDescriptor() ([]byte, []int) { 97 return file_google_cloud_bigquery_storage_v1_stream_proto_rawDescGZIP(), []int{0} 98} 99 100// Information about the ReadSession. 101type ReadSession struct { 102 state protoimpl.MessageState 103 sizeCache protoimpl.SizeCache 104 unknownFields protoimpl.UnknownFields 105 106 // Output only. Unique identifier for the session, in the form 107 // `projects/{project_id}/locations/{location}/sessions/{session_id}`. 108 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 109 // Output only. Time at which the session becomes invalid. After this time, subsequent 110 // requests to read this Session will return errors. The expire_time is 111 // automatically assigned and currently cannot be specified or updated. 112 ExpireTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=expire_time,json=expireTime,proto3" json:"expire_time,omitempty"` 113 // Immutable. Data format of the output data. 114 DataFormat DataFormat `protobuf:"varint,3,opt,name=data_format,json=dataFormat,proto3,enum=google.cloud.bigquery.storage.v1.DataFormat" json:"data_format,omitempty"` 115 // The schema for the read. If read_options.selected_fields is set, the 116 // schema may be different from the table schema as it will only contain 117 // the selected fields. 118 // 119 // Types that are assignable to Schema: 120 // *ReadSession_AvroSchema 121 // *ReadSession_ArrowSchema 122 Schema isReadSession_Schema `protobuf_oneof:"schema"` 123 // Immutable. Table that this ReadSession is reading from, in the form 124 // `projects/{project_id}/datasets/{dataset_id}/tables/{table_id}` 125 Table string `protobuf:"bytes,6,opt,name=table,proto3" json:"table,omitempty"` 126 // Optional. Any modifiers which are applied when reading from the specified table. 127 TableModifiers *ReadSession_TableModifiers `protobuf:"bytes,7,opt,name=table_modifiers,json=tableModifiers,proto3" json:"table_modifiers,omitempty"` 128 // Optional. Read options for this session (e.g. column selection, filters). 129 ReadOptions *ReadSession_TableReadOptions `protobuf:"bytes,8,opt,name=read_options,json=readOptions,proto3" json:"read_options,omitempty"` 130 // Output only. A list of streams created with the session. 131 // 132 // At least one stream is created with the session. In the future, larger 133 // request_stream_count values *may* result in this list being unpopulated, 134 // in that case, the user will need to use a List method to get the streams 135 // instead, which is not yet available. 136 Streams []*ReadStream `protobuf:"bytes,10,rep,name=streams,proto3" json:"streams,omitempty"` 137} 138 139func (x *ReadSession) Reset() { 140 *x = ReadSession{} 141 if protoimpl.UnsafeEnabled { 142 mi := &file_google_cloud_bigquery_storage_v1_stream_proto_msgTypes[0] 143 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 144 ms.StoreMessageInfo(mi) 145 } 146} 147 148func (x *ReadSession) String() string { 149 return protoimpl.X.MessageStringOf(x) 150} 151 152func (*ReadSession) ProtoMessage() {} 153 154func (x *ReadSession) ProtoReflect() protoreflect.Message { 155 mi := &file_google_cloud_bigquery_storage_v1_stream_proto_msgTypes[0] 156 if protoimpl.UnsafeEnabled && x != nil { 157 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 158 if ms.LoadMessageInfo() == nil { 159 ms.StoreMessageInfo(mi) 160 } 161 return ms 162 } 163 return mi.MessageOf(x) 164} 165 166// Deprecated: Use ReadSession.ProtoReflect.Descriptor instead. 167func (*ReadSession) Descriptor() ([]byte, []int) { 168 return file_google_cloud_bigquery_storage_v1_stream_proto_rawDescGZIP(), []int{0} 169} 170 171func (x *ReadSession) GetName() string { 172 if x != nil { 173 return x.Name 174 } 175 return "" 176} 177 178func (x *ReadSession) GetExpireTime() *timestamppb.Timestamp { 179 if x != nil { 180 return x.ExpireTime 181 } 182 return nil 183} 184 185func (x *ReadSession) GetDataFormat() DataFormat { 186 if x != nil { 187 return x.DataFormat 188 } 189 return DataFormat_DATA_FORMAT_UNSPECIFIED 190} 191 192func (m *ReadSession) GetSchema() isReadSession_Schema { 193 if m != nil { 194 return m.Schema 195 } 196 return nil 197} 198 199func (x *ReadSession) GetAvroSchema() *AvroSchema { 200 if x, ok := x.GetSchema().(*ReadSession_AvroSchema); ok { 201 return x.AvroSchema 202 } 203 return nil 204} 205 206func (x *ReadSession) GetArrowSchema() *ArrowSchema { 207 if x, ok := x.GetSchema().(*ReadSession_ArrowSchema); ok { 208 return x.ArrowSchema 209 } 210 return nil 211} 212 213func (x *ReadSession) GetTable() string { 214 if x != nil { 215 return x.Table 216 } 217 return "" 218} 219 220func (x *ReadSession) GetTableModifiers() *ReadSession_TableModifiers { 221 if x != nil { 222 return x.TableModifiers 223 } 224 return nil 225} 226 227func (x *ReadSession) GetReadOptions() *ReadSession_TableReadOptions { 228 if x != nil { 229 return x.ReadOptions 230 } 231 return nil 232} 233 234func (x *ReadSession) GetStreams() []*ReadStream { 235 if x != nil { 236 return x.Streams 237 } 238 return nil 239} 240 241type isReadSession_Schema interface { 242 isReadSession_Schema() 243} 244 245type ReadSession_AvroSchema struct { 246 // Output only. Avro schema. 247 AvroSchema *AvroSchema `protobuf:"bytes,4,opt,name=avro_schema,json=avroSchema,proto3,oneof"` 248} 249 250type ReadSession_ArrowSchema struct { 251 // Output only. Arrow schema. 252 ArrowSchema *ArrowSchema `protobuf:"bytes,5,opt,name=arrow_schema,json=arrowSchema,proto3,oneof"` 253} 254 255func (*ReadSession_AvroSchema) isReadSession_Schema() {} 256 257func (*ReadSession_ArrowSchema) isReadSession_Schema() {} 258 259// Information about a single stream that gets data out of the storage system. 260// Most of the information about `ReadStream` instances is aggregated, making 261// `ReadStream` lightweight. 262type ReadStream struct { 263 state protoimpl.MessageState 264 sizeCache protoimpl.SizeCache 265 unknownFields protoimpl.UnknownFields 266 267 // Output only. Name of the stream, in the form 268 // `projects/{project_id}/locations/{location}/sessions/{session_id}/streams/{stream_id}`. 269 Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` 270} 271 272func (x *ReadStream) Reset() { 273 *x = ReadStream{} 274 if protoimpl.UnsafeEnabled { 275 mi := &file_google_cloud_bigquery_storage_v1_stream_proto_msgTypes[1] 276 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 277 ms.StoreMessageInfo(mi) 278 } 279} 280 281func (x *ReadStream) String() string { 282 return protoimpl.X.MessageStringOf(x) 283} 284 285func (*ReadStream) ProtoMessage() {} 286 287func (x *ReadStream) ProtoReflect() protoreflect.Message { 288 mi := &file_google_cloud_bigquery_storage_v1_stream_proto_msgTypes[1] 289 if protoimpl.UnsafeEnabled && x != nil { 290 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 291 if ms.LoadMessageInfo() == nil { 292 ms.StoreMessageInfo(mi) 293 } 294 return ms 295 } 296 return mi.MessageOf(x) 297} 298 299// Deprecated: Use ReadStream.ProtoReflect.Descriptor instead. 300func (*ReadStream) Descriptor() ([]byte, []int) { 301 return file_google_cloud_bigquery_storage_v1_stream_proto_rawDescGZIP(), []int{1} 302} 303 304func (x *ReadStream) GetName() string { 305 if x != nil { 306 return x.Name 307 } 308 return "" 309} 310 311// Additional attributes when reading a table. 312type ReadSession_TableModifiers struct { 313 state protoimpl.MessageState 314 sizeCache protoimpl.SizeCache 315 unknownFields protoimpl.UnknownFields 316 317 // The snapshot time of the table. If not set, interpreted as now. 318 SnapshotTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=snapshot_time,json=snapshotTime,proto3" json:"snapshot_time,omitempty"` 319} 320 321func (x *ReadSession_TableModifiers) Reset() { 322 *x = ReadSession_TableModifiers{} 323 if protoimpl.UnsafeEnabled { 324 mi := &file_google_cloud_bigquery_storage_v1_stream_proto_msgTypes[2] 325 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 326 ms.StoreMessageInfo(mi) 327 } 328} 329 330func (x *ReadSession_TableModifiers) String() string { 331 return protoimpl.X.MessageStringOf(x) 332} 333 334func (*ReadSession_TableModifiers) ProtoMessage() {} 335 336func (x *ReadSession_TableModifiers) ProtoReflect() protoreflect.Message { 337 mi := &file_google_cloud_bigquery_storage_v1_stream_proto_msgTypes[2] 338 if protoimpl.UnsafeEnabled && x != nil { 339 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 340 if ms.LoadMessageInfo() == nil { 341 ms.StoreMessageInfo(mi) 342 } 343 return ms 344 } 345 return mi.MessageOf(x) 346} 347 348// Deprecated: Use ReadSession_TableModifiers.ProtoReflect.Descriptor instead. 349func (*ReadSession_TableModifiers) Descriptor() ([]byte, []int) { 350 return file_google_cloud_bigquery_storage_v1_stream_proto_rawDescGZIP(), []int{0, 0} 351} 352 353func (x *ReadSession_TableModifiers) GetSnapshotTime() *timestamppb.Timestamp { 354 if x != nil { 355 return x.SnapshotTime 356 } 357 return nil 358} 359 360// Options dictating how we read a table. 361type ReadSession_TableReadOptions struct { 362 state protoimpl.MessageState 363 sizeCache protoimpl.SizeCache 364 unknownFields protoimpl.UnknownFields 365 366 // Names of the fields in the table that should be read. If empty, all 367 // fields will be read. If the specified field is a nested field, all 368 // the sub-fields in the field will be selected. The output field order is 369 // unrelated to the order of fields in selected_fields. 370 SelectedFields []string `protobuf:"bytes,1,rep,name=selected_fields,json=selectedFields,proto3" json:"selected_fields,omitempty"` 371 // SQL text filtering statement, similar to a WHERE clause in a query. 372 // Aggregates are not supported. 373 // 374 // Examples: "int_field > 5" 375 // "date_field = CAST('2014-9-27' as DATE)" 376 // "nullable_field is not NULL" 377 // "st_equals(geo_field, st_geofromtext("POINT(2, 2)"))" 378 // "numeric_field BETWEEN 1.0 AND 5.0" 379 RowRestriction string `protobuf:"bytes,2,opt,name=row_restriction,json=rowRestriction,proto3" json:"row_restriction,omitempty"` 380} 381 382func (x *ReadSession_TableReadOptions) Reset() { 383 *x = ReadSession_TableReadOptions{} 384 if protoimpl.UnsafeEnabled { 385 mi := &file_google_cloud_bigquery_storage_v1_stream_proto_msgTypes[3] 386 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 387 ms.StoreMessageInfo(mi) 388 } 389} 390 391func (x *ReadSession_TableReadOptions) String() string { 392 return protoimpl.X.MessageStringOf(x) 393} 394 395func (*ReadSession_TableReadOptions) ProtoMessage() {} 396 397func (x *ReadSession_TableReadOptions) ProtoReflect() protoreflect.Message { 398 mi := &file_google_cloud_bigquery_storage_v1_stream_proto_msgTypes[3] 399 if protoimpl.UnsafeEnabled && x != nil { 400 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 401 if ms.LoadMessageInfo() == nil { 402 ms.StoreMessageInfo(mi) 403 } 404 return ms 405 } 406 return mi.MessageOf(x) 407} 408 409// Deprecated: Use ReadSession_TableReadOptions.ProtoReflect.Descriptor instead. 410func (*ReadSession_TableReadOptions) Descriptor() ([]byte, []int) { 411 return file_google_cloud_bigquery_storage_v1_stream_proto_rawDescGZIP(), []int{0, 1} 412} 413 414func (x *ReadSession_TableReadOptions) GetSelectedFields() []string { 415 if x != nil { 416 return x.SelectedFields 417 } 418 return nil 419} 420 421func (x *ReadSession_TableReadOptions) GetRowRestriction() string { 422 if x != nil { 423 return x.RowRestriction 424 } 425 return "" 426} 427 428var File_google_cloud_bigquery_storage_v1_stream_proto protoreflect.FileDescriptor 429 430var file_google_cloud_bigquery_storage_v1_stream_proto_rawDesc = []byte{ 431 0x0a, 0x2d, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x62, 432 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2f, 433 0x76, 0x31, 0x2f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 434 0x20, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 435 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 436 0x31, 0x1a, 0x1f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x66, 0x69, 437 0x65, 0x6c, 0x64, 0x5f, 0x62, 0x65, 0x68, 0x61, 0x76, 0x69, 0x6f, 0x72, 0x2e, 0x70, 0x72, 0x6f, 438 0x74, 0x6f, 0x1a, 0x19, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x2f, 0x72, 439 0x65, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x2c, 0x67, 440 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x62, 0x69, 0x67, 0x71, 441 0x75, 0x65, 0x72, 0x79, 0x2f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2f, 0x76, 0x31, 0x2f, 442 0x61, 0x72, 0x72, 0x6f, 0x77, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x2b, 0x67, 0x6f, 0x6f, 443 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 444 0x72, 0x79, 0x2f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2f, 0x76, 0x31, 0x2f, 0x61, 0x76, 445 0x72, 0x6f, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 446 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2f, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 447 0x61, 0x6d, 0x70, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0xf9, 0x07, 0x0a, 0x0b, 0x52, 0x65, 448 0x61, 0x64, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x17, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 449 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x04, 0x6e, 0x61, 450 0x6d, 0x65, 0x12, 0x40, 0x0a, 0x0b, 0x65, 0x78, 0x70, 0x69, 0x72, 0x65, 0x5f, 0x74, 0x69, 0x6d, 451 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 452 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x73, 0x74, 453 0x61, 0x6d, 0x70, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x0a, 0x65, 0x78, 0x70, 0x69, 0x72, 0x65, 454 0x54, 0x69, 0x6d, 0x65, 0x12, 0x52, 0x0a, 0x0b, 0x64, 0x61, 0x74, 0x61, 0x5f, 0x66, 0x6f, 0x72, 455 0x6d, 0x61, 0x74, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x2c, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 456 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 457 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x44, 0x61, 0x74, 458 0x61, 0x46, 0x6f, 0x72, 0x6d, 0x61, 0x74, 0x42, 0x03, 0xe0, 0x41, 0x05, 0x52, 0x0a, 0x64, 0x61, 459 0x74, 0x61, 0x46, 0x6f, 0x72, 0x6d, 0x61, 0x74, 0x12, 0x54, 0x0a, 0x0b, 0x61, 0x76, 0x72, 0x6f, 460 0x5f, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x18, 0x04, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2c, 0x2e, 461 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 462 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 463 0x2e, 0x41, 0x76, 0x72, 0x6f, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x42, 0x03, 0xe0, 0x41, 0x03, 464 0x48, 0x00, 0x52, 0x0a, 0x61, 0x76, 0x72, 0x6f, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x12, 0x57, 465 0x0a, 0x0c, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x5f, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x18, 0x05, 466 0x20, 0x01, 0x28, 0x0b, 0x32, 0x2d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 467 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 468 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x41, 0x72, 0x72, 0x6f, 0x77, 0x53, 0x63, 0x68, 469 0x65, 0x6d, 0x61, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x48, 0x00, 0x52, 0x0b, 0x61, 0x72, 0x72, 0x6f, 470 0x77, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x12, 0x3b, 0x0a, 0x05, 0x74, 0x61, 0x62, 0x6c, 0x65, 471 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x42, 0x25, 0xe0, 0x41, 0x05, 0xfa, 0x41, 0x1f, 0x0a, 0x1d, 472 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 473 0x70, 0x69, 0x73, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x52, 0x05, 0x74, 474 0x61, 0x62, 0x6c, 0x65, 0x12, 0x6a, 0x0a, 0x0f, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x5f, 0x6d, 0x6f, 475 0x64, 0x69, 0x66, 0x69, 0x65, 0x72, 0x73, 0x18, 0x07, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x3c, 0x2e, 476 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 477 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 478 0x2e, 0x52, 0x65, 0x61, 0x64, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x2e, 0x54, 0x61, 0x62, 479 0x6c, 0x65, 0x4d, 0x6f, 0x64, 0x69, 0x66, 0x69, 0x65, 0x72, 0x73, 0x42, 0x03, 0xe0, 0x41, 0x01, 480 0x52, 0x0e, 0x74, 0x61, 0x62, 0x6c, 0x65, 0x4d, 0x6f, 0x64, 0x69, 0x66, 0x69, 0x65, 0x72, 0x73, 481 0x12, 0x66, 0x0a, 0x0c, 0x72, 0x65, 0x61, 0x64, 0x5f, 0x6f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 482 0x18, 0x08, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x3e, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 483 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 484 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x52, 0x65, 0x61, 0x64, 0x53, 0x65, 485 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x2e, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x52, 0x65, 0x61, 0x64, 0x4f, 486 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x42, 0x03, 0xe0, 0x41, 0x01, 0x52, 0x0b, 0x72, 0x65, 0x61, 487 0x64, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x4b, 0x0a, 0x07, 0x73, 0x74, 0x72, 0x65, 488 0x61, 0x6d, 0x73, 0x18, 0x0a, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x2c, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 489 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 490 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x52, 0x65, 0x61, 491 0x64, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x07, 0x73, 0x74, 492 0x72, 0x65, 0x61, 0x6d, 0x73, 0x1a, 0x51, 0x0a, 0x0e, 0x54, 0x61, 0x62, 0x6c, 0x65, 0x4d, 0x6f, 493 0x64, 0x69, 0x66, 0x69, 0x65, 0x72, 0x73, 0x12, 0x3f, 0x0a, 0x0d, 0x73, 0x6e, 0x61, 0x70, 0x73, 494 0x68, 0x6f, 0x74, 0x5f, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 495 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 496 0x2e, 0x54, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x52, 0x0c, 0x73, 0x6e, 0x61, 0x70, 497 0x73, 0x68, 0x6f, 0x74, 0x54, 0x69, 0x6d, 0x65, 0x1a, 0x64, 0x0a, 0x10, 0x54, 0x61, 0x62, 0x6c, 498 0x65, 0x52, 0x65, 0x61, 0x64, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x27, 0x0a, 0x0f, 499 0x73, 0x65, 0x6c, 0x65, 0x63, 0x74, 0x65, 0x64, 0x5f, 0x66, 0x69, 0x65, 0x6c, 0x64, 0x73, 0x18, 500 0x01, 0x20, 0x03, 0x28, 0x09, 0x52, 0x0e, 0x73, 0x65, 0x6c, 0x65, 0x63, 0x74, 0x65, 0x64, 0x46, 501 0x69, 0x65, 0x6c, 0x64, 0x73, 0x12, 0x27, 0x0a, 0x0f, 0x72, 0x6f, 0x77, 0x5f, 0x72, 0x65, 0x73, 502 0x74, 0x72, 0x69, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0e, 503 0x72, 0x6f, 0x77, 0x52, 0x65, 0x73, 0x74, 0x72, 0x69, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x3a, 0x6b, 504 0xea, 0x41, 0x68, 0x0a, 0x2a, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x73, 0x74, 0x6f, 505 0x72, 0x61, 0x67, 0x65, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 506 0x63, 0x6f, 0x6d, 0x2f, 0x52, 0x65, 0x61, 0x64, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x12, 507 0x3a, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x7b, 0x70, 0x72, 0x6f, 0x6a, 0x65, 508 0x63, 0x74, 0x7d, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x7b, 0x6c, 509 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x7d, 0x2f, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 510 0x73, 0x2f, 0x7b, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x7d, 0x42, 0x08, 0x0a, 0x06, 0x73, 511 0x63, 0x68, 0x65, 0x6d, 0x61, 0x22, 0xa2, 0x01, 0x0a, 0x0a, 0x52, 0x65, 0x61, 0x64, 0x53, 0x74, 512 0x72, 0x65, 0x61, 0x6d, 0x12, 0x17, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 513 0x28, 0x09, 0x42, 0x03, 0xe0, 0x41, 0x03, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x3a, 0x7b, 0xea, 514 0x41, 0x78, 0x0a, 0x29, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x73, 0x74, 0x6f, 0x72, 515 0x61, 0x67, 0x65, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2e, 0x63, 516 0x6f, 0x6d, 0x2f, 0x52, 0x65, 0x61, 0x64, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x12, 0x4b, 0x70, 517 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 0x73, 0x2f, 0x7b, 0x70, 0x72, 0x6f, 0x6a, 0x65, 0x63, 0x74, 518 0x7d, 0x2f, 0x6c, 0x6f, 0x63, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x7b, 0x6c, 0x6f, 0x63, 519 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x7d, 0x2f, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 520 0x7b, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x7d, 0x2f, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 521 0x73, 0x2f, 0x7b, 0x73, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x7d, 0x2a, 0x3e, 0x0a, 0x0a, 0x44, 0x61, 522 0x74, 0x61, 0x46, 0x6f, 0x72, 0x6d, 0x61, 0x74, 0x12, 0x1b, 0x0a, 0x17, 0x44, 0x41, 0x54, 0x41, 523 0x5f, 0x46, 0x4f, 0x52, 0x4d, 0x41, 0x54, 0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 524 0x49, 0x45, 0x44, 0x10, 0x00, 0x12, 0x08, 0x0a, 0x04, 0x41, 0x56, 0x52, 0x4f, 0x10, 0x01, 0x12, 525 0x09, 0x0a, 0x05, 0x41, 0x52, 0x52, 0x4f, 0x57, 0x10, 0x02, 0x42, 0xc4, 0x01, 0x0a, 0x24, 0x63, 526 0x6f, 0x6d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 527 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 528 0x2e, 0x76, 0x31, 0x42, 0x0b, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x50, 0x72, 0x6f, 0x74, 0x6f, 529 0x50, 0x01, 0x5a, 0x47, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x67, 0x6f, 0x6c, 0x61, 0x6e, 530 0x67, 0x2e, 0x6f, 0x72, 0x67, 0x2f, 0x67, 0x65, 0x6e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x67, 531 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 532 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 533 0x2f, 0x76, 0x31, 0x3b, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0xaa, 0x02, 0x20, 0x47, 0x6f, 534 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x43, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x42, 0x69, 0x67, 0x51, 0x75, 535 0x65, 0x72, 0x79, 0x2e, 0x53, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x56, 0x31, 0xca, 0x02, 536 0x20, 0x47, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x5c, 0x43, 0x6c, 0x6f, 0x75, 0x64, 0x5c, 0x42, 0x69, 537 0x67, 0x51, 0x75, 0x65, 0x72, 0x79, 0x5c, 0x53, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x5c, 0x56, 538 0x31, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, 539} 540 541var ( 542 file_google_cloud_bigquery_storage_v1_stream_proto_rawDescOnce sync.Once 543 file_google_cloud_bigquery_storage_v1_stream_proto_rawDescData = file_google_cloud_bigquery_storage_v1_stream_proto_rawDesc 544) 545 546func file_google_cloud_bigquery_storage_v1_stream_proto_rawDescGZIP() []byte { 547 file_google_cloud_bigquery_storage_v1_stream_proto_rawDescOnce.Do(func() { 548 file_google_cloud_bigquery_storage_v1_stream_proto_rawDescData = protoimpl.X.CompressGZIP(file_google_cloud_bigquery_storage_v1_stream_proto_rawDescData) 549 }) 550 return file_google_cloud_bigquery_storage_v1_stream_proto_rawDescData 551} 552 553var file_google_cloud_bigquery_storage_v1_stream_proto_enumTypes = make([]protoimpl.EnumInfo, 1) 554var file_google_cloud_bigquery_storage_v1_stream_proto_msgTypes = make([]protoimpl.MessageInfo, 4) 555var file_google_cloud_bigquery_storage_v1_stream_proto_goTypes = []interface{}{ 556 (DataFormat)(0), // 0: google.cloud.bigquery.storage.v1.DataFormat 557 (*ReadSession)(nil), // 1: google.cloud.bigquery.storage.v1.ReadSession 558 (*ReadStream)(nil), // 2: google.cloud.bigquery.storage.v1.ReadStream 559 (*ReadSession_TableModifiers)(nil), // 3: google.cloud.bigquery.storage.v1.ReadSession.TableModifiers 560 (*ReadSession_TableReadOptions)(nil), // 4: google.cloud.bigquery.storage.v1.ReadSession.TableReadOptions 561 (*timestamppb.Timestamp)(nil), // 5: google.protobuf.Timestamp 562 (*AvroSchema)(nil), // 6: google.cloud.bigquery.storage.v1.AvroSchema 563 (*ArrowSchema)(nil), // 7: google.cloud.bigquery.storage.v1.ArrowSchema 564} 565var file_google_cloud_bigquery_storage_v1_stream_proto_depIdxs = []int32{ 566 5, // 0: google.cloud.bigquery.storage.v1.ReadSession.expire_time:type_name -> google.protobuf.Timestamp 567 0, // 1: google.cloud.bigquery.storage.v1.ReadSession.data_format:type_name -> google.cloud.bigquery.storage.v1.DataFormat 568 6, // 2: google.cloud.bigquery.storage.v1.ReadSession.avro_schema:type_name -> google.cloud.bigquery.storage.v1.AvroSchema 569 7, // 3: google.cloud.bigquery.storage.v1.ReadSession.arrow_schema:type_name -> google.cloud.bigquery.storage.v1.ArrowSchema 570 3, // 4: google.cloud.bigquery.storage.v1.ReadSession.table_modifiers:type_name -> google.cloud.bigquery.storage.v1.ReadSession.TableModifiers 571 4, // 5: google.cloud.bigquery.storage.v1.ReadSession.read_options:type_name -> google.cloud.bigquery.storage.v1.ReadSession.TableReadOptions 572 2, // 6: google.cloud.bigquery.storage.v1.ReadSession.streams:type_name -> google.cloud.bigquery.storage.v1.ReadStream 573 5, // 7: google.cloud.bigquery.storage.v1.ReadSession.TableModifiers.snapshot_time:type_name -> google.protobuf.Timestamp 574 8, // [8:8] is the sub-list for method output_type 575 8, // [8:8] is the sub-list for method input_type 576 8, // [8:8] is the sub-list for extension type_name 577 8, // [8:8] is the sub-list for extension extendee 578 0, // [0:8] is the sub-list for field type_name 579} 580 581func init() { file_google_cloud_bigquery_storage_v1_stream_proto_init() } 582func file_google_cloud_bigquery_storage_v1_stream_proto_init() { 583 if File_google_cloud_bigquery_storage_v1_stream_proto != nil { 584 return 585 } 586 file_google_cloud_bigquery_storage_v1_arrow_proto_init() 587 file_google_cloud_bigquery_storage_v1_avro_proto_init() 588 if !protoimpl.UnsafeEnabled { 589 file_google_cloud_bigquery_storage_v1_stream_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { 590 switch v := v.(*ReadSession); i { 591 case 0: 592 return &v.state 593 case 1: 594 return &v.sizeCache 595 case 2: 596 return &v.unknownFields 597 default: 598 return nil 599 } 600 } 601 file_google_cloud_bigquery_storage_v1_stream_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { 602 switch v := v.(*ReadStream); i { 603 case 0: 604 return &v.state 605 case 1: 606 return &v.sizeCache 607 case 2: 608 return &v.unknownFields 609 default: 610 return nil 611 } 612 } 613 file_google_cloud_bigquery_storage_v1_stream_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { 614 switch v := v.(*ReadSession_TableModifiers); i { 615 case 0: 616 return &v.state 617 case 1: 618 return &v.sizeCache 619 case 2: 620 return &v.unknownFields 621 default: 622 return nil 623 } 624 } 625 file_google_cloud_bigquery_storage_v1_stream_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { 626 switch v := v.(*ReadSession_TableReadOptions); i { 627 case 0: 628 return &v.state 629 case 1: 630 return &v.sizeCache 631 case 2: 632 return &v.unknownFields 633 default: 634 return nil 635 } 636 } 637 } 638 file_google_cloud_bigquery_storage_v1_stream_proto_msgTypes[0].OneofWrappers = []interface{}{ 639 (*ReadSession_AvroSchema)(nil), 640 (*ReadSession_ArrowSchema)(nil), 641 } 642 type x struct{} 643 out := protoimpl.TypeBuilder{ 644 File: protoimpl.DescBuilder{ 645 GoPackagePath: reflect.TypeOf(x{}).PkgPath(), 646 RawDescriptor: file_google_cloud_bigquery_storage_v1_stream_proto_rawDesc, 647 NumEnums: 1, 648 NumMessages: 4, 649 NumExtensions: 0, 650 NumServices: 0, 651 }, 652 GoTypes: file_google_cloud_bigquery_storage_v1_stream_proto_goTypes, 653 DependencyIndexes: file_google_cloud_bigquery_storage_v1_stream_proto_depIdxs, 654 EnumInfos: file_google_cloud_bigquery_storage_v1_stream_proto_enumTypes, 655 MessageInfos: file_google_cloud_bigquery_storage_v1_stream_proto_msgTypes, 656 }.Build() 657 File_google_cloud_bigquery_storage_v1_stream_proto = out.File 658 file_google_cloud_bigquery_storage_v1_stream_proto_rawDesc = nil 659 file_google_cloud_bigquery_storage_v1_stream_proto_goTypes = nil 660 file_google_cloud_bigquery_storage_v1_stream_proto_depIdxs = nil 661} 662