arrow.pb.go

Documentation: cloud.google.com/go/bigquery/storage/apiv1beta2/storagepb

     1  // Copyright 2021 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/v1beta2/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  // The IPC format to use when serializing Arrow streams.
    39  type ArrowSerializationOptions_Format int32
    40  
    41  const (
    42  	// If unspecied the IPC format as of 0.15 release will be used.
    43  	ArrowSerializationOptions_FORMAT_UNSPECIFIED ArrowSerializationOptions_Format = 0
    44  	// Use the legacy IPC message format as of Apache Arrow Release 0.14.
    45  	ArrowSerializationOptions_ARROW_0_14 ArrowSerializationOptions_Format = 1
    46  	// Use the message format as of Apache Arrow Release 0.15.
    47  	ArrowSerializationOptions_ARROW_0_15 ArrowSerializationOptions_Format = 2
    48  )
    49  
    50  // Enum value maps for ArrowSerializationOptions_Format.
    51  var (
    52  	ArrowSerializationOptions_Format_name = map[int32]string{
    53  		0: "FORMAT_UNSPECIFIED",
    54  		1: "ARROW_0_14",
    55  		2: "ARROW_0_15",
    56  	}
    57  	ArrowSerializationOptions_Format_value = map[string]int32{
    58  		"FORMAT_UNSPECIFIED": 0,
    59  		"ARROW_0_14":         1,
    60  		"ARROW_0_15":         2,
    61  	}
    62  )
    63  
    64  func (x ArrowSerializationOptions_Format) Enum() *ArrowSerializationOptions_Format {
    65  	p := new(ArrowSerializationOptions_Format)
    66  	*p = x
    67  	return p
    68  }
    69  
    70  func (x ArrowSerializationOptions_Format) String() string {
    71  	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
    72  }
    73  
    74  func (ArrowSerializationOptions_Format) Descriptor() protoreflect.EnumDescriptor {
    75  	return file_google_cloud_bigquery_storage_v1beta2_arrow_proto_enumTypes[0].Descriptor()
    76  }
    77  
    78  func (ArrowSerializationOptions_Format) Type() protoreflect.EnumType {
    79  	return &file_google_cloud_bigquery_storage_v1beta2_arrow_proto_enumTypes[0]
    80  }
    81  
    82  func (x ArrowSerializationOptions_Format) Number() protoreflect.EnumNumber {
    83  	return protoreflect.EnumNumber(x)
    84  }
    85  
    86  // Deprecated: Use ArrowSerializationOptions_Format.Descriptor instead.
    87  func (ArrowSerializationOptions_Format) EnumDescriptor() ([]byte, []int) {
    88  	return file_google_cloud_bigquery_storage_v1beta2_arrow_proto_rawDescGZIP(), []int{2, 0}
    89  }
    90  
    91  // Arrow schema as specified in
    92  // https://arrow.apache.org/docs/python/api/datatypes.html
    93  // and serialized to bytes using IPC:
    94  // https://arrow.apache.org/docs/format/Columnar.html#serialization-and-interprocess-communication-ipc
    95  //
    96  // See code samples on how this message can be deserialized.
    97  type ArrowSchema struct {
    98  	state         protoimpl.MessageState
    99  	sizeCache     protoimpl.SizeCache
   100  	unknownFields protoimpl.UnknownFields
   101  
   102  	// IPC serialized Arrow schema.
   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_v1beta2_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_v1beta2_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  // Deprecated: Use ArrowSchema.ProtoReflect.Descriptor instead.
   134  func (*ArrowSchema) Descriptor() ([]byte, []int) {
   135  	return file_google_cloud_bigquery_storage_v1beta2_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  // Arrow RecordBatch.
   146  type ArrowRecordBatch struct {
   147  	state         protoimpl.MessageState
   148  	sizeCache     protoimpl.SizeCache
   149  	unknownFields protoimpl.UnknownFields
   150  
   151  	// IPC-serialized Arrow RecordBatch.
   152  	SerializedRecordBatch []byte `protobuf:"bytes,1,opt,name=serialized_record_batch,json=serializedRecordBatch,proto3" json:"serialized_record_batch,omitempty"`
   153  }
   154  
   155  func (x *ArrowRecordBatch) Reset() {
   156  	*x = ArrowRecordBatch{}
   157  	if protoimpl.UnsafeEnabled {
   158  		mi := &file_google_cloud_bigquery_storage_v1beta2_arrow_proto_msgTypes[1]
   159  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   160  		ms.StoreMessageInfo(mi)
   161  	}
   162  }
   163  
   164  func (x *ArrowRecordBatch) String() string {
   165  	return protoimpl.X.MessageStringOf(x)
   166  }
   167  
   168  func (*ArrowRecordBatch) ProtoMessage() {}
   169  
   170  func (x *ArrowRecordBatch) ProtoReflect() protoreflect.Message {
   171  	mi := &file_google_cloud_bigquery_storage_v1beta2_arrow_proto_msgTypes[1]
   172  	if protoimpl.UnsafeEnabled && x != nil {
   173  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   174  		if ms.LoadMessageInfo() == nil {
   175  			ms.StoreMessageInfo(mi)
   176  		}
   177  		return ms
   178  	}
   179  	return mi.MessageOf(x)
   180  }
   181  
   182  // Deprecated: Use ArrowRecordBatch.ProtoReflect.Descriptor instead.
   183  func (*ArrowRecordBatch) Descriptor() ([]byte, []int) {
   184  	return file_google_cloud_bigquery_storage_v1beta2_arrow_proto_rawDescGZIP(), []int{1}
   185  }
   186  
   187  func (x *ArrowRecordBatch) GetSerializedRecordBatch() []byte {
   188  	if x != nil {
   189  		return x.SerializedRecordBatch
   190  	}
   191  	return nil
   192  }
   193  
   194  // Contains options specific to Arrow Serialization.
   195  type ArrowSerializationOptions struct {
   196  	state         protoimpl.MessageState
   197  	sizeCache     protoimpl.SizeCache
   198  	unknownFields protoimpl.UnknownFields
   199  
   200  	// The Arrow IPC format to use.
   201  	Format ArrowSerializationOptions_Format `protobuf:"varint,1,opt,name=format,proto3,enum=google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptions_Format" json:"format,omitempty"`
   202  }
   203  
   204  func (x *ArrowSerializationOptions) Reset() {
   205  	*x = ArrowSerializationOptions{}
   206  	if protoimpl.UnsafeEnabled {
   207  		mi := &file_google_cloud_bigquery_storage_v1beta2_arrow_proto_msgTypes[2]
   208  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   209  		ms.StoreMessageInfo(mi)
   210  	}
   211  }
   212  
   213  func (x *ArrowSerializationOptions) String() string {
   214  	return protoimpl.X.MessageStringOf(x)
   215  }
   216  
   217  func (*ArrowSerializationOptions) ProtoMessage() {}
   218  
   219  func (x *ArrowSerializationOptions) ProtoReflect() protoreflect.Message {
   220  	mi := &file_google_cloud_bigquery_storage_v1beta2_arrow_proto_msgTypes[2]
   221  	if protoimpl.UnsafeEnabled && x != nil {
   222  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   223  		if ms.LoadMessageInfo() == nil {
   224  			ms.StoreMessageInfo(mi)
   225  		}
   226  		return ms
   227  	}
   228  	return mi.MessageOf(x)
   229  }
   230  
   231  // Deprecated: Use ArrowSerializationOptions.ProtoReflect.Descriptor instead.
   232  func (*ArrowSerializationOptions) Descriptor() ([]byte, []int) {
   233  	return file_google_cloud_bigquery_storage_v1beta2_arrow_proto_rawDescGZIP(), []int{2}
   234  }
   235  
   236  func (x *ArrowSerializationOptions) GetFormat() ArrowSerializationOptions_Format {
   237  	if x != nil {
   238  		return x.Format
   239  	}
   240  	return ArrowSerializationOptions_FORMAT_UNSPECIFIED
   241  }
   242  
   243  var File_google_cloud_bigquery_storage_v1beta2_arrow_proto protoreflect.FileDescriptor
   244  
   245  var file_google_cloud_bigquery_storage_v1beta2_arrow_proto_rawDesc = []byte{
   246  	0x0a, 0x31, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x62,
   247  	0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2f,
   248  	0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2f, 0x61, 0x72, 0x72, 0x6f, 0x77, 0x2e, 0x70, 0x72,
   249  	0x6f, 0x74, 0x6f, 0x12, 0x25, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75,
   250  	0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61,
   251  	0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x22, 0x3a, 0x0a, 0x0b, 0x41, 0x72,
   252  	0x72, 0x6f, 0x77, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x12, 0x2b, 0x0a, 0x11, 0x73, 0x65, 0x72,
   253  	0x69, 0x61, 0x6c, 0x69, 0x7a, 0x65, 0x64, 0x5f, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x18, 0x01,
   254  	0x20, 0x01, 0x28, 0x0c, 0x52, 0x10, 0x73, 0x65, 0x72, 0x69, 0x61, 0x6c, 0x69, 0x7a, 0x65, 0x64,
   255  	0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x22, 0x4a, 0x0a, 0x10, 0x41, 0x72, 0x72, 0x6f, 0x77, 0x52,
   256  	0x65, 0x63, 0x6f, 0x72, 0x64, 0x42, 0x61, 0x74, 0x63, 0x68, 0x12, 0x36, 0x0a, 0x17, 0x73, 0x65,
   257  	0x72, 0x69, 0x61, 0x6c, 0x69, 0x7a, 0x65, 0x64, 0x5f, 0x72, 0x65, 0x63, 0x6f, 0x72, 0x64, 0x5f,
   258  	0x62, 0x61, 0x74, 0x63, 0x68, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x15, 0x73, 0x65, 0x72,
   259  	0x69, 0x61, 0x6c, 0x69, 0x7a, 0x65, 0x64, 0x52, 0x65, 0x63, 0x6f, 0x72, 0x64, 0x42, 0x61, 0x74,
   260  	0x63, 0x68, 0x22, 0xbe, 0x01, 0x0a, 0x19, 0x41, 0x72, 0x72, 0x6f, 0x77, 0x53, 0x65, 0x72, 0x69,
   261  	0x61, 0x6c, 0x69, 0x7a, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73,
   262  	0x12, 0x5f, 0x0a, 0x06, 0x66, 0x6f, 0x72, 0x6d, 0x61, 0x74, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0e,
   263  	0x32, 0x47, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e,
   264  	0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65,
   265  	0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2e, 0x41, 0x72, 0x72, 0x6f, 0x77, 0x53, 0x65,
   266  	0x72, 0x69, 0x61, 0x6c, 0x69, 0x7a, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x4f, 0x70, 0x74, 0x69, 0x6f,
   267  	0x6e, 0x73, 0x2e, 0x46, 0x6f, 0x72, 0x6d, 0x61, 0x74, 0x52, 0x06, 0x66, 0x6f, 0x72, 0x6d, 0x61,
   268  	0x74, 0x22, 0x40, 0x0a, 0x06, 0x46, 0x6f, 0x72, 0x6d, 0x61, 0x74, 0x12, 0x16, 0x0a, 0x12, 0x46,
   269  	0x4f, 0x52, 0x4d, 0x41, 0x54, 0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 0x49, 0x45,
   270  	0x44, 0x10, 0x00, 0x12, 0x0e, 0x0a, 0x0a, 0x41, 0x52, 0x52, 0x4f, 0x57, 0x5f, 0x30, 0x5f, 0x31,
   271  	0x34, 0x10, 0x01, 0x12, 0x0e, 0x0a, 0x0a, 0x41, 0x52, 0x52, 0x4f, 0x57, 0x5f, 0x30, 0x5f, 0x31,
   272  	0x35, 0x10, 0x02, 0x42, 0x7e, 0x0a, 0x29, 0x63, 0x6f, 0x6d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c,
   273  	0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79,
   274  	0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32,
   275  	0x42, 0x0a, 0x41, 0x72, 0x72, 0x6f, 0x77, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x50, 0x01, 0x5a, 0x43,
   276  	0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6f, 0x6d,
   277  	0x2f, 0x67, 0x6f, 0x2f, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2f, 0x73, 0x74, 0x6f,
   278  	0x72, 0x61, 0x67, 0x65, 0x2f, 0x61, 0x70, 0x69, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2f,
   279  	0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x70, 0x62, 0x3b, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67,
   280  	0x65, 0x70, 0x62, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
   281  }
   282  
   283  var (
   284  	file_google_cloud_bigquery_storage_v1beta2_arrow_proto_rawDescOnce sync.Once
   285  	file_google_cloud_bigquery_storage_v1beta2_arrow_proto_rawDescData = file_google_cloud_bigquery_storage_v1beta2_arrow_proto_rawDesc
   286  )
   287  
   288  func file_google_cloud_bigquery_storage_v1beta2_arrow_proto_rawDescGZIP() []byte {
   289  	file_google_cloud_bigquery_storage_v1beta2_arrow_proto_rawDescOnce.Do(func() {
   290  		file_google_cloud_bigquery_storage_v1beta2_arrow_proto_rawDescData = protoimpl.X.CompressGZIP(file_google_cloud_bigquery_storage_v1beta2_arrow_proto_rawDescData)
   291  	})
   292  	return file_google_cloud_bigquery_storage_v1beta2_arrow_proto_rawDescData
   293  }
   294  
   295  var file_google_cloud_bigquery_storage_v1beta2_arrow_proto_enumTypes = make([]protoimpl.EnumInfo, 1)
   296  var file_google_cloud_bigquery_storage_v1beta2_arrow_proto_msgTypes = make([]protoimpl.MessageInfo, 3)
   297  var file_google_cloud_bigquery_storage_v1beta2_arrow_proto_goTypes = []interface{}{
   298  	(ArrowSerializationOptions_Format)(0), // 0: google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptions.Format
   299  	(*ArrowSchema)(nil),                   // 1: google.cloud.bigquery.storage.v1beta2.ArrowSchema
   300  	(*ArrowRecordBatch)(nil),              // 2: google.cloud.bigquery.storage.v1beta2.ArrowRecordBatch
   301  	(*ArrowSerializationOptions)(nil),     // 3: google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptions
   302  }
   303  var file_google_cloud_bigquery_storage_v1beta2_arrow_proto_depIdxs = []int32{
   304  	0, // 0: google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptions.format:type_name -> google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptions.Format
   305  	1, // [1:1] is the sub-list for method output_type
   306  	1, // [1:1] is the sub-list for method input_type
   307  	1, // [1:1] is the sub-list for extension type_name
   308  	1, // [1:1] is the sub-list for extension extendee
   309  	0, // [0:1] is the sub-list for field type_name
   310  }
   311  
   312  func init() { file_google_cloud_bigquery_storage_v1beta2_arrow_proto_init() }
   313  func file_google_cloud_bigquery_storage_v1beta2_arrow_proto_init() {
   314  	if File_google_cloud_bigquery_storage_v1beta2_arrow_proto != nil {
   315  		return
   316  	}
   317  	if !protoimpl.UnsafeEnabled {
   318  		file_google_cloud_bigquery_storage_v1beta2_arrow_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
   319  			switch v := v.(*ArrowSchema); i {
   320  			case 0:
   321  				return &v.state
   322  			case 1:
   323  				return &v.sizeCache
   324  			case 2:
   325  				return &v.unknownFields
   326  			default:
   327  				return nil
   328  			}
   329  		}
   330  		file_google_cloud_bigquery_storage_v1beta2_arrow_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
   331  			switch v := v.(*ArrowRecordBatch); i {
   332  			case 0:
   333  				return &v.state
   334  			case 1:
   335  				return &v.sizeCache
   336  			case 2:
   337  				return &v.unknownFields
   338  			default:
   339  				return nil
   340  			}
   341  		}
   342  		file_google_cloud_bigquery_storage_v1beta2_arrow_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
   343  			switch v := v.(*ArrowSerializationOptions); i {
   344  			case 0:
   345  				return &v.state
   346  			case 1:
   347  				return &v.sizeCache
   348  			case 2:
   349  				return &v.unknownFields
   350  			default:
   351  				return nil
   352  			}
   353  		}
   354  	}
   355  	type x struct{}
   356  	out := protoimpl.TypeBuilder{
   357  		File: protoimpl.DescBuilder{
   358  			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
   359  			RawDescriptor: file_google_cloud_bigquery_storage_v1beta2_arrow_proto_rawDesc,
   360  			NumEnums:      1,
   361  			NumMessages:   3,
   362  			NumExtensions: 0,
   363  			NumServices:   0,
   364  		},
   365  		GoTypes:           file_google_cloud_bigquery_storage_v1beta2_arrow_proto_goTypes,
   366  		DependencyIndexes: file_google_cloud_bigquery_storage_v1beta2_arrow_proto_depIdxs,
   367  		EnumInfos:         file_google_cloud_bigquery_storage_v1beta2_arrow_proto_enumTypes,
   368  		MessageInfos:      file_google_cloud_bigquery_storage_v1beta2_arrow_proto_msgTypes,
   369  	}.Build()
   370  	File_google_cloud_bigquery_storage_v1beta2_arrow_proto = out.File
   371  	file_google_cloud_bigquery_storage_v1beta2_arrow_proto_rawDesc = nil
   372  	file_google_cloud_bigquery_storage_v1beta2_arrow_proto_goTypes = nil
   373  	file_google_cloud_bigquery_storage_v1beta2_arrow_proto_depIdxs = nil
   374  }
   375
View as plain text