File tree Expand file tree Collapse file tree 3 files changed +4
-4
lines changed
presto_cpp/main/operators Expand file tree Collapse file tree 3 files changed +4
-4
lines changed 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