Skip to content

Commit

Permalink
Fix spotless
Browse files Browse the repository at this point in the history
  • Loading branch information
sandynz committed Aug 21, 2024
1 parent 1fd2f4c commit ccb6df8
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -115,7 +115,7 @@ protected void runBlocking() {
try (Connection connection = dataSource.getConnection()) {
if (!Strings.isNullOrEmpty(dumperContext.getQuerySQL()) || !dumperContext.hasUniqueKey()
|| position instanceof PrimaryKeyIngestPosition && null == ((PrimaryKeyIngestPosition<?>) position).getBeginValue()
&& null == ((PrimaryKeyIngestPosition<?>) position).getEndValue()) {
&& null == ((PrimaryKeyIngestPosition<?>) position).getEndValue()) {
dumpWithStreamingQuery(connection);
} else {
dumpPageByPage(connection);
Expand Down Expand Up @@ -347,7 +347,7 @@ private DataRecord loadDataRecord(final ResultSet resultSet, final ResultSetMeta
protected IngestPosition newDataRecordPosition(final ResultSet resultSet) throws SQLException {
return dumperContext.hasUniqueKey()
? PrimaryKeyIngestPositionFactory.newInstance(
resultSet.getObject(dumperContext.getUniqueKeyColumns().get(0).getName()), ((PrimaryKeyIngestPosition<?>) dumperContext.getCommonContext().getPosition()).getEndValue())
resultSet.getObject(dumperContext.getUniqueKeyColumns().get(0).getName()), ((PrimaryKeyIngestPosition<?>) dumperContext.getCommonContext().getPosition()).getEndValue())
: new IngestPlaceholderPosition();
}

Expand Down

0 comments on commit ccb6df8

Please sign in to comment.