Class CanalJsonDeserializationSchema.Builder
- java.lang.Object
-
- org.apache.flink.formats.json.canal.CanalJsonDeserializationSchema.Builder
-
- Enclosing class:
- CanalJsonDeserializationSchema
@Internal public static final class CanalJsonDeserializationSchema.Builder extends Object
A builder for creating aCanalJsonDeserializationSchema.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description CanalJsonDeserializationSchemabuild()CanalJsonDeserializationSchema.BuildersetDatabase(String database)CanalJsonDeserializationSchema.BuildersetIgnoreParseErrors(boolean ignoreParseErrors)CanalJsonDeserializationSchema.BuildersetTable(String table)CanalJsonDeserializationSchema.BuildersetTimestampFormat(org.apache.flink.formats.common.TimestampFormat timestampFormat)
-
-
-
Method Detail
-
setDatabase
public CanalJsonDeserializationSchema.Builder setDatabase(String database)
-
setTable
public CanalJsonDeserializationSchema.Builder setTable(String table)
-
setIgnoreParseErrors
public CanalJsonDeserializationSchema.Builder setIgnoreParseErrors(boolean ignoreParseErrors)
-
setTimestampFormat
public CanalJsonDeserializationSchema.Builder setTimestampFormat(org.apache.flink.formats.common.TimestampFormat timestampFormat)
-
build
public CanalJsonDeserializationSchema build()
-
-