Class | Description |
---|---|
JsonFileSystemFormatFactory |
Factory to build reader/writer to read/write json format file.
|
JsonFileSystemFormatFactory.JsonInputFormat |
A
JsonFileSystemFormatFactory.JsonInputFormat is responsible to read RowData records from json format
files. |
JsonFileSystemFormatFactory.JsonRowDataEncoder |
A
JsonFileSystemFormatFactory.JsonRowDataEncoder is responsible to encode a RowData to OutputStream with json format. |
JsonFormatFactory |
Table format factory for providing configured instances of JSON to RowData
SerializationSchema and DeserializationSchema . |
JsonNodeDeserializationSchema |
DeserializationSchema that deserializes a JSON String into an ObjectNode.
|
JsonOptions |
This class holds configuration constants used by json format.
|
JsonRowDataDeserializationSchema |
Deserialization schema from JSON to Flink Table/SQL internal data structure
RowData . |
JsonRowDataSerializationSchema |
Serialization schema that serializes an object of Flink internal data structure into a JSON
bytes.
|
JsonRowDeserializationSchema |
Deserialization schema from JSON to Flink types.
|
JsonRowDeserializationSchema.Builder |
Builder for
JsonRowDeserializationSchema . |
JsonRowFormatFactory |
Table format factory for providing configured instances of JSON-to-row
SerializationSchema and DeserializationSchema . |
JsonRowSchemaConverter |
Converts a JSON schema into Flink's type information.
|
JsonRowSerializationSchema |
Serialization schema that serializes an object of Flink types into a JSON bytes.
|
JsonRowSerializationSchema.Builder |
Builder for
JsonRowSerializationSchema . |
Enum | Description |
---|---|
TimestampFormat |
Timestamp format Enums.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.