1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21 package storagepb
22
23 import (
24 reflect "reflect"
25 sync "sync"
26
27 protoreflect "google.golang.org/protobuf/reflect/protoreflect"
28 protoimpl "google.golang.org/protobuf/runtime/protoimpl"
29 )
30
31 const (
32
33 _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
34
35 _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
36 )
37
38
39 type ArrowSerializationOptions_CompressionCodec int32
40
41 const (
42
43 ArrowSerializationOptions_COMPRESSION_UNSPECIFIED ArrowSerializationOptions_CompressionCodec = 0
44
45 ArrowSerializationOptions_LZ4_FRAME ArrowSerializationOptions_CompressionCodec = 1
46
47 ArrowSerializationOptions_ZSTD ArrowSerializationOptions_CompressionCodec = 2
48 )
49
50
51 var (
52 ArrowSerializationOptions_CompressionCodec_name = map[int32]string{
53 0: "COMPRESSION_UNSPECIFIED",
54 1: "LZ4_FRAME",
55 2: "ZSTD",
56 }
57 ArrowSerializationOptions_CompressionCodec_value = map[string]int32{
58 "COMPRESSION_UNSPECIFIED": 0,
59 "LZ4_FRAME": 1,
60 "ZSTD": 2,
61 }
62 )
63
64 func (x ArrowSerializationOptions_CompressionCodec) Enum() *ArrowSerializationOptions_CompressionCodec {
65 p := new(ArrowSerializationOptions_CompressionCodec)
66 *p = x
67 return p
68 }
69
70 func (x ArrowSerializationOptions_CompressionCodec) String() string {
71 return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
72 }
73
74 func (ArrowSerializationOptions_CompressionCodec) Descriptor() protoreflect.EnumDescriptor {
75 return file_google_cloud_bigquery_storage_v1_arrow_proto_enumTypes[0].Descriptor()
76 }
77
78 func (ArrowSerializationOptions_CompressionCodec) Type() protoreflect.EnumType {
79 return &file_google_cloud_bigquery_storage_v1_arrow_proto_enumTypes[0]
80 }
81
82 func (x ArrowSerializationOptions_CompressionCodec) Number() protoreflect.EnumNumber {
83 return protoreflect.EnumNumber(x)
84 }
85
86
87 func (ArrowSerializationOptions_CompressionCodec) EnumDescriptor() ([]byte, []int) {
88 return file_google_cloud_bigquery_storage_v1_arrow_proto_rawDescGZIP(), []int{2, 0}
89 }
90
91
92
93
94
95
96
97 type ArrowSchema struct {
98 state protoimpl.MessageState
99 sizeCache protoimpl.SizeCache
100 unknownFields protoimpl.UnknownFields
101
102
103 SerializedSchema []byte `protobuf:"bytes,1,opt,name=serialized_schema,json=serializedSchema,proto3" json:"serialized_schema,omitempty"`
104 }
105
106 func (x *ArrowSchema) Reset() {
107 *x = ArrowSchema{}
108 if protoimpl.UnsafeEnabled {
109 mi := &file_google_cloud_bigquery_storage_v1_arrow_proto_msgTypes[0]
110 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
111 ms.StoreMessageInfo(mi)
112 }
113 }
114
115 func (x *ArrowSchema) String() string {
116 return protoimpl.X.MessageStringOf(x)
117 }
118
119 func (*ArrowSchema) ProtoMessage() {}
120
121 func (x *ArrowSchema) ProtoReflect() protoreflect.Message {
122 mi := &file_google_cloud_bigquery_storage_v1_arrow_proto_msgTypes[0]
123 if protoimpl.UnsafeEnabled && x != nil {
124 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
125 if ms.LoadMessageInfo() == nil {
126 ms.StoreMessageInfo(mi)
127 }
128 return ms
129 }
130 return mi.MessageOf(x)
131 }
132
133
134 func (*ArrowSchema) Descriptor() ([]byte, []int) {
135 return file_google_cloud_bigquery_storage_v1_arrow_proto_rawDescGZIP(), []int{0}
136 }
137
138 func (x *ArrowSchema) GetSerializedSchema() []byte {
139 if x != nil {
140 return x.SerializedSchema
141 }
142 return nil
143 }
144
145
146 type ArrowRecordBatch struct {
147 state protoimpl.MessageState
148 sizeCache protoimpl.SizeCache
149 unknownFields protoimpl.UnknownFields
150
151
152 SerializedRecordBatch []byte `protobuf:"bytes,1,opt,name=serialized_record_batch,json=serializedRecordBatch,proto3" json:"serialized_record_batch,omitempty"`
153
154
155
156
157 RowCount int64 `protobuf:"varint,2,opt,name=row_count,json=rowCount,proto3" json:"row_count,omitempty"`
158 }
159
160 func (x *ArrowRecordBatch) Reset() {
161 *x = ArrowRecordBatch{}
162 if protoimpl.UnsafeEnabled {
163 mi := &file_google_cloud_bigquery_storage_v1_arrow_proto_msgTypes[1]
164 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
165 ms.StoreMessageInfo(mi)
166 }
167 }
168
169 func (x *ArrowRecordBatch) String() string {
170 return protoimpl.X.MessageStringOf(x)
171 }
172
173 func (*ArrowRecordBatch) ProtoMessage() {}
174
175 func (x *ArrowRecordBatch) ProtoReflect() protoreflect.Message {
176 mi := &file_google_cloud_bigquery_storage_v1_arrow_proto_msgTypes[1]
177 if protoimpl.UnsafeEnabled && x != nil {
178 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
179 if ms.LoadMessageInfo() == nil {
180 ms.StoreMessageInfo(mi)
181 }
182 return ms
183 }
184 return mi.MessageOf(x)
185 }
186
187
188 func (*ArrowRecordBatch) Descriptor() ([]byte, []int) {
189 return file_google_cloud_bigquery_storage_v1_arrow_proto_rawDescGZIP(), []int{1}
190 }
191
192 func (x *ArrowRecordBatch) GetSerializedRecordBatch() []byte {
193 if x != nil {
194 return x.SerializedRecordBatch
195 }
196 return nil
197 }
198
199
200 func (x *ArrowRecordBatch) GetRowCount() int64 {
201 if x != nil {
202 return x.RowCount
203 }
204 return 0
205 }
206
207
208 type ArrowSerializationOptions struct {
209 state protoimpl.MessageState
210 sizeCache protoimpl.SizeCache
211 unknownFields protoimpl.UnknownFields
212
213
214
215 BufferCompression ArrowSerializationOptions_CompressionCodec `protobuf:"varint,2,opt,name=buffer_compression,json=bufferCompression,proto3,enum=google.cloud.bigquery.storage.v1.ArrowSerializationOptions_CompressionCodec" json:"buffer_compression,omitempty"`
216 }
217
218 func (x *ArrowSerializationOptions) Reset() {
219 *x = ArrowSerializationOptions{}
220 if protoimpl.UnsafeEnabled {
221 mi := &file_google_cloud_bigquery_storage_v1_arrow_proto_msgTypes[2]
222 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
223 ms.StoreMessageInfo(mi)
224 }
225 }
226
227 func (x *ArrowSerializationOptions) String() string {
228 return protoimpl.X.MessageStringOf(x)
229 }
230
231 func (*ArrowSerializationOptions) ProtoMessage() {}
232
233 func (x *ArrowSerializationOptions) ProtoReflect() protoreflect.Message {
234 mi := &file_google_cloud_bigquery_storage_v1_arrow_proto_msgTypes[2]
235 if protoimpl.UnsafeEnabled && x != nil {
236 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
237 if ms.LoadMessageInfo() == nil {
238 ms.StoreMessageInfo(mi)
239 }
240 return ms
241 }
242 return mi.MessageOf(x)
243 }
244
245
246 func (*ArrowSerializationOptions) Descriptor() ([]byte, []int) {
247 return file_google_cloud_bigquery_storage_v1_arrow_proto_rawDescGZIP(), []int{2}
248 }
249
250 func (x *ArrowSerializationOptions) GetBufferCompression() ArrowSerializationOptions_CompressionCodec {
251 if x != nil {
252 return x.BufferCompression
253 }
254 return ArrowSerializationOptions_COMPRESSION_UNSPECIFIED
255 }
256
257 var File_google_cloud_bigquery_storage_v1_arrow_proto protoreflect.FileDescriptor
258
259 var file_google_cloud_bigquery_storage_v1_arrow_proto_rawDesc = []byte{
260 0x0a, 0x2c, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x62,
261 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2f,
262 0x76, 0x31, 0x2f, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x20,
263 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67,
264 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31,
265 0x22, 0x3a, 0x0a, 0x0b, 0x41, 0x72, 0x72, 0x6f, 0x77, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x12,
266 0x2b, 0x0a, 0x11, 0x73, 0x65, 0x72, 0x69, 0x61, 0x6c, 0x69, 0x7a, 0x65, 0x64, 0x5f, 0x73, 0x63,
267 0x68, 0x65, 0x6d, 0x61, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x10, 0x73, 0x65, 0x72, 0x69,
268 0x61, 0x6c, 0x69, 0x7a, 0x65, 0x64, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x22, 0x6b, 0x0a, 0x10,
269 0x41, 0x72, 0x72, 0x6f, 0x77, 0x52, 0x65, 0x63, 0x6f, 0x72, 0x64, 0x42, 0x61, 0x74, 0x63, 0x68,
270 0x12, 0x36, 0x0a, 0x17, 0x73, 0x65, 0x72, 0x69, 0x61, 0x6c, 0x69, 0x7a, 0x65, 0x64, 0x5f, 0x72,
271 0x65, 0x63, 0x6f, 0x72, 0x64, 0x5f, 0x62, 0x61, 0x74, 0x63, 0x68, 0x18, 0x01, 0x20, 0x01, 0x28,
272 0x0c, 0x52, 0x15, 0x73, 0x65, 0x72, 0x69, 0x61, 0x6c, 0x69, 0x7a, 0x65, 0x64, 0x52, 0x65, 0x63,
273 0x6f, 0x72, 0x64, 0x42, 0x61, 0x74, 0x63, 0x68, 0x12, 0x1f, 0x0a, 0x09, 0x72, 0x6f, 0x77, 0x5f,
274 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x03, 0x42, 0x02, 0x18, 0x01, 0x52,
275 0x08, 0x72, 0x6f, 0x77, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x22, 0xe2, 0x01, 0x0a, 0x19, 0x41, 0x72,
276 0x72, 0x6f, 0x77, 0x53, 0x65, 0x72, 0x69, 0x61, 0x6c, 0x69, 0x7a, 0x61, 0x74, 0x69, 0x6f, 0x6e,
277 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x7b, 0x0a, 0x12, 0x62, 0x75, 0x66, 0x66, 0x65,
278 0x72, 0x5f, 0x63, 0x6f, 0x6d, 0x70, 0x72, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x02, 0x20,
279 0x01, 0x28, 0x0e, 0x32, 0x4c, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f,
280 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72,
281 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x2e, 0x41, 0x72, 0x72, 0x6f, 0x77, 0x53, 0x65, 0x72, 0x69,
282 0x61, 0x6c, 0x69, 0x7a, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73,
283 0x2e, 0x43, 0x6f, 0x6d, 0x70, 0x72, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x43, 0x6f, 0x64, 0x65,
284 0x63, 0x52, 0x11, 0x62, 0x75, 0x66, 0x66, 0x65, 0x72, 0x43, 0x6f, 0x6d, 0x70, 0x72, 0x65, 0x73,
285 0x73, 0x69, 0x6f, 0x6e, 0x22, 0x48, 0x0a, 0x10, 0x43, 0x6f, 0x6d, 0x70, 0x72, 0x65, 0x73, 0x73,
286 0x69, 0x6f, 0x6e, 0x43, 0x6f, 0x64, 0x65, 0x63, 0x12, 0x1b, 0x0a, 0x17, 0x43, 0x4f, 0x4d, 0x50,
287 0x52, 0x45, 0x53, 0x53, 0x49, 0x4f, 0x4e, 0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46,
288 0x49, 0x45, 0x44, 0x10, 0x00, 0x12, 0x0d, 0x0a, 0x09, 0x4c, 0x5a, 0x34, 0x5f, 0x46, 0x52, 0x41,
289 0x4d, 0x45, 0x10, 0x01, 0x12, 0x08, 0x0a, 0x04, 0x5a, 0x53, 0x54, 0x44, 0x10, 0x02, 0x42, 0xba,
290 0x01, 0x0a, 0x24, 0x63, 0x6f, 0x6d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c,
291 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f,
292 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x42, 0x0a, 0x41, 0x72, 0x72, 0x6f, 0x77, 0x50, 0x72,
293 0x6f, 0x74, 0x6f, 0x50, 0x01, 0x5a, 0x3e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x67, 0x6f, 0x6f,
294 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x67, 0x6f, 0x2f, 0x62, 0x69, 0x67, 0x71, 0x75,
295 0x65, 0x72, 0x79, 0x2f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x76,
296 0x31, 0x2f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x70, 0x62, 0x3b, 0x73, 0x74, 0x6f, 0x72,
297 0x61, 0x67, 0x65, 0x70, 0x62, 0xaa, 0x02, 0x20, 0x47, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x43,
298 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x42, 0x69, 0x67, 0x51, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x53, 0x74,
299 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x56, 0x31, 0xca, 0x02, 0x20, 0x47, 0x6f, 0x6f, 0x67, 0x6c,
300 0x65, 0x5c, 0x43, 0x6c, 0x6f, 0x75, 0x64, 0x5c, 0x42, 0x69, 0x67, 0x51, 0x75, 0x65, 0x72, 0x79,
301 0x5c, 0x53, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x5c, 0x56, 0x31, 0x62, 0x06, 0x70, 0x72, 0x6f,
302 0x74, 0x6f, 0x33,
303 }
304
305 var (
306 file_google_cloud_bigquery_storage_v1_arrow_proto_rawDescOnce sync.Once
307 file_google_cloud_bigquery_storage_v1_arrow_proto_rawDescData = file_google_cloud_bigquery_storage_v1_arrow_proto_rawDesc
308 )
309
310 func file_google_cloud_bigquery_storage_v1_arrow_proto_rawDescGZIP() []byte {
311 file_google_cloud_bigquery_storage_v1_arrow_proto_rawDescOnce.Do(func() {
312 file_google_cloud_bigquery_storage_v1_arrow_proto_rawDescData = protoimpl.X.CompressGZIP(file_google_cloud_bigquery_storage_v1_arrow_proto_rawDescData)
313 })
314 return file_google_cloud_bigquery_storage_v1_arrow_proto_rawDescData
315 }
316
317 var file_google_cloud_bigquery_storage_v1_arrow_proto_enumTypes = make([]protoimpl.EnumInfo, 1)
318 var file_google_cloud_bigquery_storage_v1_arrow_proto_msgTypes = make([]protoimpl.MessageInfo, 3)
319 var file_google_cloud_bigquery_storage_v1_arrow_proto_goTypes = []interface{}{
320 (ArrowSerializationOptions_CompressionCodec)(0),
321 (*ArrowSchema)(nil),
322 (*ArrowRecordBatch)(nil),
323 (*ArrowSerializationOptions)(nil),
324 }
325 var file_google_cloud_bigquery_storage_v1_arrow_proto_depIdxs = []int32{
326 0,
327 1,
328 1,
329 1,
330 1,
331 0,
332 }
333
334 func init() { file_google_cloud_bigquery_storage_v1_arrow_proto_init() }
335 func file_google_cloud_bigquery_storage_v1_arrow_proto_init() {
336 if File_google_cloud_bigquery_storage_v1_arrow_proto != nil {
337 return
338 }
339 if !protoimpl.UnsafeEnabled {
340 file_google_cloud_bigquery_storage_v1_arrow_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
341 switch v := v.(*ArrowSchema); i {
342 case 0:
343 return &v.state
344 case 1:
345 return &v.sizeCache
346 case 2:
347 return &v.unknownFields
348 default:
349 return nil
350 }
351 }
352 file_google_cloud_bigquery_storage_v1_arrow_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
353 switch v := v.(*ArrowRecordBatch); i {
354 case 0:
355 return &v.state
356 case 1:
357 return &v.sizeCache
358 case 2:
359 return &v.unknownFields
360 default:
361 return nil
362 }
363 }
364 file_google_cloud_bigquery_storage_v1_arrow_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
365 switch v := v.(*ArrowSerializationOptions); i {
366 case 0:
367 return &v.state
368 case 1:
369 return &v.sizeCache
370 case 2:
371 return &v.unknownFields
372 default:
373 return nil
374 }
375 }
376 }
377 type x struct{}
378 out := protoimpl.TypeBuilder{
379 File: protoimpl.DescBuilder{
380 GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
381 RawDescriptor: file_google_cloud_bigquery_storage_v1_arrow_proto_rawDesc,
382 NumEnums: 1,
383 NumMessages: 3,
384 NumExtensions: 0,
385 NumServices: 0,
386 },
387 GoTypes: file_google_cloud_bigquery_storage_v1_arrow_proto_goTypes,
388 DependencyIndexes: file_google_cloud_bigquery_storage_v1_arrow_proto_depIdxs,
389 EnumInfos: file_google_cloud_bigquery_storage_v1_arrow_proto_enumTypes,
390 MessageInfos: file_google_cloud_bigquery_storage_v1_arrow_proto_msgTypes,
391 }.Build()
392 File_google_cloud_bigquery_storage_v1_arrow_proto = out.File
393 file_google_cloud_bigquery_storage_v1_arrow_proto_rawDesc = nil
394 file_google_cloud_bigquery_storage_v1_arrow_proto_goTypes = nil
395 file_google_cloud_bigquery_storage_v1_arrow_proto_depIdxs = nil
396 }
397
View as plain text