Code gen for #520

linkedin · Oct 25, 2023 · 854aab3 · 854aab3
1 parent 86e3937
commit 854aab3
Show file tree

Hide file tree

Showing 126 changed files with 3,407 additions and 4,027 deletions.
diff --git a/...d/deserialization/AVRO_1_11/Array_of_BOOLEAN_GenericDeserializer_869749973_869749973.java b/...d/deserialization/AVRO_1_11/Array_of_BOOLEAN_GenericDeserializer_869749973_869749973.java
@@ -5,6 +5,7 @@
 import java.util.List;
 import com.linkedin.avro.api.PrimitiveBooleanList;
 import com.linkedin.avro.fastserde.FastDeserializer;
+import com.linkedin.avro.fastserde.customized.DatumReaderCustomization;
 import com.linkedin.avro.fastserde.primitive.PrimitiveBooleanArrayList;
 import org.apache.avro.Schema;
 import org.apache.avro.io.Decoder;
@@ -19,7 +20,7 @@ public Array_of_BOOLEAN_GenericDeserializer_869749973_869749973(Schema readerSch
         this.readerSchema = readerSchema;
     }
 
-    public List<Boolean> deserialize(List<Boolean> reuse, Decoder decoder)
+    public List<Boolean> deserialize(List<Boolean> reuse, Decoder decoder, DatumReaderCustomization customization)
         throws IOException
     {
         PrimitiveBooleanList array0 = null;

diff --git a/...ated/deserialization/AVRO_1_11/Array_of_DOUBLE_GenericDeserializer_18760307_18760307.java b/...ated/deserialization/AVRO_1_11/Array_of_DOUBLE_GenericDeserializer_18760307_18760307.java
@@ -5,6 +5,7 @@
 import java.util.List;
 import com.linkedin.avro.api.PrimitiveDoubleList;
 import com.linkedin.avro.fastserde.FastDeserializer;
+import com.linkedin.avro.fastserde.customized.DatumReaderCustomization;
 import com.linkedin.avro.fastserde.primitive.PrimitiveDoubleArrayList;
 import org.apache.avro.Schema;
 import org.apache.avro.io.Decoder;
@@ -19,7 +20,7 @@ public Array_of_DOUBLE_GenericDeserializer_18760307_18760307(Schema readerSchema
         this.readerSchema = readerSchema;
     }
 
-    public List<Double> deserialize(List<Double> reuse, Decoder decoder)
+    public List<Double> deserialize(List<Double> reuse, Decoder decoder, DatumReaderCustomization customization)
         throws IOException
     {
         PrimitiveDoubleList array0 = null;

diff --git a/...d/deserialization/AVRO_1_11/Array_of_FLOAT_GenericDeserializer_1012670397_1012670397.java b/...d/deserialization/AVRO_1_11/Array_of_FLOAT_GenericDeserializer_1012670397_1012670397.java
@@ -6,6 +6,7 @@
 import com.linkedin.avro.api.PrimitiveFloatList;
 import com.linkedin.avro.fastserde.BufferBackedPrimitiveFloatList;
 import com.linkedin.avro.fastserde.FastDeserializer;
+import com.linkedin.avro.fastserde.customized.DatumReaderCustomization;
 import org.apache.avro.Schema;
 import org.apache.avro.io.Decoder;
 
@@ -19,7 +20,7 @@ public Array_of_FLOAT_GenericDeserializer_1012670397_1012670397(Schema readerSch
         this.readerSchema = readerSchema;
     }
 
-    public List<Float> deserialize(List<Float> reuse, Decoder decoder)
+    public List<Float> deserialize(List<Float> reuse, Decoder decoder, DatumReaderCustomization customization)
         throws IOException
     {
         PrimitiveFloatList array0 = null;

diff --git a/...ted/deserialization/AVRO_1_11/Array_of_INT_GenericDeserializer_1012089072_1012089072.java b/...ted/deserialization/AVRO_1_11/Array_of_INT_GenericDeserializer_1012089072_1012089072.java
@@ -5,6 +5,7 @@
 import java.util.List;
 import com.linkedin.avro.api.PrimitiveIntList;
 import com.linkedin.avro.fastserde.FastDeserializer;
+import com.linkedin.avro.fastserde.customized.DatumReaderCustomization;
 import com.linkedin.avro.fastserde.primitive.PrimitiveIntArrayList;
 import org.apache.avro.Schema;
 import org.apache.avro.io.Decoder;
@@ -19,7 +20,7 @@ public Array_of_INT_GenericDeserializer_1012089072_1012089072(Schema readerSchem
         this.readerSchema = readerSchema;
     }
 
-    public List<Integer> deserialize(List<Integer> reuse, Decoder decoder)
+    public List<Integer> deserialize(List<Integer> reuse, Decoder decoder, DatumReaderCustomization customization)
         throws IOException
     {
         PrimitiveIntList array0 = null;

diff --git a/...ated/deserialization/AVRO_1_11/Array_of_LONG_GenericDeserializer_325099267_325099267.java b/...ated/deserialization/AVRO_1_11/Array_of_LONG_GenericDeserializer_325099267_325099267.java
@@ -5,6 +5,7 @@
 import java.util.List;
 import com.linkedin.avro.api.PrimitiveLongList;
 import com.linkedin.avro.fastserde.FastDeserializer;
+import com.linkedin.avro.fastserde.customized.DatumReaderCustomization;
 import com.linkedin.avro.fastserde.primitive.PrimitiveLongArrayList;
 import org.apache.avro.Schema;
 import org.apache.avro.io.Decoder;
@@ -19,7 +20,7 @@ public Array_of_LONG_GenericDeserializer_325099267_325099267(Schema readerSchema
         this.readerSchema = readerSchema;
     }
 
-    public List<Long> deserialize(List<Long> reuse, Decoder decoder)
+    public List<Long> deserialize(List<Long> reuse, Decoder decoder, DatumReaderCustomization customization)
         throws IOException
     {
         PrimitiveLongList array0 = null;

diff --git a/...rialization/AVRO_1_11/Array_of_TestRecord_SpecificDeserializer_1088113243_1088113243.java b/...rialization/AVRO_1_11/Array_of_TestRecord_SpecificDeserializer_1088113243_1088113243.java
diff --git a/...ted/deserialization/AVRO_1_11/Array_of_UNION_GenericDeserializer_777827233_777827233.java b/...ted/deserialization/AVRO_1_11/Array_of_UNION_GenericDeserializer_777827233_777827233.java
@@ -4,6 +4,7 @@
 import java.io.IOException;
 import java.util.List;
 import com.linkedin.avro.fastserde.FastDeserializer;
+import com.linkedin.avro.fastserde.customized.DatumReaderCustomization;
 import org.apache.avro.Schema;
 import org.apache.avro.generic.GenericArray;
 import org.apache.avro.generic.IndexedRecord;
@@ -26,7 +27,7 @@ public Array_of_UNION_GenericDeserializer_777827233_777827233(Schema readerSchem
         this.field0 = arrayElemOptionSchema0 .getField("field").schema();
     }
 
-    public List<IndexedRecord> deserialize(List<IndexedRecord> reuse, Decoder decoder)
+    public List<IndexedRecord> deserialize(List<IndexedRecord> reuse, Decoder decoder, DatumReaderCustomization customization)
         throws IOException
     {
         List<IndexedRecord> array0 = null;
@@ -53,7 +54,7 @@ public List<IndexedRecord> deserialize(List<IndexedRecord> reuse, Decoder decode
                     array0 .add(null);
                 } else {
                     if (unionIndex0 == 1) {
-                        array0 .add(deserializerecord0(arrayArrayElementReuseVar0, (decoder)));
+                        array0 .add(deserializerecord0(arrayArrayElementReuseVar0, (decoder), (customization)));
                     } else {
                         throw new RuntimeException(("Illegal union index for 'arrayElem': "+ unionIndex0));
                     }
@@ -64,7 +65,7 @@ public List<IndexedRecord> deserialize(List<IndexedRecord> reuse, Decoder decode
         return array0;
     }
 
-    public IndexedRecord deserializerecord0(Object reuse, Decoder decoder)
+    public IndexedRecord deserializerecord0(Object reuse, Decoder decoder, DatumReaderCustomization customization)
         throws IOException
     {
         IndexedRecord record;