| Class | Description |
|---|---|
| MaxwellJsonDecodingFormat |
DecodingFormat for Maxwell using JSON encoding. |
| MaxwellJsonDeserializationSchema |
Deserialization schema from Maxwell JSON to Flink Table/SQL internal data structure
RowData. |
| MaxwellJsonFormatFactory |
Format factory for providing configured instances of Maxwell JSON to RowData
DeserializationSchema. |
| MaxwellJsonFormatOptions |
Option utils for maxwell-json format.
|
| MaxwellJsonSerializationSchema |
Serialization schema from Flink Table/SQL internal data structure
RowData to
maxwell-Json. |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.