summaryrefslogtreecommitdiff
path: root/src/mongo/db/exec/sbe/stages/column_scan.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/exec/sbe/stages/column_scan.cpp')
-rw-r--r--src/mongo/db/exec/sbe/stages/column_scan.cpp19
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) {