Package io.debezium.relational

Class SnapshotChangeRecordEmitter<P extends Partition>

java.lang.Object

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

io.debezium.relational.RelationalChangeRecordEmitter<P>

io.debezium.relational.SnapshotChangeRecordEmitter<P>

All Implemented Interfaces:

ChangeRecordEmitter<P>

public class SnapshotChangeRecordEmitter<P extends Partition>
extends RelationalChangeRecordEmitter<P>

Emits change data based on a single row read via JDBC.

Author:

Jiri Pechanec

Nested Class Summary

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

ChangeRecordEmitter.Receiver<P extends Partition>

Field Summary

Fields

Modifier and Type	Field	Description
private final Object[]	row

Fields inherited from class io.debezium.relational.RelationalChangeRecordEmitter

PK_UPDATE_NEWKEY_FIELD, PK_UPDATE_OLDKEY_FIELD

Constructor Summary

Constructors

Constructor	Description
SnapshotChangeRecordEmitter(P partition, OffsetContext offset, Object[] row, io.debezium.util.Clock clock, RelationalDatabaseConnectorConfig connectorConfig)

Method Summary

Modifier and Type	Method	Description
protected Object[]	getNewColumnValues()	Returns the new row state in case of a CREATE or READ.
protected Object[]	getOldColumnValues()	Returns the old row state in case of an UPDATE or DELETE.
Envelope.Operation	getOperation()	Returns the operation done by the represented change.

Methods inherited from class io.debezium.relational.RelationalChangeRecordEmitter

emitChangeRecords, emitCreateRecord, emitDeleteRecord, emitReadRecord, emitTruncateRecord, emitUpdateAsPrimaryKeyChangeRecord, emitUpdateRecord, skipEmptyMessages

Methods inherited from class io.debezium.pipeline.AbstractChangeRecordEmitter

getClock, getOffset, getPartition, skipMessagesWithoutChange

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.debezium.pipeline.spi.ChangeRecordEmitter

ignoreRecord

Field Details

row

private final Object[] row

Constructor Details

SnapshotChangeRecordEmitter

public SnapshotChangeRecordEmitter(P partition,
 OffsetContext offset,
 Object[] row,
 io.debezium.util.Clock clock,
 RelationalDatabaseConnectorConfig connectorConfig)

Method Details

getOperation

public Envelope.Operation getOperation()

Description copied from interface: ChangeRecordEmitter

Returns the operation done by the represented change.

getOldColumnValues

protected Object[] getOldColumnValues()

Description copied from class: RelationalChangeRecordEmitter

Returns the old row state in case of an UPDATE or DELETE.

Specified by:

getOldColumnValues in class RelationalChangeRecordEmitter<P extends Partition>

getNewColumnValues

protected Object[] getNewColumnValues()

Description copied from class: RelationalChangeRecordEmitter

Returns the new row state in case of a CREATE or READ.

Specified by:

getNewColumnValues in class RelationalChangeRecordEmitter<P extends Partition>