Package io.debezium.connector.oracle.logminer

Class LogMinerChangeRecordEmitter

java.lang.Object

io.debezium.pipeline.AbstractChangeRecordEmitter<P,io.debezium.relational.TableSchema>

io.debezium.relational.RelationalChangeRecordEmitter

io.debezium.connector.oracle.BaseChangeRecordEmitter<Object>

io.debezium.connector.oracle.logminer.LogMinerChangeRecordEmitter

All Implemented Interfaces:

io.debezium.pipeline.spi.ChangeRecordEmitter

public class LogMinerChangeRecordEmitter
extends io.debezium.connector.oracle.BaseChangeRecordEmitter<Object>

Copied from Debezium 1.9.8.Final. Emits change records based on an event read from Oracle LogMiner.

This class add RowId and overrides the emit methods to put rowId in the header.

Nested Class Summary

Nested classes/interfaces inherited from interface io.debezium.pipeline.spi.ChangeRecordEmitter

io.debezium.pipeline.spi.ChangeRecordEmitter.Receiver<P extends io.debezium.pipeline.spi.Partition>

Field Summary

Fields inherited from class io.debezium.connector.oracle.BaseChangeRecordEmitter

table

Fields inherited from class io.debezium.relational.RelationalChangeRecordEmitter

PK_UPDATE_NEWKEY_FIELD, PK_UPDATE_OLDKEY_FIELD

Constructor Summary

Constructors

Constructor	Description
LogMinerChangeRecordEmitter(io.debezium.connector.oracle.OracleConnectorConfig connectorConfig, io.debezium.pipeline.spi.Partition partition, io.debezium.pipeline.spi.OffsetContext offset, io.debezium.connector.oracle.logminer.events.EventType eventType, Object[] oldValues, Object[] newValues, io.debezium.relational.Table table, io.debezium.connector.oracle.OracleDatabaseSchema schema, io.debezium.util.Clock clock, String rowId)
LogMinerChangeRecordEmitter(io.debezium.connector.oracle.OracleConnectorConfig connectorConfig, io.debezium.pipeline.spi.Partition partition, io.debezium.pipeline.spi.OffsetContext offset, io.debezium.data.Envelope.Operation operation, Object[] oldValues, Object[] newValues, io.debezium.relational.Table table, io.debezium.connector.oracle.OracleDatabaseSchema schema, io.debezium.util.Clock clock, String rowId)

Method Summary

Modifier and Type	Method	Description
protected Optional<org.apache.kafka.connect.header.ConnectHeaders>	getEmitConnectHeaders()
io.debezium.data.Envelope.Operation	getOperation()

Methods inherited from class io.debezium.connector.oracle.BaseChangeRecordEmitter

emitTruncateRecord, emitUpdateAsPrimaryKeyChangeRecord, getNewColumnValues, getOldColumnValues

Methods inherited from class io.debezium.relational.RelationalChangeRecordEmitter

emitChangeRecords, emitCreateRecord, emitDeleteRecord, emitReadRecord, emitUpdateRecord, skipEmptyMessages

Methods inherited from class io.debezium.pipeline.AbstractChangeRecordEmitter

getClock, getOffset, getPartition

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

LogMinerChangeRecordEmitter

public LogMinerChangeRecordEmitter(io.debezium.connector.oracle.OracleConnectorConfig connectorConfig,
                                   io.debezium.pipeline.spi.Partition partition,
                                   io.debezium.pipeline.spi.OffsetContext offset,
                                   io.debezium.data.Envelope.Operation operation,
                                   Object[] oldValues,
                                   Object[] newValues,
                                   io.debezium.relational.Table table,
                                   io.debezium.connector.oracle.OracleDatabaseSchema schema,
                                   io.debezium.util.Clock clock,
                                   String rowId)

LogMinerChangeRecordEmitter

public LogMinerChangeRecordEmitter(io.debezium.connector.oracle.OracleConnectorConfig connectorConfig,
                                   io.debezium.pipeline.spi.Partition partition,
                                   io.debezium.pipeline.spi.OffsetContext offset,
                                   io.debezium.connector.oracle.logminer.events.EventType eventType,
                                   Object[] oldValues,
                                   Object[] newValues,
                                   io.debezium.relational.Table table,
                                   io.debezium.connector.oracle.OracleDatabaseSchema schema,
                                   io.debezium.util.Clock clock,
                                   String rowId)

Method Detail

getOperation

public io.debezium.data.Envelope.Operation getOperation()

getEmitConnectHeaders

protected Optional<org.apache.kafka.connect.header.ConnectHeaders> getEmitConnectHeaders()

Overrides:

getEmitConnectHeaders in class RelationalChangeRecordEmitter