Package org.apache.beam.sdk.util

Class RowJson

java.lang.Object

org.apache.beam.sdk.util.RowJson

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

Jackson serializer and deserializer for Rows.

Supports converting between JSON primitive types and:

• Schema.TypeName.BYTE
• Schema.TypeName.INT16
• Schema.TypeName.INT32
• Schema.TypeName.INT64
• Schema.TypeName.FLOAT
• Schema.TypeName.DOUBLE
• Schema.TypeName.BOOLEAN
• Schema.TypeName.STRING
• Schema.TypeName.DECIMAL
• Schema.TypeName.DATETIME

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	RowJson.RowJsonDeserializer	Jackson deserializer for parsing JSON into Rows.
static class	RowJson.RowJsonSerializer	Jackson serializer for converting Rows to JSON.
static class	RowJson.UnsupportedRowJsonException	Gets thrown when Row parsing or serialization fails for any reason.

Constructor Summary

Constructors

Constructor	Description
RowJson()

Method Summary

Modifier and Type	Method	Description
static void	verifySchemaSupported(Schema schema)	Throws RowJson.UnsupportedRowJsonException if schema contains an unsupported field type.

Methods inherited from class java.lang.Object

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

Constructor Detail

RowJson

public RowJson()

Method Detail

verifySchemaSupported

public static void verifySchemaSupported(Schema schema)

Throws RowJson.UnsupportedRowJsonException if schema contains an unsupported field type.