Package | Description |
---|---|
org.apache.flink.formats.json.canal |
Modifier and Type | Method and Description |
---|---|
static CanalJsonDeserializationSchema.Builder |
CanalJsonDeserializationSchema.builder(DataType physicalDataType,
List<org.apache.flink.formats.json.canal.CanalJsonDecodingFormat.ReadableMetadata> requestedMetadata,
TypeInformation<RowData> producedTypeInfo)
Creates A builder for building a
CanalJsonDeserializationSchema . |
CanalJsonDeserializationSchema.Builder |
CanalJsonDeserializationSchema.Builder.setDatabase(String database) |
CanalJsonDeserializationSchema.Builder |
CanalJsonDeserializationSchema.Builder.setIgnoreParseErrors(boolean ignoreParseErrors) |
CanalJsonDeserializationSchema.Builder |
CanalJsonDeserializationSchema.Builder.setTable(String table) |
CanalJsonDeserializationSchema.Builder |
CanalJsonDeserializationSchema.Builder.setTimestampFormat(TimestampFormat timestampFormat) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.