@@ -1204,8 +1204,8 @@ core::PlanNodePtr SubstraitToBoltPlanConverter::constructValueStreamNode(
12041204 auto outputType = ROW (std::move (outNames), std::move (boltTypeList));
12051205 int64_t rowCount = 0 ;
12061206 if (readRel.has_advanced_extension () &&
1207- SubstraitParser::configLongValueInOptimization (readRel.advanced_extension (), " rowSize =" ) >= 0 ) {
1208- rowCount = SubstraitParser::configLongValueInOptimization (readRel.advanced_extension (), " rowSize =" );
1207+ SubstraitParser::configLongValueInOptimization (readRel.advanced_extension (), " rowCount =" ) >= 0 ) {
1208+ rowCount = SubstraitParser::configLongValueInOptimization (readRel.advanced_extension (), " rowCount =" );
12091209 }
12101210
12111211 std::shared_ptr<ResultIterator> iterator;
@@ -1376,12 +1376,12 @@ core::PlanNodePtr SubstraitToBoltPlanConverter::toBoltPlan(const ::substrait::Re
13761376 auto tableScanNode =
13771377 std::make_shared<core::TableScanNode>(nextPlanNodeId (), std::move (outputType), tableHandle, assignments);
13781378 if (readRel.has_advanced_extension () &&
1379- SubstraitParser::configLongValueInOptimization (readRel.advanced_extension (), " rowSize =" ) >= 0 ) {
1379+ SubstraitParser::configLongValueInOptimization (readRel.advanced_extension (), " rowCount =" ) >= 0 ) {
13801380 LOG (INFO ) << " table scan node rowcount: "
1381- << SubstraitParser::configLongValueInOptimization (readRel.advanced_extension (), " rowSize =" )
1381+ << SubstraitParser::configLongValueInOptimization (readRel.advanced_extension (), " rowCount =" )
13821382 << std::endl;
13831383 tableScanNode->setRowCount (
1384- SubstraitParser::configLongValueInOptimization (readRel.advanced_extension (), " rowSize =" ));
1384+ SubstraitParser::configLongValueInOptimization (readRel.advanced_extension (), " rowCount =" ));
13851385 }
13861386 // Set split info map.
13871387 splitInfoMap_[tableScanNode->id ()] = splitInfo;
0 commit comments