org.wikimedia.eventutilities.flink.formats.json

Class RowDataToJsonConverters

java.lang.Object

org.wikimedia.eventutilities.flink.formats.json.RowDataToJsonConverters

All Implemented Interfaces:

Serializable

public class RowDataToJsonConverters
extends Object
implements Serializable

Tool class used to convert from RowData to JsonNode.

NOTE: This class was directly copied and modified from upstream Flink in order to use unshaded Jackson dependencies for use with eventutilities-core.

WMF changes from upstream Flink: - Use unshaded jackson dependencies.

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 and SQL internal data structures to corresponding JsonNodes.

Constructor Summary

Constructors

Constructor and Description
RowDataToJsonConverters(org.apache.flink.formats.common.TimestampFormat timestampFormat, org.apache.flink.formats.json.JsonFormatOptions.MapNullKeyMode mapNullKeyMode, String mapNullKeyLiteral)

Method Summary

Modifier and Type	Method and Description
protected boolean	canEqual(Object other)
RowDataToJsonConverters.RowDataToJsonConverter	createConverter(org.apache.flink.table.types.logical.LogicalType type) Creates a runtime converter which is null safe.
boolean	equals(Object o)
int	hashCode()

Methods inherited from class java.lang.Object

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

Constructor Detail

RowDataToJsonConverters

public RowDataToJsonConverters(org.apache.flink.formats.common.TimestampFormat timestampFormat,
                               org.apache.flink.formats.json.JsonFormatOptions.MapNullKeyMode mapNullKeyMode,
                               String mapNullKeyLiteral)

Method Detail

createConverter

public RowDataToJsonConverters.RowDataToJsonConverter createConverter(org.apache.flink.table.types.logical.LogicalType type)

Creates a runtime converter which is null safe.

equals

public boolean equals(Object o)

Overrides:

equals in class Object

canEqual

protected boolean canEqual(Object other)

hashCode

public int hashCode()

Overrides:

hashCode in class Object