org.apache.beam.it.gcp.artifacts.utils

Class JsonTestUtil

java.lang.Object

org.apache.beam.it.gcp.artifacts.utils.JsonTestUtil

public class JsonTestUtil
extends java.lang.Object

The JsonTestUtil class provides common utilities used for executing tests that involve Json.

Constructor Summary

Constructors

Constructor and Description
JsonTestUtil()

Method Summary

Modifier and Type	Method and Description
static java.lang.Object	parseJsonString(java.lang.String jsonString) Parses a JSON string and returns either a List of Maps or a Map, depending on whether the JSON represents an array or an object.
static java.util.List<java.util.Map<java.lang.String,java.lang.Object>>	readNDJSON(byte[] jsonBytes) Reads NDJSON (Newline Delimited JSON) data from a byte array and returns a list of parsed JSON objects.
static java.util.Map<java.lang.String,java.lang.Object>	readRecord(byte[] contents) Read JSON record to a Map.
static java.util.Map<java.lang.String,java.lang.Object>	readRecord(java.lang.String contents) Read JSON record to a Map.
static java.util.List<java.util.Map<java.lang.String,java.lang.Object>>	readRecords(byte[] contents) Read JSON records to a list of Maps.
static java.util.List<java.util.Map<java.lang.String,java.lang.Object>>	readRecords(java.lang.String contents) Read JSON records to a list of Maps.
static java.util.Map<java.lang.String,java.lang.Object>	sortJsonMap(java.util.Map<java.lang.String,java.lang.Object> jsonMap) Recursively sorts the keys of a nested JSON represented as a Map.

Methods inherited from class java.lang.Object

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

Constructor Detail

JsonTestUtil

public JsonTestUtil()

Method Detail

readRecords

public static java.util.List<java.util.Map<java.lang.String,java.lang.Object>> readRecords(byte[] contents)
                                                                                    throws java.io.IOException

Read JSON records to a list of Maps.

Parameters:

contents - Byte array with contents to read.

Returns:

A list with all records.

Throws:

java.io.IOException

readNDJSON

public static java.util.List<java.util.Map<java.lang.String,java.lang.Object>> readNDJSON(byte[] jsonBytes)
                                                                                   throws java.io.IOException

Reads NDJSON (Newline Delimited JSON) data from a byte array and returns a list of parsed JSON objects. Each JSON object is represented as a Map of String keys to Object values.

Parameters:

jsonBytes - A byte array containing NDJSON data.

Returns:

A list of parsed JSON objects as Map<String, Object>.

Throws:

java.io.IOException - if there's an issue reading or parsing the data.

sortJsonMap

public static java.util.Map<java.lang.String,java.lang.Object> sortJsonMap(java.util.Map<java.lang.String,java.lang.Object> jsonMap)

Recursively sorts the keys of a nested JSON represented as a Map.

Parameters:

jsonMap - A Map<String, Object> representing the nested JSON.

Returns:

A sorted Map<String, Object> where the keys are sorted in natural order.

readRecords

public static java.util.List<java.util.Map<java.lang.String,java.lang.Object>> readRecords(java.lang.String contents)
                                                                                    throws java.io.IOException

Read JSON records to a list of Maps.

Parameters:

contents - String with contents to read.

Returns:

A list with all records.

Throws:

java.io.IOException

readRecord

public static java.util.Map<java.lang.String,java.lang.Object> readRecord(byte[] contents)
                                                                   throws java.io.IOException

Read JSON record to a Map.

Parameters:

contents - Byte array with contents to read.

Returns:

A map with the records.

Throws:

java.io.IOException

readRecord

public static java.util.Map<java.lang.String,java.lang.Object> readRecord(java.lang.String contents)
                                                                   throws java.io.IOException

Read JSON record to a Map.

Parameters:

contents - String with contents to read.

Returns:

A map with the records.

Throws:

java.io.IOException

parseJsonString

public static java.lang.Object parseJsonString(java.lang.String jsonString)
                                        throws java.io.IOException

Parses a JSON string and returns either a List of Maps or a Map, depending on whether the JSON represents an array or an object.

Parameters:

jsonString - The JSON string to parse.

Returns:

A List of Maps if the JSON is an array, or a Map if it's an object.

Throws:

java.io.IOException - If there's an error while parsing the JSON string.