alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-1096 Removing unused parameter

Browse Source
This commit is contained in:
Gunnar Morling 2019-02-04 13:19:20 +01:00 committed by Jiri Pechanec
parent 10c1214291
commit 9fc336dc6d
2 changed files with 3 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
debezium-connector-sqlserver/src/main/java/io/debezium/connector/sqlserver/SqlServerChangeRecordEmitter.java
View File

@ -8,7 +8,6 @@
import io.debezium.data.Envelope.Operation;
import io.debezium.pipeline.spi.OffsetContext;
import io.debezium.relational.RelationalChangeRecordEmitter;
import io.debezium.relational.Table;
import io.debezium.util.Clock;
/**
@ -27,7 +26,7 @@ public class SqlServerChangeRecordEmitter extends RelationalChangeRecordEmitter
private final Object[] data;
private final Object[] dataNext;
public SqlServerChangeRecordEmitter(OffsetContext offset, int operation, Object[] data, Object[] dataNext, Table table, Clock clock) {
public SqlServerChangeRecordEmitter(OffsetContext offset, int operation, Object[] data, Object[] dataNext, Clock clock) {
super(offset, clock);
this.operation = operation;

5
debezium-connector-sqlserver/src/main/java/io/debezium/connector/sqlserver/SqlServerStreamingChangeEventSource.java
View File

@ -36,7 +36,7 @@
*
* <p>The connector uses CDC functionality of SQL Server that is implemented as as a process that monitors
* source table and write changes from the table into the change table.</p>
*
*
* <p>The main loop keeps a pointer to the LSN of changes that were already processed. It queries all change
* tables and get result set of changes. It always finds the smallest LSN across all tables and the change
* is converted into the event message and sent downstream. The process repeats until all result sets are
@ -200,7 +200,6 @@ public void execute(ChangeEventSourceContext context) throws InterruptedExceptio
operation,
data,
dataNext,
schema.tableFor(tableId),
clock
)
);
@ -273,7 +272,7 @@ private ChangeTable[] getCdcTablesToQuery() throws SQLException, InterruptedExce
}
if (schema.tableFor(currentTable.getSourceTableId()) == null) {
LOGGER.info("Table {} is new to be monitored by capture instance {}", currentTable.getSourceTableId(), currentTable.getCaptureInstance());
// We need to read the source table schema - primary key information cannot be obtained from change table
// We need to read the source table schema - nullability information cannot be obtained from change table
dispatcher.dispatchSchemaChangeEvent(
currentTable.getSourceTableId(),
new SqlServerSchemaChangeEventEmitter(