Skip to content

Commit

Permalink
rename
Browse files Browse the repository at this point in the history
  • Loading branch information
SeaRise committed Dec 14, 2021
1 parent b0c54f8 commit 2dbe165
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
4 changes: 2 additions & 2 deletions dbms/src/Flash/Coprocessor/DAGQueryBlockInterpreter.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -933,7 +933,7 @@ void DAGQueryBlockInterpreter::executeExchangeReceiver(DAGPipeline & pipeline)
analyzer = std::make_unique<DAGExpressionAnalyzer>(std::move(source_columns), context);
}

void DAGQueryBlockInterpreter::executeSourceProject(DAGPipeline & pipeline, const tipb::Projection & projection)
void DAGQueryBlockInterpreter::executeSourceProjection(DAGPipeline & pipeline, const tipb::Projection & projection)
{
std::vector<NameAndTypePair> input_columns;
pipeline.streams = input_streams_vec[0];
Expand Down Expand Up @@ -1044,7 +1044,7 @@ void DAGQueryBlockInterpreter::executeImpl(DAGPipeline & pipeline)
}
else if (query_block.source->tp() == tipb::ExecType::TypeProjection)
{
executeSourceProject(pipeline, query_block.source->projection());
executeSourceProjection(pipeline, query_block.source->projection());
recordProfileStreams(pipeline, query_block.source_name);
}
else
Expand Down
2 changes: 1 addition & 1 deletion dbms/src/Flash/Coprocessor/DAGQueryBlockInterpreter.h
Original file line number Diff line number Diff line change
Expand Up @@ -53,7 +53,7 @@ class DAGQueryBlockInterpreter
const google::protobuf::RepeatedPtrField<tipb::Expr> & filters,
String & filter_column_name);
void executeExchangeReceiver(DAGPipeline & pipeline);
void executeSourceProject(DAGPipeline & pipeline, const tipb::Projection & projection);
void executeSourceProjection(DAGPipeline & pipeline, const tipb::Projection & projection);
void executeExtraCastAndSelection(
DAGPipeline & pipeline,
const ExpressionActionsPtr & extra_cast,
Expand Down

0 comments on commit 2dbe165

Please sign in to comment.