[WIP] Implement flattening JSON Arrays

embulk · Aug 18, 2023 · d91764c · d91764c
1 parent 8eba18b
commit d91764c
Showing 1 changed file with 17 additions and 0 deletions.
diff --git a/src/main/java/org/embulk/util/json/JsonValueParser.java b/src/main/java/org/embulk/util/json/JsonValueParser.java
@@ -34,13 +34,15 @@
 public final class JsonValueParser implements Closeable {
     private JsonValueParser(
             final com.fasterxml.jackson.core.JsonParser jacksonParser,
+            final boolean flattenJsonArray,
             final boolean hasLiteralsWithNumbers,
             final boolean hasFallbacksForUnparsableNumbers,
             final double defaultDouble,
             final long defaultLong) {
         this.jacksonParser = Objects.requireNonNull(jacksonParser);
         this.valueReader = new InternalJsonValueReader(
                 hasLiteralsWithNumbers, hasFallbacksForUnparsableNumbers, defaultDouble, defaultLong);
+        this.flattenJsonArray = flattenJsonArray;
         this.hasLiteralsWithNumbers = hasLiteralsWithNumbers;
         this.hasFallbacksForUnparsableNumbers = hasFallbacksForUnparsableNumbers;
         this.defaultDouble = defaultDouble;
@@ -54,6 +56,7 @@ public static final class Builder {
         Builder(final JsonFactory factory) {
             this.factory = Objects.requireNonNull(factory);
             this.root = null;
+            this.flattenJsonArray = false;
             this.hasLiteralsWithNumbers = false;
             this.hasFallbacksForUnparsableNumbers = false;
             this.defaultDouble = 0.0;
@@ -84,6 +87,16 @@ public Builder root(final String root) {
             return this;
         }
 
+        /**
+         * Enables flattening JSON Arrays to parse.
+         *
+         * @return this builder
+         */
+        public Builder flattenJsonArray() {
+            this.flattenJsonArray = true;
+            return this;
+        }
+
         /**
          * Enables creating {@link JsonDouble} and {@link JsonLong} instances with supplemental literal strings.
          *
@@ -126,6 +139,7 @@ public Builder fallbackForUnparsableNumbers(final double defaultDouble, final lo
         public JsonValueParser build(final String json) throws IOException {
             return new JsonValueParser(
                     buildJacksonParser(json),
+                    this.flattenJsonArray,
                     this.hasLiteralsWithNumbers,
                     this.hasFallbacksForUnparsableNumbers,
                     this.defaultDouble,
@@ -141,6 +155,7 @@ public JsonValueParser build(final String json) throws IOException {
         public JsonValueParser build(final InputStream jsonStream) throws IOException {
             return new JsonValueParser(
                     buildJacksonParser(jsonStream),
+                    this.flattenJsonArray,
                     this.hasLiteralsWithNumbers,
                     this.hasFallbacksForUnparsableNumbers,
                     this.defaultDouble,
@@ -170,6 +185,7 @@ private com.fasterxml.jackson.core.JsonParser extendJacksonParser(final com.fast
         private final JsonFactory factory;
 
         private JsonPointer root;
+        private boolean flattenJsonArray;
         private boolean hasLiteralsWithNumbers;
         private boolean hasFallbacksForUnparsableNumbers;
         private double defaultDouble;
@@ -243,6 +259,7 @@ public final void close() throws IOException {
     private final com.fasterxml.jackson.core.JsonParser jacksonParser;
     private final InternalJsonValueReader valueReader;
 
+    private final boolean flattenJsonArray;
     private final boolean hasLiteralsWithNumbers;
     private final boolean hasFallbacksForUnparsableNumbers;
     private final double defaultDouble;