Skip to content

Commit f21eded

Browse files
gaojieliugaojieliu
authored
Checkin fast-avro generated codes (#580)
1 parent 00cb0c5 commit f21eded

File tree

102 files changed

+7139
-6348
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

102 files changed

+7139
-6348
lines changed

‎fastserde/avro-fastserde-tests111/build/codegen/java/com/linkedin/avro/fastserde/generated/deserialization/AVRO_1_11/Array_of_TestRecord_SpecificDeserializer_1088113243_1088113243.java‎

Lines changed: 167 additions & 165 deletions
Large diffs are not rendered by default.

‎fastserde/avro-fastserde-tests111/build/codegen/java/com/linkedin/avro/fastserde/generated/deserialization/AVRO_1_11/Array_of_UNION_GenericDeserializer_777827233_777827233.java‎

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -68,31 +68,31 @@ public List<IndexedRecord> deserialize(List<IndexedRecord> reuse, Decoder decode
6868
public IndexedRecord deserializerecord0(Object reuse, Decoder decoder, DatumReaderCustomization customization)
6969
throws IOException
7070
{
71-
IndexedRecord record;
71+
IndexedRecord record0;
7272
if ((((reuse)!= null)&&((reuse) instanceof IndexedRecord))&&(((IndexedRecord)(reuse)).getSchema() == arrayElemOptionSchema0)) {
73-
record = ((IndexedRecord)(reuse));
73+
record0 = ((IndexedRecord)(reuse));
7474
} else {
75-
record = new org.apache.avro.generic.GenericData.Record(arrayElemOptionSchema0);
75+
record0 = new org.apache.avro.generic.GenericData.Record(arrayElemOptionSchema0);
7676
}
7777
int unionIndex1 = (decoder.readIndex());
7878
if (unionIndex1 == 0) {
7979
decoder.readNull();
80-
record.put(0, null);
80+
record0 .put(0, null);
8181
} else {
8282
if (unionIndex1 == 1) {
8383
Utf8 charSequence0;
84-
Object oldString0 = record.get(0);
84+
Object oldString0 = record0 .get(0);
8585
if (oldString0 instanceof Utf8) {
8686
charSequence0 = (decoder).readString(((Utf8) oldString0));
8787
} else {
8888
charSequence0 = (decoder).readString(null);
8989
}
90-
record.put(0, charSequence0);
90+
record0 .put(0, charSequence0);
9191
} else {
9292
throw new RuntimeException(("Illegal union index for 'field': "+ unionIndex1));
9393
}
9494
}
95-
return record;
95+
return record0;
9696
}
9797

9898
}

‎fastserde/avro-fastserde-tests111/build/codegen/java/com/linkedin/avro/fastserde/generated/deserialization/AVRO_1_11/Array_of_UNION_SpecificDeserializer_1277939469_1277939469.java‎

Lines changed: 167 additions & 165 deletions
Large diffs are not rendered by default.

‎fastserde/avro-fastserde-tests111/build/codegen/java/com/linkedin/avro/fastserde/generated/deserialization/AVRO_1_11/Array_of_record_GenericDeserializer_1606337179_2018567528.java‎

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -63,14 +63,14 @@ public List<IndexedRecord> deserialize(List<IndexedRecord> reuse, Decoder decode
6363
public IndexedRecord deserializerecord0(Object reuse, Decoder decoder, DatumReaderCustomization customization)
6464
throws IOException
6565
{
66-
IndexedRecord record;
66+
IndexedRecord record0;
6767
if ((((reuse)!= null)&&((reuse) instanceof IndexedRecord))&&(((IndexedRecord)(reuse)).getSchema() == unionOptionArrayElemSchema0)) {
68-
record = ((IndexedRecord)(reuse));
68+
record0 = ((IndexedRecord)(reuse));
6969
} else {
70-
record = new org.apache.avro.generic.GenericData.Record(unionOptionArrayElemSchema0);
70+
record0 = new org.apache.avro.generic.GenericData.Record(unionOptionArrayElemSchema0);
7171
}
72-
record.put(0, (decoder.readInt()));
73-
return record;
72+
record0 .put(0, (decoder.readInt()));
73+
return record0;
7474
}
7575

7676
}

‎fastserde/avro-fastserde-tests111/build/codegen/java/com/linkedin/avro/fastserde/generated/deserialization/AVRO_1_11/Array_of_record_GenericDeserializer_477614132_477614132.java‎

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -56,31 +56,31 @@ public List<IndexedRecord> deserialize(List<IndexedRecord> reuse, Decoder decode
5656
public IndexedRecord deserializerecord0(Object reuse, Decoder decoder, DatumReaderCustomization customization)
5757
throws IOException
5858
{
59-
IndexedRecord record;
59+
IndexedRecord record0;
6060
if ((((reuse)!= null)&&((reuse) instanceof IndexedRecord))&&(((IndexedRecord)(reuse)).getSchema() == arrayArrayElemSchema0)) {
61-
record = ((IndexedRecord)(reuse));
61+
record0 = ((IndexedRecord)(reuse));
6262
} else {
63-
record = new org.apache.avro.generic.GenericData.Record(arrayArrayElemSchema0);
63+
record0 = new org.apache.avro.generic.GenericData.Record(arrayArrayElemSchema0);
6464
}
6565
int unionIndex0 = (decoder.readIndex());
6666
if (unionIndex0 == 0) {
6767
decoder.readNull();
68-
record.put(0, null);
68+
record0 .put(0, null);
6969
} else {
7070
if (unionIndex0 == 1) {
7171
Utf8 charSequence0;
72-
Object oldString0 = record.get(0);
72+
Object oldString0 = record0 .get(0);
7373
if (oldString0 instanceof Utf8) {
7474
charSequence0 = (decoder).readString(((Utf8) oldString0));
7575
} else {
7676
charSequence0 = (decoder).readString(null);
7777
}
78-
record.put(0, charSequence0);
78+
record0 .put(0, charSequence0);
7979
} else {
8080
throw new RuntimeException(("Illegal union index for 'field': "+ unionIndex0));
8181
}
8282
}
83-
return record;
83+
return record0;
8484
}
8585

8686
}

‎fastserde/avro-fastserde-tests111/build/codegen/java/com/linkedin/avro/fastserde/generated/deserialization/AVRO_1_11/FastGenericDeserializerGeneratorTest_shouldBeAbleToReadVeryLargeSchema_GenericDeserializer_836892732_836892732.java‎

Lines changed: 4006 additions & 4006 deletions
Large diffs are not rendered by default.

‎fastserde/avro-fastserde-tests111/build/codegen/java/com/linkedin/avro/fastserde/generated/deserialization/AVRO_1_11/FastGenericDeserializerGeneratorTest_shouldHandleNullableCorrectly_GenericDeserializer_64996084_522115670.java‎

Lines changed: 148 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,148 @@
1+
2+
package com.linkedin.avro.fastserde.generated.deserialization.AVRO_1_11;
3+
4+
import java.io.IOException;
5+
import java.util.List;
6+
import com.linkedin.avro.fastserde.FastDeserializer;
7+
import com.linkedin.avro.fastserde.customized.DatumReaderCustomization;
8+
import org.apache.avro.Schema;
9+
import org.apache.avro.generic.GenericArray;
10+
import org.apache.avro.generic.IndexedRecord;
11+
import org.apache.avro.io.Decoder;
12+
import org.apache.avro.util.Utf8;
13+
14+
public class FastGenericDeserializerGeneratorTest_shouldHandleNullableCorrectly_GenericDeserializer_64996084_522115670
15+
implements FastDeserializer<IndexedRecord>
16+
{
17+
18+
private final Schema readerSchema;
19+
private final Schema field10;
20+
private final Schema field20;
21+
private final Schema fieldRecordOne0;
22+
private final Schema recordOneRecordSchema0;
23+
private final Schema fieldA0;
24+
private final Schema arrayFieldRecordTwo0;
25+
private final Schema arrayFieldRecordTwoArraySchema0;
26+
private final Schema arrayFieldRecordTwoArrayElemSchema0;
27+
private final Schema recordTwoRecordSchema0;
28+
private final Schema fieldB0;
29+
30+
public FastGenericDeserializerGeneratorTest_shouldHandleNullableCorrectly_GenericDeserializer_64996084_522115670(Schema readerSchema) {
31+
this.readerSchema = readerSchema;
32+
this.field10 = readerSchema.getField("field1").schema();
33+
this.field20 = readerSchema.getField("field2").schema();
34+
this.fieldRecordOne0 = readerSchema.getField("fieldRecordOne").schema();
35+
this.recordOneRecordSchema0 = fieldRecordOne0 .getTypes().get(1);
36+
this.fieldA0 = recordOneRecordSchema0 .getField("fieldA").schema();
37+
this.arrayFieldRecordTwo0 = readerSchema.getField("arrayFieldRecordTwo").schema();
38+
this.arrayFieldRecordTwoArraySchema0 = arrayFieldRecordTwo0 .getTypes().get(1);
39+
this.arrayFieldRecordTwoArrayElemSchema0 = arrayFieldRecordTwoArraySchema0 .getElementType();
40+
this.recordTwoRecordSchema0 = arrayFieldRecordTwoArrayElemSchema0 .getTypes().get(1);
41+
this.fieldB0 = recordTwoRecordSchema0 .getField("fieldB").schema();
42+
}
43+
44+
public IndexedRecord deserialize(IndexedRecord reuse, Decoder decoder, DatumReaderCustomization customization)
45+
throws IOException
46+
{
47+
return deserializeFastGenericDeserializerGeneratorTest_shouldHandleNullableCorrectly0((reuse), (decoder), (customization));
48+
}
49+
50+
public IndexedRecord deserializeFastGenericDeserializerGeneratorTest_shouldHandleNullableCorrectly0(Object reuse, Decoder decoder, DatumReaderCustomization customization)
51+
throws IOException
52+
{
53+
IndexedRecord fastGenericDeserializerGeneratorTest_shouldHandleNullableCorrectly0;
54+
if ((((reuse)!= null)&&((reuse) instanceof IndexedRecord))&&(((IndexedRecord)(reuse)).getSchema() == readerSchema)) {
55+
fastGenericDeserializerGeneratorTest_shouldHandleNullableCorrectly0 = ((IndexedRecord)(reuse));
56+
} else {
57+
fastGenericDeserializerGeneratorTest_shouldHandleNullableCorrectly0 = new org.apache.avro.generic.GenericData.Record(readerSchema);
58+
}
59+
Utf8 charSequence0;
60+
Object oldString0 = fastGenericDeserializerGeneratorTest_shouldHandleNullableCorrectly0 .get(0);
61+
if (oldString0 instanceof Utf8) {
62+
charSequence0 = (decoder).readString(((Utf8) oldString0));
63+
} else {
64+
charSequence0 = (decoder).readString(null);
65+
}
66+
fastGenericDeserializerGeneratorTest_shouldHandleNullableCorrectly0 .put(0, charSequence0);
67+
populate_FastGenericDeserializerGeneratorTest_shouldHandleNullableCorrectly0((fastGenericDeserializerGeneratorTest_shouldHandleNullableCorrectly0), (customization), (decoder));
68+
populate_FastGenericDeserializerGeneratorTest_shouldHandleNullableCorrectly1((fastGenericDeserializerGeneratorTest_shouldHandleNullableCorrectly0), (customization), (decoder));
69+
return fastGenericDeserializerGeneratorTest_shouldHandleNullableCorrectly0;
70+
}
71+
72+
private void populate_FastGenericDeserializerGeneratorTest_shouldHandleNullableCorrectly0(IndexedRecord fastGenericDeserializerGeneratorTest_shouldHandleNullableCorrectly0, DatumReaderCustomization customization, Decoder decoder)
73+
throws IOException
74+
{
75+
fastGenericDeserializerGeneratorTest_shouldHandleNullableCorrectly0 .put(1, (decoder.readDouble()));
76+
fastGenericDeserializerGeneratorTest_shouldHandleNullableCorrectly0 .put(2, deserializerecordOne0(fastGenericDeserializerGeneratorTest_shouldHandleNullableCorrectly0 .get(2), (decoder), (customization)));
77+
}
78+
79+
public IndexedRecord deserializerecordOne0(Object reuse, Decoder decoder, DatumReaderCustomization customization)
80+
throws IOException
81+
{
82+
IndexedRecord recordOne0;
83+
if ((((reuse)!= null)&&((reuse) instanceof IndexedRecord))&&(((IndexedRecord)(reuse)).getSchema() == recordOneRecordSchema0)) {
84+
recordOne0 = ((IndexedRecord)(reuse));
85+
} else {
86+
recordOne0 = new org.apache.avro.generic.GenericData.Record(recordOneRecordSchema0);
87+
}
88+
Utf8 charSequence1;
89+
Object oldString1 = recordOne0 .get(0);
90+
if (oldString1 instanceof Utf8) {
91+
charSequence1 = (decoder).readString(((Utf8) oldString1));
92+
} else {
93+
charSequence1 = (decoder).readString(null);
94+
}
95+
recordOne0 .put(0, charSequence1);
96+
return recordOne0;
97+
}
98+
99+
private void populate_FastGenericDeserializerGeneratorTest_shouldHandleNullableCorrectly1(IndexedRecord fastGenericDeserializerGeneratorTest_shouldHandleNullableCorrectly0, DatumReaderCustomization customization, Decoder decoder)
100+
throws IOException
101+
{
102+
List<IndexedRecord> arrayFieldRecordTwo1 = null;
103+
long chunkLen0 = (decoder.readArrayStart());
104+
Object oldArray0 = fastGenericDeserializerGeneratorTest_shouldHandleNullableCorrectly0 .get(3);
105+
if (oldArray0 instanceof List) {
106+
arrayFieldRecordTwo1 = ((List) oldArray0);
107+
if (arrayFieldRecordTwo1 instanceof GenericArray) {
108+
((GenericArray) arrayFieldRecordTwo1).reset();
109+
} else {
110+
arrayFieldRecordTwo1 .clear();
111+
}
112+
} else {
113+
arrayFieldRecordTwo1 = new org.apache.avro.generic.GenericData.Array<IndexedRecord>(((int) chunkLen0), arrayFieldRecordTwoArraySchema0);
114+
}
115+
while (chunkLen0 > 0) {
116+
for (int counter0 = 0; (counter0 <chunkLen0); counter0 ++) {
117+
Object arrayFieldRecordTwoArrayElementReuseVar0 = null;
118+
if (oldArray0 instanceof GenericArray) {
119+
arrayFieldRecordTwoArrayElementReuseVar0 = ((GenericArray) oldArray0).peek();
120+
}
121+
arrayFieldRecordTwo1 .add(deserializerecordTwo0(arrayFieldRecordTwoArrayElementReuseVar0, (decoder), (customization)));
122+
}
123+
chunkLen0 = (decoder.arrayNext());
124+
}
125+
fastGenericDeserializerGeneratorTest_shouldHandleNullableCorrectly0 .put(3, arrayFieldRecordTwo1);
126+
}
127+
128+
public IndexedRecord deserializerecordTwo0(Object reuse, Decoder decoder, DatumReaderCustomization customization)
129+
throws IOException
130+
{
131+
IndexedRecord recordTwo0;
132+
if ((((reuse)!= null)&&((reuse) instanceof IndexedRecord))&&(((IndexedRecord)(reuse)).getSchema() == recordTwoRecordSchema0)) {
133+
recordTwo0 = ((IndexedRecord)(reuse));
134+
} else {
135+
recordTwo0 = new org.apache.avro.generic.GenericData.Record(recordTwoRecordSchema0);
136+
}
137+
Utf8 charSequence2;
138+
Object oldString2 = recordTwo0 .get(0);
139+
if (oldString2 instanceof Utf8) {
140+
charSequence2 = (decoder).readString(((Utf8) oldString2));
141+
} else {
142+
charSequence2 = (decoder).readString(null);
143+
}
144+
recordTwo0 .put(0, charSequence2);
145+
return recordTwo0;
146+
}
147+
148+
}

‎fastserde/avro-fastserde-tests111/build/codegen/java/com/linkedin/avro/fastserde/generated/deserialization/AVRO_1_11/FastGenericDeserializerGeneratorTest_shouldReadAliasedField_GenericDeserializer_1824759546_1574596677.java‎

Lines changed: 12 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -32,51 +32,51 @@ public IndexedRecord deserialize(IndexedRecord reuse, Decoder decoder, DatumRead
3232
public IndexedRecord deserializeFastGenericDeserializerGeneratorTest_shouldReadAliasedField0(Object reuse, Decoder decoder, DatumReaderCustomization customization)
3333
throws IOException
3434
{
35-
IndexedRecord FastGenericDeserializerGeneratorTest_shouldReadAliasedField;
35+
IndexedRecord fastGenericDeserializerGeneratorTest_shouldReadAliasedField0;
3636
if ((((reuse)!= null)&&((reuse) instanceof IndexedRecord))&&(((IndexedRecord)(reuse)).getSchema() == readerSchema)) {
37-
FastGenericDeserializerGeneratorTest_shouldReadAliasedField = ((IndexedRecord)(reuse));
37+
fastGenericDeserializerGeneratorTest_shouldReadAliasedField0 = ((IndexedRecord)(reuse));
3838
} else {
39-
FastGenericDeserializerGeneratorTest_shouldReadAliasedField = new org.apache.avro.generic.GenericData.Record(readerSchema);
39+
fastGenericDeserializerGeneratorTest_shouldReadAliasedField0 = new org.apache.avro.generic.GenericData.Record(readerSchema);
4040
}
4141
int unionIndex0 = (decoder.readIndex());
4242
if (unionIndex0 == 0) {
4343
decoder.readNull();
44-
FastGenericDeserializerGeneratorTest_shouldReadAliasedField.put(0, null);
44+
fastGenericDeserializerGeneratorTest_shouldReadAliasedField0 .put(0, null);
4545
} else {
4646
if (unionIndex0 == 1) {
4747
Utf8 charSequence0;
48-
Object oldString0 = FastGenericDeserializerGeneratorTest_shouldReadAliasedField.get(0);
48+
Object oldString0 = fastGenericDeserializerGeneratorTest_shouldReadAliasedField0 .get(0);
4949
if (oldString0 instanceof Utf8) {
5050
charSequence0 = (decoder).readString(((Utf8) oldString0));
5151
} else {
5252
charSequence0 = (decoder).readString(null);
5353
}
54-
FastGenericDeserializerGeneratorTest_shouldReadAliasedField.put(0, charSequence0);
54+
fastGenericDeserializerGeneratorTest_shouldReadAliasedField0 .put(0, charSequence0);
5555
} else {
5656
throw new RuntimeException(("Illegal union index for 'testString': "+ unionIndex0));
5757
}
5858
}
59-
populate_FastGenericDeserializerGeneratorTest_shouldReadAliasedField0((FastGenericDeserializerGeneratorTest_shouldReadAliasedField), (customization), (decoder));
60-
return FastGenericDeserializerGeneratorTest_shouldReadAliasedField;
59+
populate_FastGenericDeserializerGeneratorTest_shouldReadAliasedField0((fastGenericDeserializerGeneratorTest_shouldReadAliasedField0), (customization), (decoder));
60+
return fastGenericDeserializerGeneratorTest_shouldReadAliasedField0;
6161
}
6262

63-
private void populate_FastGenericDeserializerGeneratorTest_shouldReadAliasedField0(IndexedRecord FastGenericDeserializerGeneratorTest_shouldReadAliasedField, DatumReaderCustomization customization, Decoder decoder)
63+
private void populate_FastGenericDeserializerGeneratorTest_shouldReadAliasedField0(IndexedRecord fastGenericDeserializerGeneratorTest_shouldReadAliasedField0, DatumReaderCustomization customization, Decoder decoder)
6464
throws IOException
6565
{
6666
int unionIndex1 = (decoder.readIndex());
6767
if (unionIndex1 == 0) {
6868
decoder.readNull();
69-
FastGenericDeserializerGeneratorTest_shouldReadAliasedField.put(1, null);
69+
fastGenericDeserializerGeneratorTest_shouldReadAliasedField0 .put(1, null);
7070
} else {
7171
if (unionIndex1 == 1) {
7272
Utf8 charSequence1;
73-
Object oldString1 = FastGenericDeserializerGeneratorTest_shouldReadAliasedField.get(1);
73+
Object oldString1 = fastGenericDeserializerGeneratorTest_shouldReadAliasedField0 .get(1);
7474
if (oldString1 instanceof Utf8) {
7575
charSequence1 = (decoder).readString(((Utf8) oldString1));
7676
} else {
7777
charSequence1 = (decoder).readString(null);
7878
}
79-
FastGenericDeserializerGeneratorTest_shouldReadAliasedField.put(1, charSequence1);
79+
fastGenericDeserializerGeneratorTest_shouldReadAliasedField0 .put(1, charSequence1);
8080
} else {
8181
throw new RuntimeException(("Illegal union index for 'testStringUnionAlias': "+ unionIndex1));
8282
}

0 commit comments

Comments
 (0)