Package | Description |
---|---|
org.wikimedia.eventutilities.flink.formats.json | |
org.wikimedia.eventutilities.flink.stream |
Class and Description |
---|
JsonRowDeserializationSchema
Deserialization schema from JSON to Flink Row type.
|
JsonRowDeserializationSchema.Builder
Builder for
JsonRowDeserializationSchema . |
JsonRowDeserializationSchema.RowFieldMode
Used to determine which of the Row field modes in which this deserializer should create Rows.
|
JsonRowSerializationSchema
Serialization schema that serializes an object of Flink types into a JSON bytes.
|
JsonRowSerializationSchema.Builder
Builder for
JsonRowSerializationSchema . |
KafkaRecordTimestampStrategy
Strategy regarding how to assign the kafka timestamp of the output messages.
|
RowDataToJsonConverters.RowDataToJsonConverter
Runtime converter that converts objects of Flink Table and SQL internal data structures to
corresponding
JsonNode s. |
Class and Description |
---|
JsonRowDeserializationSchema
Deserialization schema from JSON to Flink Row type.
|
JsonRowSerializationSchema
Serialization schema that serializes an object of Flink types into a JSON bytes.
|
KafkaRecordTimestampStrategy
Strategy regarding how to assign the kafka timestamp of the output messages.
|
Copyright © 2024. All rights reserved.