Skip to content

Commit

Permalink
code format
Browse files Browse the repository at this point in the history
  • Loading branch information
agrgr committed Jan 5, 2025
1 parent 2174c25 commit 49ff7e9
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -1547,8 +1547,7 @@ public Filter sIndexFilter(Map<QualifierKey, Object> qualifierMap) {
/**
* FilterOperations that require both sIndexFilter and FilterExpression
*/
protected static final List<FilterOperation> dualFilterOperations =
Arrays.asList(
protected static final List<FilterOperation> dualFilterOperations = Arrays.asList(
MAP_VAL_EQ_BY_KEY, MAP_VAL_GT_BY_KEY, MAP_VAL_GTEQ_BY_KEY, MAP_VAL_LT_BY_KEY, MAP_VAL_LTEQ_BY_KEY,
MAP_VAL_BETWEEN_BY_KEY, MAP_KEYS_BETWEEN, MAP_VAL_BETWEEN
);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -114,15 +114,15 @@ public Flux<KeyRecord> select(String namespace, String set, String[] binNames, @
&& statement.getFilter() != null
&& SEC_INDEX_ERROR_RESULT_CODES.contains(ae.getResultCode()))
{
return retryWithoutSIndexFilter(namespace, qualifier, statement, ae);
return retryWithoutSIndexFilter(qualifier, statement, ae);
}
// for other exceptions
return Mono.error(throwable);
});
}

private Publisher<? extends KeyRecord> retryWithoutSIndexFilter(String namespace, Qualifier qualifier,
Statement statement, AerospikeException ae) {
private Publisher<? extends KeyRecord> retryWithoutSIndexFilter(Qualifier qualifier, Statement statement,
AerospikeException ae) {
// retry without sIndex filter
log.warn(
"Got secondary index related exception (resultCode: {}), retrying with filter expression only",
Expand Down

0 comments on commit 49ff7e9

Please sign in to comment.