@Test public void commitLsnIsPresent() { assertThat(source.struct().getString(SourceInfo.COMMIT_LSN_KEY)).isEqualTo(Lsn.valueOf(new byte[]{ 0x02 }).toString()); }
@Override public String toString() { return "SourceInfo [" + "serverName=" + serverName() + ", changeLsn=" + changeLsn + ", commitLsn=" + commitLsn + ", snapshot=" + snapshotRecord + ", sourceTime=" + sourceTime + "]"; }
SourceInfo extends BaseSourceInfo { @Override public String toString() { return "SourceInfo [" + "serverName=" + serverName() + ", changeLsn=" + changeLsn + ", commitLsn=" + commitLsn + ", snapshot=" + snapshotRecord + ", sourceTime=" + sourceTime + "]"; } }
SourceInfo extends BaseSourceInfo { @Override public String toString() { return "SourceInfo [" + "serverName=" + serverName() + ", changeLsn=" + changeLsn + ", commitLsn=" + commitLsn + ", snapshot=" + snapshotRecord + ", sourceTime=" + sourceTime + "]"; } protected  SourceInfo(Db2ConnectorConfig connectorConfig); }
SourceInfo extends BaseSourceInfo { @Override public String toString() { return "SourceInfo [" + "serverName=" + serverName() + ", changeLsn=" + changeLsn + ", commitLsn=" + commitLsn + ", snapshot=" + snapshotRecord + ", sourceTime=" + sourceTime + "]"; } protected  SourceInfo(Db2ConnectorConfig connectorConfig); void setChangeLsn(Lsn lsn); Lsn getChangeLsn(); Lsn getCommitLsn(); void setCommitLsn(Lsn commitLsn); void setSourceTime(Instant instant); TableId getTableId(); void setTableId(TableId tableId); @Override String toString(); }
SourceInfo extends BaseSourceInfo { @Override public String toString() { return "SourceInfo [" + "serverName=" + serverName() + ", changeLsn=" + changeLsn + ", commitLsn=" + commitLsn + ", snapshot=" + snapshotRecord + ", sourceTime=" + sourceTime + "]"; } protected  SourceInfo(Db2ConnectorConfig connectorConfig); void setChangeLsn(Lsn lsn); Lsn getChangeLsn(); Lsn getCommitLsn(); void setCommitLsn(Lsn commitLsn); void setSourceTime(Instant instant); TableId getTableId(); void setTableId(TableId tableId); @Override String toString(); static final String CHANGE_LSN_KEY; static final String COMMIT_LSN_KEY; }