add new API for boundedMemoryDecoder (#134)

linkedin · Mar 4, 2021 · 5ea12f7 · 5ea12f7
1 parent 0391a2f
commit 5ea12f7
Show file tree

Hide file tree

Showing 8 changed files with 37 additions and 0 deletions.
diff --git a/helper/helper-common/src/main/java/com/linkedin/avroutil1/compatibility/AvroAdapter.java b/helper/helper-common/src/main/java/com/linkedin/avroutil1/compatibility/AvroAdapter.java
@@ -62,6 +62,8 @@ BinaryDecoder newBinaryDecoder(byte[] bytes, int offset,
 
   Decoder newBoundedMemoryDecoder(InputStream in) throws IOException;
 
+  Decoder newBoundedMemoryDecoder(byte[] data) throws IOException;
+
   //parsing and Schema-related
 
   SchemaParseResult parse(String schemaJson, SchemaParseConfiguration desiredConf, Collection<Schema> known);

diff --git a/...r-impl-110/src/main/java/com/linkedin/avroutil1/compatibility/avro110/Avro110Adapter.java b/...r-impl-110/src/main/java/com/linkedin/avroutil1/compatibility/avro110/Avro110Adapter.java
@@ -173,6 +173,11 @@ public Decoder newBoundedMemoryDecoder(InputStream in) throws IOException {
         return new BoundedMemoryDecoder(in);
     }
 
+    @Override
+    public Decoder newBoundedMemoryDecoder(byte[] data) throws IOException {
+        return new BoundedMemoryDecoder(data);
+    }
+
     @Override
     public SchemaParseResult parse(String schemaJson, SchemaParseConfiguration desiredConf, Collection<Schema> known) {
         Schema.Parser parser = new Schema.Parser();

diff --git a/...lper-impl-14/src/main/java/com/linkedin/avroutil1/compatibility/avro14/Avro14Adapter.java b/...lper-impl-14/src/main/java/com/linkedin/avroutil1/compatibility/avro14/Avro14Adapter.java
@@ -165,6 +165,11 @@ public Decoder newBoundedMemoryDecoder(InputStream in) throws IOException {
     return new BoundedMemoryDecoder(in);
   }
 
+  @Override
+  public Decoder newBoundedMemoryDecoder(byte[] data) throws IOException {
+    return new BoundedMemoryDecoder(data);
+  }
+
   @Override
   public SchemaParseResult parse(String schemaJson, SchemaParseConfiguration desiredConf, Collection<Schema> known) {
     SchemaParseResult result = Avro14SchemaAccessUtil.parse(schemaJson, known);

diff --git a/...lper-impl-15/src/main/java/com/linkedin/avroutil1/compatibility/avro15/Avro15Adapter.java b/...lper-impl-15/src/main/java/com/linkedin/avroutil1/compatibility/avro15/Avro15Adapter.java
@@ -168,6 +168,11 @@ public Decoder newBoundedMemoryDecoder(InputStream in) throws IOException {
     return new BoundedMemoryDecoder(in);
   }
 
+  @Override
+  public Decoder newBoundedMemoryDecoder(byte[] data) throws IOException {
+    return new BoundedMemoryDecoder(data);
+  }
+
   @Override
   public SchemaParseResult parse(String schemaJson, SchemaParseConfiguration desiredConf, Collection<Schema> known) {
     Schema.Parser parser = new Schema.Parser();

diff --git a/...lper-impl-16/src/main/java/com/linkedin/avroutil1/compatibility/avro16/Avro16Adapter.java b/...lper-impl-16/src/main/java/com/linkedin/avroutil1/compatibility/avro16/Avro16Adapter.java
@@ -174,6 +174,11 @@ public Decoder newBoundedMemoryDecoder(InputStream in) throws IOException {
     return new BoundedMemoryDecoder(in);
   }
 
+  @Override
+  public Decoder newBoundedMemoryDecoder(byte[] data) throws IOException {
+    return new BoundedMemoryDecoder(data);
+  }
+
   @Override
   public SchemaParseResult parse(String schemaJson, SchemaParseConfiguration desiredConf, Collection<Schema> known) {
     Schema.Parser parser = new Schema.Parser();

diff --git a/...lper-impl-17/src/main/java/com/linkedin/avroutil1/compatibility/avro17/Avro17Adapter.java b/...lper-impl-17/src/main/java/com/linkedin/avroutil1/compatibility/avro17/Avro17Adapter.java
@@ -217,6 +217,11 @@ public Decoder newBoundedMemoryDecoder(InputStream in) throws IOException {
     return new BoundedMemoryDecoder(in);
   }
 
+  @Override
+  public Decoder newBoundedMemoryDecoder(byte[] data) throws IOException {
+    return new BoundedMemoryDecoder(data);
+  }
+
   @Override
   public SchemaParseResult parse(String schemaJson, SchemaParseConfiguration desiredConf, Collection<Schema> known) {
     Schema.Parser parser = new Schema.Parser();

diff --git a/...lper-impl-18/src/main/java/com/linkedin/avroutil1/compatibility/avro18/Avro18Adapter.java b/...lper-impl-18/src/main/java/com/linkedin/avroutil1/compatibility/avro18/Avro18Adapter.java
@@ -176,6 +176,11 @@ public Decoder newBoundedMemoryDecoder(InputStream in) throws IOException {
     return new BoundedMemoryDecoder(in);
   }
 
+  @Override
+  public Decoder newBoundedMemoryDecoder(byte[] data) throws IOException {
+    return new BoundedMemoryDecoder(data);
+  }
+
   @Override
   public SchemaParseResult parse(String schemaJson, SchemaParseConfiguration desiredConf, Collection<Schema> known) {
     Schema.Parser parser = new Schema.Parser();

diff --git a/...lper-impl-19/src/main/java/com/linkedin/avroutil1/compatibility/avro19/Avro19Adapter.java b/...lper-impl-19/src/main/java/com/linkedin/avroutil1/compatibility/avro19/Avro19Adapter.java
@@ -176,6 +176,11 @@ public Decoder newBoundedMemoryDecoder(InputStream in) throws IOException {
     return new BoundedMemoryDecoder(in);
   }
 
+  @Override
+  public Decoder newBoundedMemoryDecoder(byte[] data) throws IOException {
+    return new BoundedMemoryDecoder(data);
+  }
+
   @Override
   public SchemaParseResult parse(String schemaJson, SchemaParseConfiguration desiredConf, Collection<Schema> known) {
     Schema.Parser parser = new Schema.Parser();