Uses of Interface
org.apache.flink.cdc.debezium.table.DeserializationRuntimeConverterFactory
-
-
Uses of DeserializationRuntimeConverterFactory in org.apache.flink.cdc.connectors.mysql.table
Methods in org.apache.flink.cdc.connectors.mysql.table that return DeserializationRuntimeConverterFactory Modifier and Type Method Description static DeserializationRuntimeConverterFactoryMySqlDeserializationConverterFactory. instance() -
Uses of DeserializationRuntimeConverterFactory in org.apache.flink.cdc.connectors.oracle.table
Methods in org.apache.flink.cdc.connectors.oracle.table that return DeserializationRuntimeConverterFactory Modifier and Type Method Description static DeserializationRuntimeConverterFactoryOracleDeserializationConverterFactory. instance() -
Uses of DeserializationRuntimeConverterFactory in org.apache.flink.cdc.connectors.postgres.table
Methods in org.apache.flink.cdc.connectors.postgres.table that return DeserializationRuntimeConverterFactory Modifier and Type Method Description static DeserializationRuntimeConverterFactoryPostgreSQLDeserializationConverterFactory. instance() -
Uses of DeserializationRuntimeConverterFactory in org.apache.flink.cdc.connectors.sqlserver.table
Methods in org.apache.flink.cdc.connectors.sqlserver.table that return DeserializationRuntimeConverterFactory Modifier and Type Method Description static DeserializationRuntimeConverterFactorySqlServerDeserializationConverterFactory. instance() -
Uses of DeserializationRuntimeConverterFactory in org.apache.flink.cdc.debezium.table
Fields in org.apache.flink.cdc.debezium.table declared as DeserializationRuntimeConverterFactory Modifier and Type Field Description static DeserializationRuntimeConverterFactoryDeserializationRuntimeConverterFactory. DEFAULTA user-defined converter factory which always fallback to default converters.Methods in org.apache.flink.cdc.debezium.table with parameters of type DeserializationRuntimeConverterFactory Modifier and Type Method Description static DeserializationRuntimeConverterRowDataDebeziumDeserializeSchema. createConverter(org.apache.flink.table.types.logical.LogicalType type, java.time.ZoneId serverTimeZone, DeserializationRuntimeConverterFactory userDefinedConverterFactory)Creates a runtime converter which is null safe.static DeserializationRuntimeConverterRowDataDebeziumDeserializeSchema. createNotNullConverter(org.apache.flink.table.types.logical.LogicalType type, java.time.ZoneId serverTimeZone, DeserializationRuntimeConverterFactory userDefinedConverterFactory)Creates a runtime converter which assuming input object is not null.RowDataDebeziumDeserializeSchema.BuilderRowDataDebeziumDeserializeSchema.Builder. setUserDefinedConverterFactory(DeserializationRuntimeConverterFactory userDefinedConverterFactory)
-