org.apache.flink.formats.json

Class RowDataToJsonConverters

java.lang.Object

org.apache.flink.formats.json.RowDataToJsonConverters

All Implemented Interfaces:

Serializable

@Internal
public class RowDataToJsonConverters
extends Object
implements Serializable

Tool class used to convert from RowData to JsonNode. *

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	RowDataToJsonConverters.RowDataToJsonConverter Runtime converter that converts objects of Flink Table & SQL internal data structures to corresponding JsonNodes.

Constructor Summary

Constructors

Constructor and Description
RowDataToJsonConverters(TimestampFormat timestampFormat, JsonFormatOptions.MapNullKeyMode mapNullKeyMode, String mapNullKeyLiteral)

Method Summary

Modifier and Type	Method and Description
RowDataToJsonConverters.RowDataToJsonConverter	createConverter(LogicalType type) Creates a runtime converter which is null safe.

Methods inherited from class java.lang.Object

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

Constructor Detail

RowDataToJsonConverters

public RowDataToJsonConverters(TimestampFormat timestampFormat,
                               JsonFormatOptions.MapNullKeyMode mapNullKeyMode,
                               String mapNullKeyLiteral)

Method Detail

createConverter

public RowDataToJsonConverters.RowDataToJsonConverter createConverter(LogicalType type)

Creates a runtime converter which is null safe.