Package org.apache.flink.cdc.connectors.oracle.source

Class OracleSourceValueConverters

  • All Implemented Interfaces:
    io.debezium.relational.ValueConverterProvider
    public class OracleSourceValueConverters
extends io.debezium.connector.oracle.OracleValueConverters
    Oracle Value Converters for cdc.

    • Nested Class Summary

      • Nested classes/interfaces inherited from class io.debezium.jdbc.JdbcValueConverters

        io.debezium.jdbc.JdbcValueConverters.BigIntUnsignedMode, io.debezium.jdbc.JdbcValueConverters.DecimalMode

    • Field Summary

      • Fields inherited from class io.debezium.connector.oracle.OracleValueConverters

        EMPTY_BLOB_FUNCTION, EMPTY_CLOB_FUNCTION, HEXTORAW_FUNCTION_END, HEXTORAW_FUNCTION_START, UNAVAILABLE_VALUE

      • Fields inherited from class io.debezium.jdbc.JdbcValueConverters

        adaptiveTimeMicrosecondsPrecisionMode, adaptiveTimePrecisionMode, bigIntUnsignedMode, binaryMode, decimalMode, logger

    • Constructor Summary

      Constructors 
      Constructor Description
      OracleSourceValueConverters​(io.debezium.connector.oracle.OracleConnectorConfig config, io.debezium.connector.oracle.OracleConnection connection)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      io.debezium.relational.ValueConverter converter​(io.debezium.relational.Column column, org.apache.kafka.connect.data.Field fieldDefn)  
      protected Object convertGeometry​(io.debezium.relational.Column column, org.apache.kafka.connect.data.Field fieldDefn, Object data)
      Convert the a value representing a GEOMETRY STRUCT value to a Geometry value used in a SourceRecord.
      org.apache.kafka.connect.data.SchemaBuilder schemaBuilder​(io.debezium.relational.Column column)  

      • Methods inherited from class io.debezium.connector.oracle.OracleValueConverters

        convertBinary, convertBoolean, convertDecimal, convertDouble, convertFloat, convertInteger, convertIntervalDaySecond, convertIntervalYearMonth, convertNumeric, convertNumericAsBigInteger, convertNumericAsInteger, convertNumericAsSmallInt, convertNumericAsTinyInt, convertString, convertTimestampToEpochMicros, convertTimestampToEpochMillis, convertTimestampToEpochMillisAsDate, convertTimestampToEpochNanos, convertTimestampWithZone, convertTinyInt, convertVariableScale, fromOracleTimeClasses, getUnavailableValuePlaceholderBinary, getUnavailableValuePlaceholderString, withScaleAdjustedIfNeeded

      • Methods inherited from class io.debezium.jdbc.JdbcValueConverters

        byteOrderOfBitType, convertBigInt, convertBinaryToBase64, convertBinaryToBytes, convertBinaryToHex, convertBit, convertBits, convertBits, convertDateToEpochDays, convertDateToEpochDaysAsDate, convertReal, convertRowId, convertSmallInt, convertTime, convertTimeToMicrosPastMidnight, convertTimeToMillisPastMidnight, convertTimeToMillisPastMidnightAsDate, convertTimeToNanosPastMidnight, convertTimeWithZone, convertValue, getTimePrecision, handleUnknownData, normalizeBinaryData, padLittleEndian, toBigDecimal, toByteBuffer, unexpectedBinary

    • Constructor Detail

      • OracleSourceValueConverters

        public OracleSourceValueConverters​(io.debezium.connector.oracle.OracleConnectorConfig config,
                                   io.debezium.connector.oracle.OracleConnection connection)

    • Method Detail

      • schemaBuilder

        public org.apache.kafka.connect.data.SchemaBuilder schemaBuilder​(io.debezium.relational.Column column)
        Specified by:
        schemaBuilder in interface io.debezium.relational.ValueConverterProvider
        Overrides:
        schemaBuilder in class io.debezium.connector.oracle.OracleValueConverters

      • converter

        public io.debezium.relational.ValueConverter converter​(io.debezium.relational.Column column,
                                                       org.apache.kafka.connect.data.Field fieldDefn)
        Specified by:
        converter in interface io.debezium.relational.ValueConverterProvider
        Overrides:
        converter in class io.debezium.connector.oracle.OracleValueConverters

      • convertGeometry

        protected Object convertGeometry​(io.debezium.relational.Column column,
                                 org.apache.kafka.connect.data.Field fieldDefn,
                                 Object data)
        Convert the a value representing a GEOMETRY STRUCT value to a Geometry value used in a SourceRecord.
        Parameters:
        column - the column in which the value appears
        fieldDefn - the field definition for the SourceRecord's Schema; never null
        data - the data; may be null
        Returns:
        the converted value, or null if the conversion could not be made and the column allows nulls
        Throws:
        IllegalArgumentException - if the value could not be converted but the column does not allow nulls