Skip to content

Commit c1583d1

Browse files
committed
feat(silo): arrow length returns int64_t
1 parent ade2279 commit c1583d1

2 files changed

Lines changed: 3 additions & 3 deletions

File tree

src/silo/query_engine/actions/action.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -347,7 +347,7 @@ arrow::Result<arrow::acero::ExecNode*> Action::addRandomizeColumn(
347347
SILO_ASSERT_NE(rows_in_batch, arrow::Datum::kUnknownLength);
348348

349349
arrow::UInt64Builder randomize_column_builder;
350-
for (size_t i = 0; i < rows_in_batch; ++i) {
350+
for (int64_t i = 0; i < rows_in_batch; ++i) {
351351
uint64_t hash = hash64(start_of_batch + i, randomize_seed);
352352
ARROW_RETURN_NOT_OK(randomize_column_builder.Append(hash));
353353
}

src/silo/query_engine/exec_node/throttled_batch_reslicer.h

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@ using arrow::acero::BackpressureMonitor;
1616

1717
class ThrottledBatchReslicer {
1818
arrow::AsyncGenerator<std::optional<arrow::ExecBatch>> input_batches;
19-
size_t batch_size;
19+
int64_t batch_size;
2020
std::chrono::milliseconds target_batch_rate;
2121
BackpressureMonitor* backpressure_monitor;
2222

@@ -29,7 +29,7 @@ class ThrottledBatchReslicer {
2929
public:
3030
ThrottledBatchReslicer(
3131
arrow::AsyncGenerator<std::optional<arrow::ExecBatch>> input_batches,
32-
size_t batch_size,
32+
int64_t batch_size,
3333
std::chrono::milliseconds target_batch_rate,
3434
BackpressureMonitor* backpressure_monitor
3535
)

0 commit comments

Comments
 (0)