org.apache.flink.formats.json

Class JsonRowSerializationSchema.Builder

java.lang.Object

org.apache.flink.formats.json.JsonRowSerializationSchema.Builder

Enclosing class:

JsonRowSerializationSchema

@PublicEvolving
public static class JsonRowSerializationSchema.Builder
extends Object

Builder for JsonRowSerializationSchema.

Constructor Summary

Constructors

Constructor and Description
Builder(String jsonSchema) Deprecated. Use JsonRowSerializationSchema.builder() instead.
Builder(TypeInformation<Row> typeInfo) Deprecated. Use JsonRowSerializationSchema.builder() instead.

Method Summary

Modifier and Type	Method and Description
JsonRowSerializationSchema	build() Finalizes the configuration and checks validity.
JsonRowSerializationSchema.Builder	withTypeInfo(TypeInformation<Row> typeInfo) Sets type information for JSON serialization schema.

Methods inherited from class java.lang.Object

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

Constructor Detail

Builder

@Deprecated
public Builder(TypeInformation<Row> typeInfo)

Deprecated. Use JsonRowSerializationSchema.builder() instead.

Creates a JSON serialization 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.

Builder

@Deprecated
public Builder(String jsonSchema)

Deprecated. Use JsonRowSerializationSchema.builder() instead.

Creates a JSON serialization schema for the given JSON schema.

Parameters:

jsonSchema - JSON schema describing the result type

See Also:

http://json-schema.org/

Method Detail

withTypeInfo

public JsonRowSerializationSchema.Builder withTypeInfo(TypeInformation<Row> typeInfo)

Sets type information for JSON serialization schema.

Parameters:

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

build

public JsonRowSerializationSchema build()

Finalizes the configuration and checks validity.

Returns:

Configured JsonRowSerializationSchema