diff options
Diffstat (limited to 'src/mongo/db/exec/sbe/stages/column_scan.cpp')
-rw-r--r-- | src/mongo/db/exec/sbe/stages/column_scan.cpp | 19 |
1 files changed, 6 insertions, 13 deletions
diff --git a/src/mongo/db/exec/sbe/stages/column_scan.cpp b/src/mongo/db/exec/sbe/stages/column_scan.cpp index 66da5619ceb..c9b960ace59 100644 --- a/src/mongo/db/exec/sbe/stages/column_scan.cpp +++ b/src/mongo/db/exec/sbe/stages/column_scan.cpp @@ -32,23 +32,10 @@ #include "mongo/db/exec/sbe/expressions/expression.h" #include "mongo/db/exec/sbe/size_estimator.h" -#include "mongo/db/exec/sbe/values/column_store_encoder.h" -#include "mongo/db/exec/sbe/values/columnar.h" #include "mongo/db/index/columns_access_method.h" namespace mongo { namespace sbe { -namespace { -TranslatedCell translateCell(PathView path, const SplitCellView& splitCellView) { - value::ColumnStoreEncoder encoder{}; - SplitCellView::Cursor<value::ColumnStoreEncoder> cellCursor = - splitCellView.subcellValuesGenerator<value::ColumnStoreEncoder>(std::move(encoder)); - return TranslatedCell{splitCellView.arrInfo, path, std::move(cellCursor)}; -} - - -} // namespace - ColumnScanStage::ColumnScanStage(UUID collectionUuid, StringData columnIndexName, std::vector<std::string> paths, @@ -307,6 +294,12 @@ void ColumnScanStage::open(bool reOpen) { _open = true; } +TranslatedCell ColumnScanStage::translateCell(PathView path, const SplitCellView& splitCellView) { + SplitCellView::Cursor<value::ColumnStoreEncoder> cellCursor = + splitCellView.subcellValuesGenerator<value::ColumnStoreEncoder>(&_encoder); + return TranslatedCell{splitCellView.arrInfo, path, std::move(cellCursor)}; +} + void ColumnScanStage::readParentsIntoObj(StringData path, value::Object* outObj, StringDataSet* pathsReadSetOut) { |