Remove ValueStream plan node and operator (oap-project#331)

velox/core/PlanNode.cpp

@@ -653,14 +653,6 @@ void ArrowStreamNode::addDetails(std::stringstream& stream) const {
   // Nothing to add.
 }
 
-const std::vector<PlanNodePtr>& ValueStreamNode::sources() const {
-  return kEmptySources;
-}
-
-void ValueStreamNode::addDetails(std::stringstream& stream) const {
-  // Nothing to add.
-}
-
 const std::vector<PlanNodePtr>& ExchangeNode::sources() const {
   return kEmptySources;
 }

velox/core/PlanNode.h

@@ -18,7 +18,6 @@
 #include "velox/connectors/Connector.h"
 #include "velox/core/Expressions.h"
 #include "velox/core/QueryConfig.h"
-#include "velox/vector/ComplexVectorStream.h"
 #include "velox/vector/arrow/Bridge.h"
 
 struct ArrowArrayStream;
@@ -261,43 +260,6 @@ class ValuesNode : public PlanNode {
   const size_t repeatTimes_;
 };
 
-class ValueStreamNode : public PlanNode {
- public:
-  ValueStreamNode(
-      const PlanNodeId& id,
-      const RowTypePtr& outputType,
-      std::shared_ptr<RowVectorStream> valueStream)
-      : PlanNode(id),
-        outputType_(outputType),
-        valueStream_(std::move(valueStream)) {
-    VELOX_CHECK_NOT_NULL(valueStream_);
-  }
-
-  const RowTypePtr& outputType() const override {
-    return outputType_;
-  }
-
-  const std::vector<PlanNodePtr>& sources() const override;
-
-  const std::shared_ptr<RowVectorStream>& rowVectorStream() const {
-    return valueStream_;
-  }
-
-  std::string_view name() const override {
-    return "ValueStream";
-  }
-
-  folly::dynamic serialize() const override {
-    VELOX_UNSUPPORTED("ValueStream plan node is not serializable");
-  }
-
- private:
-  void addDetails(std::stringstream& stream) const override;
-
-  const RowTypePtr outputType_;
-  std::shared_ptr<RowVectorStream> valueStream_;
-};
-
 class ArrowStreamNode : public PlanNode {
  public:
   ArrowStreamNode(

velox/exec/CMakeLists.txt

@@ -65,7 +65,6 @@ add_library(
   TopNRowNumber.cpp
   Unnest.cpp
   Values.cpp
-  ValueStream.cpp
   VectorHasher.cpp
   Window.cpp
   WindowFunction.cpp

velox/exec/LocalPlanner.cpp

@@ -41,7 +41,6 @@
 #include "velox/exec/TopN.h"
 #include "velox/exec/TopNRowNumber.h"
 #include "velox/exec/Unnest.h"
-#include "velox/exec/ValueStream.h"
 #include "velox/exec/Values.h"
 #include "velox/exec/Window.h"
 
@@ -188,9 +187,6 @@ uint32_t maxDrivers(const DriverFactory& driverFactory) {
       if (!values->isParallelizable()) {
         return 1;
       }
-    } else if (std::dynamic_pointer_cast<const core::ValueStreamNode>(node)) {
-      // ValueStream node must run single-threaded.
-      return 1;
     } else if (std::dynamic_pointer_cast<const core::ArrowStreamNode>(node)) {
       // ArrowStream node must run single-threaded.
       return 1;
@@ -407,11 +403,6 @@ std::shared_ptr<Driver> DriverFactory::createDriver(
         auto valuesNode =
             std::dynamic_pointer_cast<const core::ValuesNode>(planNode)) {
       operators.push_back(std::make_unique<Values>(id, ctx.get(), valuesNode));
-    } else if (
-        auto valueStreamNode =
-            std::dynamic_pointer_cast<const core::ValueStreamNode>(planNode)) {
-      operators.push_back(
-          std::make_unique<ValueStream>(id, ctx.get(), valueStreamNode));
     } else if (
         auto arrowStreamNode =
             std::dynamic_pointer_cast<const core::ArrowStreamNode>(planNode)) {