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_v1beta1_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_v1beta1_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_v1beta1_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 RowCount int64 `protobuf:"varint,2,opt,name=row_count,json=rowCount,proto3" json:"row_count,omitempty"`
98 }
99
100 func (x *AvroRows) Reset() {
101 *x = AvroRows{}
102 if protoimpl.UnsafeEnabled {
103 mi := &file_google_cloud_bigquery_storage_v1beta1_avro_proto_msgTypes[1]
104 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
105 ms.StoreMessageInfo(mi)
106 }
107 }
108
109 func (x *AvroRows) String() string {
110 return protoimpl.X.MessageStringOf(x)
111 }
112
113 func (*AvroRows) ProtoMessage() {}
114
115 func (x *AvroRows) ProtoReflect() protoreflect.Message {
116 mi := &file_google_cloud_bigquery_storage_v1beta1_avro_proto_msgTypes[1]
117 if protoimpl.UnsafeEnabled && x != nil {
118 ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
119 if ms.LoadMessageInfo() == nil {
120 ms.StoreMessageInfo(mi)
121 }
122 return ms
123 }
124 return mi.MessageOf(x)
125 }
126
127
128 func (*AvroRows) Descriptor() ([]byte, []int) {
129 return file_google_cloud_bigquery_storage_v1beta1_avro_proto_rawDescGZIP(), []int{1}
130 }
131
132 func (x *AvroRows) GetSerializedBinaryRows() []byte {
133 if x != nil {
134 return x.SerializedBinaryRows
135 }
136 return nil
137 }
138
139 func (x *AvroRows) GetRowCount() int64 {
140 if x != nil {
141 return x.RowCount
142 }
143 return 0
144 }
145
146 var File_google_cloud_bigquery_storage_v1beta1_avro_proto protoreflect.FileDescriptor
147
148 var file_google_cloud_bigquery_storage_v1beta1_avro_proto_rawDesc = []byte{
149 0x0a, 0x30, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2f, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2f, 0x62,
150 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2f,
151 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2f, 0x61, 0x76, 0x72, 0x6f, 0x2e, 0x70, 0x72, 0x6f,
152 0x74, 0x6f, 0x12, 0x25, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f, 0x75, 0x64,
153 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67,
154 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x22, 0x24, 0x0a, 0x0a, 0x41, 0x76, 0x72,
155 0x6f, 0x53, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x12, 0x16, 0x0a, 0x06, 0x73, 0x63, 0x68, 0x65, 0x6d,
156 0x61, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x73, 0x63, 0x68, 0x65, 0x6d, 0x61, 0x22,
157 0x5d, 0x0a, 0x08, 0x41, 0x76, 0x72, 0x6f, 0x52, 0x6f, 0x77, 0x73, 0x12, 0x34, 0x0a, 0x16, 0x73,
158 0x65, 0x72, 0x69, 0x61, 0x6c, 0x69, 0x7a, 0x65, 0x64, 0x5f, 0x62, 0x69, 0x6e, 0x61, 0x72, 0x79,
159 0x5f, 0x72, 0x6f, 0x77, 0x73, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x14, 0x73, 0x65, 0x72,
160 0x69, 0x61, 0x6c, 0x69, 0x7a, 0x65, 0x64, 0x42, 0x69, 0x6e, 0x61, 0x72, 0x79, 0x52, 0x6f, 0x77,
161 0x73, 0x12, 0x1b, 0x0a, 0x09, 0x72, 0x6f, 0x77, 0x5f, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x18, 0x02,
162 0x20, 0x01, 0x28, 0x03, 0x52, 0x08, 0x72, 0x6f, 0x77, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x42, 0x7b,
163 0x0a, 0x29, 0x63, 0x6f, 0x6d, 0x2e, 0x67, 0x6f, 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6c, 0x6f,
164 0x75, 0x64, 0x2e, 0x62, 0x69, 0x67, 0x71, 0x75, 0x65, 0x72, 0x79, 0x2e, 0x73, 0x74, 0x6f, 0x72,
165 0x61, 0x67, 0x65, 0x2e, 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x42, 0x09, 0x41, 0x76, 0x72,
166 0x6f, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x5a, 0x43, 0x63, 0x6c, 0x6f, 0x75, 0x64, 0x2e, 0x67, 0x6f,
167 0x6f, 0x67, 0x6c, 0x65, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x67, 0x6f, 0x2f, 0x62, 0x69, 0x67, 0x71,
168 0x75, 0x65, 0x72, 0x79, 0x2f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x2f, 0x61, 0x70, 0x69,
169 0x76, 0x31, 0x62, 0x65, 0x74, 0x61, 0x31, 0x2f, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x70,
170 0x62, 0x3b, 0x73, 0x74, 0x6f, 0x72, 0x61, 0x67, 0x65, 0x70, 0x62, 0x62, 0x06, 0x70, 0x72, 0x6f,
171 0x74, 0x6f, 0x33,
172 }
173
174 var (
175 file_google_cloud_bigquery_storage_v1beta1_avro_proto_rawDescOnce sync.Once
176 file_google_cloud_bigquery_storage_v1beta1_avro_proto_rawDescData = file_google_cloud_bigquery_storage_v1beta1_avro_proto_rawDesc
177 )
178
179 func file_google_cloud_bigquery_storage_v1beta1_avro_proto_rawDescGZIP() []byte {
180 file_google_cloud_bigquery_storage_v1beta1_avro_proto_rawDescOnce.Do(func() {
181 file_google_cloud_bigquery_storage_v1beta1_avro_proto_rawDescData = protoimpl.X.CompressGZIP(file_google_cloud_bigquery_storage_v1beta1_avro_proto_rawDescData)
182 })
183 return file_google_cloud_bigquery_storage_v1beta1_avro_proto_rawDescData
184 }
185
186 var file_google_cloud_bigquery_storage_v1beta1_avro_proto_msgTypes = make([]protoimpl.MessageInfo, 2)
187 var file_google_cloud_bigquery_storage_v1beta1_avro_proto_goTypes = []interface{}{
188 (*AvroSchema)(nil),
189 (*AvroRows)(nil),
190 }
191 var file_google_cloud_bigquery_storage_v1beta1_avro_proto_depIdxs = []int32{
192 0,
193 0,
194 0,
195 0,
196 0,
197 }
198
199 func init() { file_google_cloud_bigquery_storage_v1beta1_avro_proto_init() }
200 func file_google_cloud_bigquery_storage_v1beta1_avro_proto_init() {
201 if File_google_cloud_bigquery_storage_v1beta1_avro_proto != nil {
202 return
203 }
204 if !protoimpl.UnsafeEnabled {
205 file_google_cloud_bigquery_storage_v1beta1_avro_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
206 switch v := v.(*AvroSchema); i {
207 case 0:
208 return &v.state
209 case 1:
210 return &v.sizeCache
211 case 2:
212 return &v.unknownFields
213 default:
214 return nil
215 }
216 }
217 file_google_cloud_bigquery_storage_v1beta1_avro_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
218 switch v := v.(*AvroRows); i {
219 case 0:
220 return &v.state
221 case 1:
222 return &v.sizeCache
223 case 2:
224 return &v.unknownFields
225 default:
226 return nil
227 }
228 }
229 }
230 type x struct{}
231 out := protoimpl.TypeBuilder{
232 File: protoimpl.DescBuilder{
233 GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
234 RawDescriptor: file_google_cloud_bigquery_storage_v1beta1_avro_proto_rawDesc,
235 NumEnums: 0,
236 NumMessages: 2,
237 NumExtensions: 0,
238 NumServices: 0,
239 },
240 GoTypes: file_google_cloud_bigquery_storage_v1beta1_avro_proto_goTypes,
241 DependencyIndexes: file_google_cloud_bigquery_storage_v1beta1_avro_proto_depIdxs,
242 MessageInfos: file_google_cloud_bigquery_storage_v1beta1_avro_proto_msgTypes,
243 }.Build()
244 File_google_cloud_bigquery_storage_v1beta1_avro_proto = out.File
245 file_google_cloud_bigquery_storage_v1beta1_avro_proto_rawDesc = nil
246 file_google_cloud_bigquery_storage_v1beta1_avro_proto_goTypes = nil
247 file_google_cloud_bigquery_storage_v1beta1_avro_proto_depIdxs = nil
248 }
249
View as plain text