Cleanup ReadFromMergeTree.h

This commit is contained in:
Igor Nikonov 2024-06-25 15:21:44 +00:00
parent 0eff924475
commit 64cfe1628f

View File

@ -199,7 +199,6 @@ public:
AnalysisResultPtr getAnalyzedResult() const { return analyzed_result_ptr; } AnalysisResultPtr getAnalyzedResult() const { return analyzed_result_ptr; }
void setAnalyzedResult(AnalysisResultPtr analyzed_result_ptr_) { analyzed_result_ptr = std::move(analyzed_result_ptr_); } void setAnalyzedResult(AnalysisResultPtr analyzed_result_ptr_) { analyzed_result_ptr = std::move(analyzed_result_ptr_); }
ReadFromMergeTree::AnalysisResult getAnalysisResult() const;
const MergeTreeData::DataPartsVector & getParts() const { return prepared_parts; } const MergeTreeData::DataPartsVector & getParts() const { return prepared_parts; }
const std::vector<AlterConversionsPtr> & getAlterConvertionsForParts() const { return alter_conversions_for_parts; } const std::vector<AlterConversionsPtr> & getAlterConvertionsForParts() const { return alter_conversions_for_parts; }
@ -211,12 +210,6 @@ public:
void applyFilters(ActionDAGNodes added_filter_nodes) override; void applyFilters(ActionDAGNodes added_filter_nodes) override;
ReadType getReadType() const
{
chassert(analyzed_result_ptr);
return analyzed_result_ptr->read_type;
}
private: private:
int getSortDirection() const int getSortDirection() const
{ {
@ -281,6 +274,8 @@ private:
Pipe spreadMarkRangesAmongStreamsFinal( Pipe spreadMarkRangesAmongStreamsFinal(
RangesInDataParts && parts, size_t num_streams, const Names & origin_column_names, const Names & column_names, ActionsDAGPtr & out_projection); RangesInDataParts && parts, size_t num_streams, const Names & origin_column_names, const Names & column_names, ActionsDAGPtr & out_projection);
ReadFromMergeTree::AnalysisResult getAnalysisResult() const;
mutable AnalysisResultPtr analyzed_result_ptr; mutable AnalysisResultPtr analyzed_result_ptr;
VirtualFields shared_virtual_fields; VirtualFields shared_virtual_fields;