Skip to content

Commit

Permalink
spotless
Browse files Browse the repository at this point in the history
Signed-off-by: Gabriel Fukushima <[email protected]>
  • Loading branch information
gfukushima committed Jan 23, 2025
1 parent 6c895b3 commit 4a4ba8a
Showing 1 changed file with 15 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -158,7 +158,9 @@ public <K, V> Stream<K> streamKeys(final KvStoreColumn<K, V> column) {
return createKeyStream(
column,
iter -> {
if (iter.isValid()) iter.seekToFirst();
if (iter.isValid()) {
iter.seekToFirst();
}
});
}

Expand All @@ -169,7 +171,9 @@ public Stream<ColumnEntry<Bytes, Bytes>> streamRaw(final KvStoreColumn<?, ?> col
return createStreamRaw(
column,
iter -> {
if (iter.isValid()) iter.seekToFirst();
if (iter.isValid()) {
iter.seekToFirst();
}
},
key -> true)
.map(entry -> ColumnEntry.create(Bytes.wrap(entry.getKey()), Bytes.wrap(entry.getValue())));
Expand All @@ -182,7 +186,9 @@ public Stream<Bytes> streamKeysRaw(final KvStoreColumn<?, ?> column) {
return createStreamKeyRaw(
column,
iter -> {
if (iter.isValid()) iter.seekToFirst();
if (iter.isValid()) {
iter.seekToFirst();
}
},
key -> true)
.map(Bytes::wrap);
Expand All @@ -208,7 +214,9 @@ public <K extends Comparable<K>, V> Stream<ColumnEntry<K, V>> stream(
return createStream(
column,
iter -> {
if (iter.isValid()) iter.seek(column.getKeySerializer().serialize(from));
if (iter.isValid()) {
iter.seek(column.getKeySerializer().serialize(from));
}
},
key -> key.compareTo(to) <= 0);
}
Expand All @@ -221,7 +229,9 @@ public <K extends Comparable<K>, V> Stream<K> streamKeys(
return createKeyStream(
column,
iter -> {
if (iter.isValid()) iter.seek(column.getKeySerializer().serialize(from));
if (iter.isValid()) {
iter.seek(column.getKeySerializer().serialize(from));
}
},
key -> key.compareTo(to) <= 0);
}
Expand Down

0 comments on commit 4a4ba8a

Please sign in to comment.