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