@Override
        protected RecordEmitter<SourceRecords, T, SourceSplitState> createRecordEmitter(
                SourceConfig sourceConfig, SourceReaderMetrics sourceReaderMetrics) {
            return new OracleRecordEmitter<>(
                    deserializationSchema,
                    sourceReaderMetrics,
                    sourceConfig.isIncludeSchemaChanges(),
                    offsetFactory);
        }
The {@link JdbcIncrementalSource} implementation for Oracle.
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/oracle-cdc/src/main/java/org/apache/inlong/sort/cdc/oracle/source/OracleSourceBuilder.java