org.wikimedia.eventutilities.flink.formats.json

Class JsonRowDeserializationSchema.Builder

java.lang.Object

org.wikimedia.eventutilities.flink.formats.json.JsonRowDeserializationSchema.Builder

Enclosing class:

JsonRowDeserializationSchema

public static class JsonRowDeserializationSchema.Builder
extends Object

Builder for JsonRowDeserializationSchema.

Constructor Summary

Constructors

Constructor and Description
Builder(org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.types.Row> typeInfo) Creates a JSON deserialization schema for the given type information.

Method Summary

Modifier and Type	Method and Description
JsonRowDeserializationSchema	build()
JsonRowDeserializationSchema.Builder	failOnMissingField() Configures schema to fail if a JSON field is missing.
JsonRowDeserializationSchema.Builder	ignoreParseErrors() Configures schema to fail when parsing json failed.
JsonRowDeserializationSchema.Builder	rowFieldMode(JsonRowDeserializationSchema.RowFieldMode rowFieldMode)

Methods inherited from class java.lang.Object

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

Constructor Detail

Builder

public Builder(org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.types.Row> typeInfo)

Creates a JSON deserialization schema for the given type information.

Parameters:

typeInfo - Type information describing the result type. The field names of Row are used to parse the JSON properties.

Method Detail

failOnMissingField

public JsonRowDeserializationSchema.Builder failOnMissingField()

Configures schema to fail if a JSON field is missing.

By default, a missing field is ignored and the field is set to null.

ignoreParseErrors

public JsonRowDeserializationSchema.Builder ignoreParseErrors()

Configures schema to fail when parsing json failed.

By default, an exception will be thrown when parsing json fails.

rowFieldMode

public JsonRowDeserializationSchema.Builder rowFieldMode(JsonRowDeserializationSchema.RowFieldMode rowFieldMode)

build

public JsonRowDeserializationSchema build()