Package dev.frostlake.executor.copy

Class JsonStageReader

java.lang.Object

dev.frostlake.executor.copy.JsonStageReader

All Implemented Interfaces:

StageFileReader

public class JsonStageReader
extends Object
implements StageFileReader

JSON staged-file reader: a top-level array yields one record per element, otherwise the file is read as newline-delimited JSON (one record per non-blank line).

Constructor Summary

Constructors

Constructor	Description
JsonStageReader()

Method Summary

Modifier and Type	Method	Description
String	formatType()	The FILE_FORMAT TYPE this reader handles (e.g.
List<tools.jackson.databind.JsonNode>	readRecords(Path file)	Parse file into its records.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

JsonStageReader

public JsonStageReader()

Method Details

readRecords

public List<tools.jackson.databind.JsonNode> readRecords(Path file)
                                                  throws IOException

Description copied from interface: StageFileReader

Parse file into its records. An unreadable/malformed file throws (a bad load is never silent).

Specified by:

readRecords in interface StageFileReader

Throws:

IOException

formatType

public String formatType()

Description copied from interface: StageFileReader

The FILE_FORMAT TYPE this reader handles (e.g. "JSON"), matched case-insensitively.

Specified by:

formatType in interface StageFileReader