File tree Expand file tree Collapse file tree 4 files changed +7
-8
lines changed
Expand file tree Collapse file tree 4 files changed +7
-8
lines changed Original file line number Diff line number Diff line change @@ -840,9 +840,8 @@ void PrestoServer::initializeThreadPools() {
840840
841841 driverExecutor_ = std::make_unique<folly::CPUThreadPoolExecutor>(
842842 numDriverCpuThreads, threadFactory);
843- driverCpuExecutor_ =
844- velox::checked_pointer_cast<folly::CPUThreadPoolExecutor>(
845- driverExecutor_.get ());
843+ driverCpuExecutor_ = velox::checkedPointerCast<folly::CPUThreadPoolExecutor>(
844+ driverExecutor_.get ());
846845
847846 const auto numIoThreads = std::max<size_t >(
848847 systemConfig->httpServerNumIoThreadsHwMultiplier () * hwConcurrency, 1 );
@@ -861,7 +860,7 @@ void PrestoServer::initializeThreadPools() {
861860 numSpillerCpuThreads,
862861 std::make_shared<folly::NamedThreadFactory>(" Spiller" ));
863862 spillerCpuExecutor_ =
864- velox::checked_pointer_cast <folly::CPUThreadPoolExecutor>(
863+ velox::checkedPointerCast <folly::CPUThreadPoolExecutor>(
865864 spillerExecutor_.get ());
866865 }
867866 const auto numExchangeHttpClientIoThreads = std::max<size_t >(
Original file line number Diff line number Diff 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) {
Original file line number Diff line number Diff 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);
You can’t perform that action at this time.
0 commit comments