JsonUtils (Apache Beam 2.43.0)

@Experimental(value=SCHEMAS)
public class JsonUtils
extends java.lang.Object

Utils to convert JSON records to Beam Row.

Constructors
Constructor and Description
`JsonUtils()`

All Methods Static Methods Concrete Methods
Modifier and Type	Method and Description
`static SimpleFunction<byte[],Row>`	`getJsonBytesToRowFunction(Schema beamSchema)` Returns a `SimpleFunction` mapping JSON byte[] arrays to Beam `Row`s.
`static SimpleFunction<java.lang.String,Row>`	`getJsonStringToRowFunction(Schema beamSchema)` Returns a `SimpleFunction` mapping JSON `String`s to Beam `Row`s.
`static SimpleFunction<Row,byte[]>`	`getRowToJsonBytesFunction(Schema beamSchema)` Returns a `SimpleFunction` mapping Beam `Row`s to JSON byte[] arrays.
`static SimpleFunction<Row,java.lang.String>`	`getRowToJsonStringsFunction(Schema beamSchema)` Returns a `SimpleFunction` mapping Beam `Row`s to JSON `String`s.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

public static SimpleFunction<byte[],Row> getJsonBytesToRowFunction(Schema beamSchema)

Returns a SimpleFunction mapping JSON byte[] arrays to Beam Rows.

public static SimpleFunction<java.lang.String,Row> getJsonStringToRowFunction(Schema beamSchema)

Returns a SimpleFunction mapping JSON Strings to Beam Rows.

public static SimpleFunction<Row,byte[]> getRowToJsonBytesFunction(Schema beamSchema)

Returns a SimpleFunction mapping Beam Rows to JSON byte[] arrays.

public static SimpleFunction<Row,java.lang.String> getRowToJsonStringsFunction(Schema beamSchema)

Returns a SimpleFunction mapping Beam Rows to JSON Strings.

Class JsonUtils