1// Copyright 2020 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.25.0 18// protoc v3.13.0 19// source: google/cloud/bigquery/storage/v1beta1/arrow.proto 20 21package storage 22 23import ( 24 reflect "reflect" 25 sync "sync" 26 27 proto "github.com/golang/protobuf/proto" 28 protoreflect "google.golang.org/protobuf/reflect/protoreflect" 29 protoimpl "google.golang.org/protobuf/runtime/protoimpl" 30) 31 32const ( 33 // Verify that this generated code is sufficiently up-to-date. 34 _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) 35 // Verify that runtime/protoimpl is sufficiently up-to-date. 36 _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) 37) 38 39// This is a compile-time assertion that a sufficiently up-to-date version 40// of the legacy proto package is being used. 41const _ = proto.ProtoPackageIsVersion4 42 43// Arrow schema. 44type ArrowSchema struct { 45 state protoimpl.MessageState 46 sizeCache protoimpl.SizeCache 47 unknownFields protoimpl.UnknownFields 48 49 // IPC serialized Arrow schema. 50 SerializedSchema []byte `protobuf:"bytes,1,opt,name=serialized_schema,json=serializedSchema,proto3" json:"serialized_schema,omitempty"` 51} 52 53func (x *ArrowSchema) Reset() { 54 *x = ArrowSchema{} 55 if protoimpl.UnsafeEnabled { 56 mi := &file_google_cloud_bigquery_storage_v1beta1_arrow_proto_msgTypes[0] 57 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 58 ms.StoreMessageInfo(mi) 59 } 60} 61 62func (x *ArrowSchema) String() string { 63 return protoimpl.X.MessageStringOf(x) 64} 65 66func (*ArrowSchema) ProtoMessage() {} 67 68func (x *ArrowSchema) ProtoReflect() protoreflect.Message { 69 mi := &file_google_cloud_bigquery_storage_v1beta1_arrow_proto_msgTypes[0] 70 if protoimpl.UnsafeEnabled && x != nil { 71 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 72 if ms.LoadMessageInfo() == nil { 73 ms.StoreMessageInfo(mi) 74 } 75 return ms 76 } 77 return mi.MessageOf(x) 78} 79 80// Deprecated: Use ArrowSchema.ProtoReflect.Descriptor instead. 81func (*ArrowSchema) Descriptor() ([]byte, []int) { 82 return file_google_cloud_bigquery_storage_v1beta1_arrow_proto_rawDescGZIP(), []int{0} 83} 84 85func (x *ArrowSchema) GetSerializedSchema() []byte { 86 if x != nil { 87 return x.SerializedSchema 88 } 89 return nil 90} 91 92// Arrow RecordBatch. 93type ArrowRecordBatch struct { 94 state protoimpl.MessageState 95 sizeCache protoimpl.SizeCache 96 unknownFields protoimpl.UnknownFields 97 98 // IPC serialized Arrow RecordBatch. 99 SerializedRecordBatch []byte `protobuf:"bytes,1,opt,name=serialized_record_batch,json=serializedRecordBatch,proto3" json:"serialized_record_batch,omitempty"` 100 // The count of rows in the returning block. 101 RowCount int64 `protobuf:"varint,2,opt,name=row_count,json=rowCount,proto3" json:"row_count,omitempty"` 102} 103 104func (x *ArrowRecordBatch) Reset() { 105 *x = ArrowRecordBatch{} 106 if protoimpl.UnsafeEnabled { 107 mi := &file_google_cloud_bigquery_storage_v1beta1_arrow_proto_msgTypes[1] 108 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 109 ms.StoreMessageInfo(mi) 110 } 111} 112 113func (x *ArrowRecordBatch) String() string { 114 return protoimpl.X.MessageStringOf(x) 115} 116 117func (*ArrowRecordBatch) ProtoMessage() {} 118 119func (x *ArrowRecordBatch) ProtoReflect() protoreflect.Message { 120 mi := &file_google_cloud_bigquery_storage_v1beta1_arrow_proto_msgTypes[1] 121 if protoimpl.UnsafeEnabled && x != nil { 122 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) 123 if ms.LoadMessageInfo() == nil { 124 ms.StoreMessageInfo(mi) 125 } 126 return ms 127 } 128 return mi.MessageOf(x) 129} 130 131// Deprecated: Use ArrowRecordBatch.ProtoReflect.Descriptor instead. 132func (*ArrowRecordBatch) Descriptor() ([]byte, []int) { 133 return file_google_cloud_bigquery_storage_v1beta1_arrow_proto_rawDescGZIP(), []int{1} 134} 135 136func (x *ArrowRecordBatch) GetSerializedRecordBatch() []byte { 137 if x != nil { 138 return x.SerializedRecordBatch 139 } 140 return nil 141} 142 143func (x *ArrowRecordBatch) GetRowCount() int64 { 144 if x != nil { 145 return x.RowCount 146 } 147 return 0 148} 149 150var File_google_cloud_bigquery_storage_v1beta1_arrow_proto protoreflect.FileDescriptor 151 152var file_google_cloud_bigquery_storage_v1beta1_arrow_proto_rawDesc = []byte{ 153 0x0a, 0x31, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x62, 154 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2f, 155 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2f, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x2e, 0x70, 0x72, 156 0x6f, 0x74, 0x6f, 0x12, 0x25, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 157 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 158 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x22, 0x3a, 0x0a, 0x0b, 0x41, 0x72, 159 0x72, 0x6f, 0x77, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x12, 0x2b, 0x0a, 0x11, 0x73, 0x65, 0x72, 160 0x69, 0x61, 0x6c, 0x69, 0x7a, 0x65, 0x64, 0x5f, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x18, 0x01, 161 0x20, 0x01, 0x28, 0x0c, 0x52, 0x10, 0x73, 0x65, 0x72, 0x69, 0x61, 0x6c, 0x69, 0x7a, 0x65, 0x64, 162 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x22, 0x67, 0x0a, 0x10, 0x41, 0x72, 0x72, 0x6f, 0x77, 0x52, 163 0x65, 0x63, 0x6f, 0x72, 0x64, 0x42, 0x61, 0x74, 0x63, 0x68, 0x12, 0x36, 0x0a, 0x17, 0x73, 0x65, 164 0x72, 0x69, 0x61, 0x6c, 0x69, 0x7a, 0x65, 0x64, 0x5f, 0x72, 0x65, 0x63, 0x6f, 0x72, 0x64, 0x5f, 165 0x62, 0x61, 0x74, 0x63, 0x68, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x15, 0x73, 0x65, 0x72, 166 0x69, 0x61, 0x6c, 0x69, 0x7a, 0x65, 0x64, 0x52, 0x65, 0x63, 0x6f, 0x72, 0x64, 0x42, 0x61, 0x74, 167 0x63, 0x68, 0x12, 0x1b, 0x0a, 0x09, 0x72, 0x6f, 0x77, 0x5f, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x18, 168 0x02, 0x20, 0x01, 0x28, 0x03, 0x52, 0x08, 0x72, 0x6f, 0x77, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x42, 169 0x85, 0x01, 0x0a, 0x29, 0x63, 0x6f, 0x6d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 170 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 171 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x42, 0x0a, 0x41, 172 0x72, 0x72, 0x6f, 0x77, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x5a, 0x4c, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 173 0x65, 0x2e, 0x67, 0x6f, 0x6c, 0x61, 0x6e, 0x67, 0x2e, 0x6f, 0x72, 0x67, 0x2f, 0x67, 0x65, 0x6e, 174 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x61, 0x70, 0x69, 0x73, 175 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2f, 176 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2f, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x3b, 177 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, 178} 179 180var ( 181 file_google_cloud_bigquery_storage_v1beta1_arrow_proto_rawDescOnce sync.Once 182 file_google_cloud_bigquery_storage_v1beta1_arrow_proto_rawDescData = file_google_cloud_bigquery_storage_v1beta1_arrow_proto_rawDesc 183) 184 185func file_google_cloud_bigquery_storage_v1beta1_arrow_proto_rawDescGZIP() []byte { 186 file_google_cloud_bigquery_storage_v1beta1_arrow_proto_rawDescOnce.Do(func() { 187 file_google_cloud_bigquery_storage_v1beta1_arrow_proto_rawDescData = protoimpl.X.CompressGZIP(file_google_cloud_bigquery_storage_v1beta1_arrow_proto_rawDescData) 188 }) 189 return file_google_cloud_bigquery_storage_v1beta1_arrow_proto_rawDescData 190} 191 192var file_google_cloud_bigquery_storage_v1beta1_arrow_proto_msgTypes = make([]protoimpl.MessageInfo, 2) 193var file_google_cloud_bigquery_storage_v1beta1_arrow_proto_goTypes = []interface{}{ 194 (*ArrowSchema)(nil), // 0: google.cloud.bigquery.storage.v1beta1.ArrowSchema 195 (*ArrowRecordBatch)(nil), // 1: google.cloud.bigquery.storage.v1beta1.ArrowRecordBatch 196} 197var file_google_cloud_bigquery_storage_v1beta1_arrow_proto_depIdxs = []int32{ 198 0, // [0:0] is the sub-list for method output_type 199 0, // [0:0] is the sub-list for method input_type 200 0, // [0:0] is the sub-list for extension type_name 201 0, // [0:0] is the sub-list for extension extendee 202 0, // [0:0] is the sub-list for field type_name 203} 204 205func init() { file_google_cloud_bigquery_storage_v1beta1_arrow_proto_init() } 206func file_google_cloud_bigquery_storage_v1beta1_arrow_proto_init() { 207 if File_google_cloud_bigquery_storage_v1beta1_arrow_proto != nil { 208 return 209 } 210 if !protoimpl.UnsafeEnabled { 211 file_google_cloud_bigquery_storage_v1beta1_arrow_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { 212 switch v := v.(*ArrowSchema); i { 213 case 0: 214 return &v.state 215 case 1: 216 return &v.sizeCache 217 case 2: 218 return &v.unknownFields 219 default: 220 return nil 221 } 222 } 223 file_google_cloud_bigquery_storage_v1beta1_arrow_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { 224 switch v := v.(*ArrowRecordBatch); i { 225 case 0: 226 return &v.state 227 case 1: 228 return &v.sizeCache 229 case 2: 230 return &v.unknownFields 231 default: 232 return nil 233 } 234 } 235 } 236 type x struct{} 237 out := protoimpl.TypeBuilder{ 238 File: protoimpl.DescBuilder{ 239 GoPackagePath: reflect.TypeOf(x{}).PkgPath(), 240 RawDescriptor: file_google_cloud_bigquery_storage_v1beta1_arrow_proto_rawDesc, 241 NumEnums: 0, 242 NumMessages: 2, 243 NumExtensions: 0, 244 NumServices: 0, 245 }, 246 GoTypes: file_google_cloud_bigquery_storage_v1beta1_arrow_proto_goTypes, 247 DependencyIndexes: file_google_cloud_bigquery_storage_v1beta1_arrow_proto_depIdxs, 248 MessageInfos: file_google_cloud_bigquery_storage_v1beta1_arrow_proto_msgTypes, 249 }.Build() 250 File_google_cloud_bigquery_storage_v1beta1_arrow_proto = out.File 251 file_google_cloud_bigquery_storage_v1beta1_arrow_proto_rawDesc = nil 252 file_google_cloud_bigquery_storage_v1beta1_arrow_proto_goTypes = nil 253 file_google_cloud_bigquery_storage_v1beta1_arrow_proto_depIdxs = nil 254} 255