Skip to content

Commit e76b789

Browse files
committed
small changes
1 parent 7be968f commit e76b789

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

fluss-client/src/main/java/org/apache/fluss/client/table/scanner/batch/FullScanBatchScanner.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -189,12 +189,12 @@ public void close() throws IOException {
189189

190190
// ---- New BatchScanner API implementations ----
191191
@Override
192-
public java.util.concurrent.CompletableFuture<java.util.List<InternalRow>> snapshotAll() {
192+
public CompletableFuture<List<InternalRow>> snapshotAll() {
193193
return rowsFuture;
194194
}
195195

196196
@Override
197-
public java.util.concurrent.CompletableFuture<java.util.List<InternalRow>> snapshotAllPartition(String partitionName) {
197+
public CompletableFuture<List<InternalRow>> snapshotAllPartition(String partitionName) {
198198
throw new UnsupportedOperationException(
199199
"This scanner is already bound to a specific scope; use TableScan#createBatchScanner(partitionName) then snapshotAll().");
200200
}

fluss-rpc/src/main/proto/FlussApi.proto

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -259,7 +259,7 @@ message LimitScanResponse{
259259
message FullScanRequest {
260260
required int64 table_id = 1;
261261
optional int64 partition_id = 2; // omit or unset for full table when non-partitioned
262-
required int32 bucket_id = 3;
262+
// required int32 bucket_id = 3;
263263
}
264264

265265
message FullScanResponse {

0 commit comments

Comments
 (0)