diff --git a/be/src/vec/exec/format/generic_reader.h b/be/src/vec/exec/format/generic_reader.h index 7842f2edb9..beac88f1ab 100644 --- a/be/src/vec/exec/format/generic_reader.h +++ b/be/src/vec/exec/format/generic_reader.h @@ -39,10 +39,6 @@ public: virtual Status get_next_block(Block* block, size_t* read_rows, bool* eof) = 0; - virtual std::unordered_map get_name_to_type() { - std::unordered_map map; - return map; - } virtual Status get_columns(std::unordered_map* name_to_type, std::unordered_set* missing_cols) { return Status::NotSupported("get_columns is not implemented"); diff --git a/be/src/vec/exec/format/orc/vorc_reader.cpp b/be/src/vec/exec/format/orc/vorc_reader.cpp index 21c94bad8c..0254c2b855 100644 --- a/be/src/vec/exec/format/orc/vorc_reader.cpp +++ b/be/src/vec/exec/format/orc/vorc_reader.cpp @@ -991,16 +991,6 @@ TypeDescriptor OrcReader::_convert_to_doris_type(const orc::Type* orc_type) { } } -std::unordered_map OrcReader::get_name_to_type() { - std::unordered_map map; - auto& root_type = _reader->getType(); - for (int i = 0; i < root_type.getSubtypeCount(); ++i) { - map.emplace(_get_field_name_lower_case(&root_type, i), - _convert_to_doris_type(root_type.getSubtype(i))); - } - return map; -} - Status OrcReader::get_columns(std::unordered_map* name_to_type, std::unordered_set* missing_cols) { auto& root_type = _reader->getType(); diff --git a/be/src/vec/exec/format/orc/vorc_reader.h b/be/src/vec/exec/format/orc/vorc_reader.h index 801becf068..5b50166bcb 100644 --- a/be/src/vec/exec/format/orc/vorc_reader.h +++ b/be/src/vec/exec/format/orc/vorc_reader.h @@ -169,7 +169,6 @@ public: int64_t size() const; - std::unordered_map get_name_to_type() override; Status get_columns(std::unordered_map* name_to_type, std::unordered_set* missing_cols) override; diff --git a/be/src/vec/exec/format/parquet/vparquet_reader.cpp b/be/src/vec/exec/format/parquet/vparquet_reader.cpp index 25c1f46aed..dc541cd789 100644 --- a/be/src/vec/exec/format/parquet/vparquet_reader.cpp +++ b/be/src/vec/exec/format/parquet/vparquet_reader.cpp @@ -459,18 +459,6 @@ Status ParquetReader::set_fill_columns( return Status::OK(); } -std::unordered_map ParquetReader::get_name_to_type() { - std::unordered_map map; - const auto& schema_desc = _file_metadata->schema(); - std::unordered_set column_names; - schema_desc.get_column_names(&column_names); - for (auto& name : column_names) { - auto field = schema_desc.get_column(name); - map.emplace(name, field->type); - } - return map; -} - Status ParquetReader::get_parsed_schema(std::vector* col_names, std::vector* col_types) { RETURN_IF_ERROR(_open_file()); diff --git a/be/src/vec/exec/format/parquet/vparquet_reader.h b/be/src/vec/exec/format/parquet/vparquet_reader.h index 57106e7db3..8c763b236f 100644 --- a/be/src/vec/exec/format/parquet/vparquet_reader.h +++ b/be/src/vec/exec/format/parquet/vparquet_reader.h @@ -128,7 +128,6 @@ public: int64_t size() const { return _file_reader->size(); } - std::unordered_map get_name_to_type() override; Status get_columns(std::unordered_map* name_to_type, std::unordered_set* missing_cols) override;