Package org.wikimedia.eventutilities.flink.formats.json

Interface Summary

Interface	Description
RowDataToJsonConverters.RowDataToJsonConverter	Runtime converter that converts objects of Flink Table and SQL internal data structures to corresponding JsonNodes.

Class Summary

Class	Description
DataTypeSchemaConversions	Implementation of SchemaConversions that can convert to Flink Table API DataType.
EventJsonFormatFactory
EventJsonFormatOptions
JsonRowDataSerializationSchema	Serialization schema that serializes an object of Flink internal data structure into a JSON bytes.
JsonRowDeserializationSchema	Deserialization schema from JSON to Flink Row type.
JsonRowDeserializationSchema.Builder	Builder for JsonRowDeserializationSchema.
JsonRowSerializationSchema	Serialization schema that serializes an object of Flink types into a JSON bytes.
JsonRowSerializationSchema.Builder	Builder for JsonRowSerializationSchema.
JsonSchemaFlinkConverter	Converts from JSONSchemas to Flink types.
KafkaEventSerializationSchema	This class is designed to produce events compliant with the WMF Event Platform.
RowDataToJsonConverters	Tool class used to convert from RowData to JsonNode.
TypeInformationSchemaConversions	Implementation of SchemaConversions that can convert to Flink DataStream API TypeInformation.

Enum Summary

Enum	Description
JsonRowDeserializationSchema.RowFieldMode	Used to determine which of the Row field modes in which this deserializer should create Rows.
KafkaRecordTimestampStrategy	Strategy regarding how to assign the kafka timestamp of the output messages.