Fix using deprecated APIs

yuokada · Jan 8, 2024 · 6c19e13 · 6c19e13
1 parent ef7b5c3
commit 6c19e13
Showing 1 changed file with 6 additions and 3 deletions.
diff --git a/src/main/java/io/github/yuokada/embulk/input/randomj/visitor/RandomjColumnVisitor.java b/src/main/java/io/github/yuokada/embulk/input/randomj/visitor/RandomjColumnVisitor.java
@@ -12,8 +12,9 @@
 import org.embulk.spi.Column;
 import org.embulk.spi.ColumnVisitor;
 import org.embulk.spi.PageBuilder;
-import org.embulk.util.json.JsonParser;
+import org.embulk.util.json.JsonValueParser;
 
+import java.io.IOException;
 import java.time.Duration;
 import java.time.Instant;
 import java.time.LocalDate;
@@ -41,7 +42,6 @@ public class RandomjColumnVisitor
             .filteredBy(CharacterPredicates.LETTERS, CharacterPredicates.DIGITS)
             .build();
     private final ZoneId zoneId = ZoneId.systemDefault();
-    private final JsonParser jsonParser = new JsonParser();
     private final ObjectMapper mapper = new ObjectMapper();
 
     private static final DateTimeFormatter formatter = DateTimeFormatter
@@ -236,11 +236,14 @@ public void jsonColumn(Column column)
         }
 
         try {
-            pageBuilder.setJson(column, jsonParser.parse(mapper.writeValueAsString(map)));
+            pageBuilder.setJson(column, JsonValueParser.builder().build(mapper.writeValueAsString(map)).readJsonValue());
         }
         catch (JsonProcessingException e) {
             e.printStackTrace(); // NOSONAR
         }
+        catch (IOException e) {
+            throw new RuntimeException(e);
+        }
     }
 
     private void visit(JsonNode node, JsonColumnVisitor visitor)