Package org.apache.beam.sdk.schemas.utils

Class JsonUtils

java.lang.Object

org.apache.beam.sdk.schemas.utils.JsonUtils

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

Utils to convert JSON records to Beam Row.

Constructor Summary

Constructors

Constructor	Description
JsonUtils()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

JsonUtils

public JsonUtils()

Method Detail

getJsonBytesToRowFunction

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

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

getJsonStringToRowFunction

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

Returns a SimpleFunction mapping JSON Strings to Beam Rows.

getRowToJsonBytesFunction

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

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

getRowToJsonStringsFunction

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

Returns a SimpleFunction mapping Beam Rows to JSON Strings.