SourceInfo extends BaseSourceInfo { protected SourceInfo update(Lsn lsn, Instant commitTime, Long txId, TableId tableId, Long xmin) { this.lsn = lsn; if (commitTime != null) { this.timestamp = commitTime; } this.txId = txId; this.xmin = xmin; if (tableId != null && tableId.schema() != null) { this.schemaName = tableId.schema(); } if (tableId != null && tableId.table() != null) { this.tableName = tableId.table(); } return this; } protected  SourceInfo(PostgresConnectorConfig connectorConfig); Lsn lsn(); Long xmin(); @Override SnapshotRecord snapshot(); @Override String toString(); static final String TIMESTAMP_USEC_KEY; static final String TXID_KEY; static final String XMIN_KEY; static final String LSN_KEY; static final String LAST_SNAPSHOT_RECORD_KEY; }
@Test @FixFor("DBZ-934") public void canHandleNullValues() { source.update(null, null, null, null, null); }