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 AvroSchema struct {
40 state protoimpl.MessageState
41 sizeCache protoimpl.SizeCache
42 unknownFields protoimpl.UnknownFields
43
44
45
46 Schema string `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"`
47 }
48
49 func (x *AvroSchema) Reset() {
50 *x = AvroSchema{}
51 if protoimpl.UnsafeEnabled {
52 mi := &file_google_cloud_bigquery_storage_v1beta2_avro_proto_msgTypes[0]
53 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
54 ms.StoreMessageInfo(mi)
55 }
56 }
57
58 func (x *AvroSchema) String() string {
59 return protoimpl.X.MessageStringOf(x)
60 }
61
62 func (*AvroSchema) ProtoMessage() {}
63
64 func (x *AvroSchema) ProtoReflect() protoreflect.Message {
65 mi := &file_google_cloud_bigquery_storage_v1beta2_avro_proto_msgTypes[0]
66 if protoimpl.UnsafeEnabled && x != nil {
67 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
68 if ms.LoadMessageInfo() == nil {
69 ms.StoreMessageInfo(mi)
70 }
71 return ms
72 }
73 return mi.MessageOf(x)
74 }
75
76
77 func (*AvroSchema) Descriptor() ([]byte, []int) {
78 return file_google_cloud_bigquery_storage_v1beta2_avro_proto_rawDescGZIP(), []int{0}
79 }
80
81 func (x *AvroSchema) GetSchema() string {
82 if x != nil {
83 return x.Schema
84 }
85 return ""
86 }
87
88
89 type AvroRows struct {
90 state protoimpl.MessageState
91 sizeCache protoimpl.SizeCache
92 unknownFields protoimpl.UnknownFields
93
94
95 SerializedBinaryRows []byte `protobuf:"bytes,1,opt,name=serialized_binary_rows,json=serializedBinaryRows,proto3" json:"serialized_binary_rows,omitempty"`
96 }
97
98 func (x *AvroRows) Reset() {
99 *x = AvroRows{}
100 if protoimpl.UnsafeEnabled {
101 mi := &file_google_cloud_bigquery_storage_v1beta2_avro_proto_msgTypes[1]
102 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
103 ms.StoreMessageInfo(mi)
104 }
105 }
106
107 func (x *AvroRows) String() string {
108 return protoimpl.X.MessageStringOf(x)
109 }
110
111 func (*AvroRows) ProtoMessage() {}
112
113 func (x *AvroRows) ProtoReflect() protoreflect.Message {
114 mi := &file_google_cloud_bigquery_storage_v1beta2_avro_proto_msgTypes[1]
115 if protoimpl.UnsafeEnabled && x != nil {
116 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
117 if ms.LoadMessageInfo() == nil {
118 ms.StoreMessageInfo(mi)
119 }
120 return ms
121 }
122 return mi.MessageOf(x)
123 }
124
125
126 func (*AvroRows) Descriptor() ([]byte, []int) {
127 return file_google_cloud_bigquery_storage_v1beta2_avro_proto_rawDescGZIP(), []int{1}
128 }
129
130 func (x *AvroRows) GetSerializedBinaryRows() []byte {
131 if x != nil {
132 return x.SerializedBinaryRows
133 }
134 return nil
135 }
136
137 var File_google_cloud_bigquery_storage_v1beta2_avro_proto protoreflect.FileDescriptor
138
139 var file_google_cloud_bigquery_storage_v1beta2_avro_proto_rawDesc = []byte{
140 0x0a, 0x30, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x62,
141 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2f,
142 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2f, 0x61, 0x76, 0x72, 0x6f, 0x2e, 0x70, 0x72, 0x6f,
143 0x74, 0x6f, 0x12, 0x25, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64,
144 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67,
145 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x22, 0x24, 0x0a, 0x0a, 0x41, 0x76, 0x72,
146 0x6f, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x12, 0x16, 0x0a, 0x06, 0x73, 0x63, 0x68, 0x65, 0x6d,
147 0x61, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x22,
148 0x40, 0x0a, 0x08, 0x41, 0x76, 0x72, 0x6f, 0x52, 0x6f, 0x77, 0x73, 0x12, 0x34, 0x0a, 0x16, 0x73,
149 0x65, 0x72, 0x69, 0x61, 0x6c, 0x69, 0x7a, 0x65, 0x64, 0x5f, 0x62, 0x69, 0x6e, 0x61, 0x72, 0x79,
150 0x5f, 0x72, 0x6f, 0x77, 0x73, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x14, 0x73, 0x65, 0x72,
151 0x69, 0x61, 0x6c, 0x69, 0x7a, 0x65, 0x64, 0x42, 0x69, 0x6e, 0x61, 0x72, 0x79, 0x52, 0x6f, 0x77,
152 0x73, 0x42, 0x7d, 0x0a, 0x29, 0x63, 0x6f, 0x6d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e,
153 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73,
154 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x42, 0x09,
155 0x41, 0x76, 0x72, 0x6f, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x50, 0x01, 0x5a, 0x43, 0x63, 0x6c, 0x6f,
156 0x75, 0x64, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x67, 0x6f,
157 0x2f, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67,
158 0x65, 0x2f, 0x61, 0x70, 0x69, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x32, 0x2f, 0x73, 0x74, 0x6f,
159 0x72, 0x61, 0x67, 0x65, 0x70, 0x62, 0x3b, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x70, 0x62,
160 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
161 }
162
163 var (
164 file_google_cloud_bigquery_storage_v1beta2_avro_proto_rawDescOnce sync.Once
165 file_google_cloud_bigquery_storage_v1beta2_avro_proto_rawDescData = file_google_cloud_bigquery_storage_v1beta2_avro_proto_rawDesc
166 )
167
168 func file_google_cloud_bigquery_storage_v1beta2_avro_proto_rawDescGZIP() []byte {
169 file_google_cloud_bigquery_storage_v1beta2_avro_proto_rawDescOnce.Do(func() {
170 file_google_cloud_bigquery_storage_v1beta2_avro_proto_rawDescData = protoimpl.X.CompressGZIP(file_google_cloud_bigquery_storage_v1beta2_avro_proto_rawDescData)
171 })
172 return file_google_cloud_bigquery_storage_v1beta2_avro_proto_rawDescData
173 }
174
175 var file_google_cloud_bigquery_storage_v1beta2_avro_proto_msgTypes = make([]protoimpl.MessageInfo, 2)
176 var file_google_cloud_bigquery_storage_v1beta2_avro_proto_goTypes = []interface{}{
177 (*AvroSchema)(nil),
178 (*AvroRows)(nil),
179 }
180 var file_google_cloud_bigquery_storage_v1beta2_avro_proto_depIdxs = []int32{
181 0,
182 0,
183 0,
184 0,
185 0,
186 }
187
188 func init() { file_google_cloud_bigquery_storage_v1beta2_avro_proto_init() }
189 func file_google_cloud_bigquery_storage_v1beta2_avro_proto_init() {
190 if File_google_cloud_bigquery_storage_v1beta2_avro_proto != nil {
191 return
192 }
193 if !protoimpl.UnsafeEnabled {
194 file_google_cloud_bigquery_storage_v1beta2_avro_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
195 switch v := v.(*AvroSchema); i {
196 case 0:
197 return &v.state
198 case 1:
199 return &v.sizeCache
200 case 2:
201 return &v.unknownFields
202 default:
203 return nil
204 }
205 }
206 file_google_cloud_bigquery_storage_v1beta2_avro_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
207 switch v := v.(*AvroRows); 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 }
219 type x struct{}
220 out := protoimpl.TypeBuilder{
221 File: protoimpl.DescBuilder{
222 GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
223 RawDescriptor: file_google_cloud_bigquery_storage_v1beta2_avro_proto_rawDesc,
224 NumEnums: 0,
225 NumMessages: 2,
226 NumExtensions: 0,
227 NumServices: 0,
228 },
229 GoTypes: file_google_cloud_bigquery_storage_v1beta2_avro_proto_goTypes,
230 DependencyIndexes: file_google_cloud_bigquery_storage_v1beta2_avro_proto_depIdxs,
231 MessageInfos: file_google_cloud_bigquery_storage_v1beta2_avro_proto_msgTypes,
232 }.Build()
233 File_google_cloud_bigquery_storage_v1beta2_avro_proto = out.File
234 file_google_cloud_bigquery_storage_v1beta2_avro_proto_rawDesc = nil
235 file_google_cloud_bigquery_storage_v1beta2_avro_proto_goTypes = nil
236 file_google_cloud_bigquery_storage_v1beta2_avro_proto_depIdxs = nil
237 }
238
View as plain text