Skip to content

Commit 80c2cac

Browse files
committed
chore(ci): Advance velox
1 parent bb8dc98 commit 80c2cac

File tree

4 files changed

+6
-6
lines changed

4 files changed

+6
-6
lines changed

presto-native-execution/presto_cpp/main/PrestoServer.cpp

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -841,7 +841,7 @@ void PrestoServer::initializeThreadPools() {
841841
driverExecutor_ = std::make_unique<folly::CPUThreadPoolExecutor>(
842842
numDriverCpuThreads, threadFactory);
843843
driverCpuExecutor_ =
844-
velox::checked_pointer_cast<folly::CPUThreadPoolExecutor>(
844+
velox::checkedPointerCast<folly::CPUThreadPoolExecutor>(
845845
driverExecutor_.get());
846846

847847
const auto numIoThreads = std::max<size_t>(
@@ -861,7 +861,7 @@ void PrestoServer::initializeThreadPools() {
861861
numSpillerCpuThreads,
862862
std::make_shared<folly::NamedThreadFactory>("Spiller"));
863863
spillerCpuExecutor_ =
864-
velox::checked_pointer_cast<folly::CPUThreadPoolExecutor>(
864+
velox::checkedPointerCast<folly::CPUThreadPoolExecutor>(
865865
spillerExecutor_.get());
866866
}
867867
const auto numExchangeHttpClientIoThreads = std::max<size_t>(

presto-native-execution/presto_cpp/main/operators/LocalShuffle.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -487,7 +487,7 @@ LocalShuffleReader::nextSorted(uint64_t maxBytes) {
487487
uint64_t bufferUsed = 0;
488488

489489
while (auto* stream = merge_->next()) {
490-
auto* reader = velox::checked_pointer_cast<SortedFileInputStream>(stream);
490+
auto* reader = velox::checkedPointerCast<SortedFileInputStream>(stream);
491491
const auto data = reader->currentValue();
492492

493493
if (bufferUsed + data.size() > maxBytes) {

presto-native-execution/presto_cpp/main/operators/ShuffleRead.cpp

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -75,7 +75,7 @@ RowVectorPtr ShuffleRead::getOutput() {
7575
VELOX_CHECK_EQ(nextRow_, 0);
7676
size_t numRows{0};
7777
for (const auto& page : currentPages_) {
78-
auto* batch = checked_pointer_cast<ShuffleSerializedPage>(page.get());
78+
auto* batch = checkedPointerCast<ShuffleSerializedPage>(page.get());
7979
VELOX_CHECK_LE(batch->size(), std::numeric_limits<int32_t>::max());
8080
rawInputBytes += page->size();
8181
const auto pageRows = page->numRows().value();
@@ -85,7 +85,7 @@ RowVectorPtr ShuffleRead::getOutput() {
8585
}
8686
rows_.reserve(numRows);
8787
for (const auto& page : currentPages_) {
88-
auto* batch = checked_pointer_cast<ShuffleSerializedPage>(page.get());
88+
auto* batch = checkedPointerCast<ShuffleSerializedPage>(page.get());
8989
const auto& rows = batch->rows();
9090
for (const auto& row : rows) {
9191
rows_.emplace_back(row);

presto-native-execution/velox

Submodule velox updated 130 files

0 commit comments

Comments
 (0)