Uses of Class
org.apache.flink.formats.json.canal.CanalJsonDeserializationSchema.Builder

Packages that use CanalJsonDeserializationSchema.Builder

Package	Description
org.apache.flink.formats.json.canal

Uses of CanalJsonDeserializationSchema.Builder in org.apache.flink.formats.json.canal

Methods in org.apache.flink.formats.json.canal that return CanalJsonDeserializationSchema.Builder

Modifier and Type	Method and Description
static CanalJsonDeserializationSchema.Builder	CanalJsonDeserializationSchema.builder(RowType rowType, TypeInformation<RowData> resultTypeInfo) 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)