diff --git a/be/src/exec/parquet_scanner.h b/be/src/exec/parquet_scanner.h index a34e4a19e6..535d3fe6c5 100644 --- a/be/src/exec/parquet_scanner.h +++ b/be/src/exec/parquet_scanner.h @@ -54,16 +54,20 @@ public: const std::vector& broker_addresses, const std::vector& pre_filter_texprs, ScannerCounter* counter); - ~ParquetScanner(); + ~ParquetScanner() override; // Open this scanner, will initialize information need to - virtual Status open(); + Status open() override; // Get next tuple - virtual Status get_next(Tuple* tuple, MemPool* tuple_pool, bool* eof, bool* fill_tuple); + Status get_next(Tuple* tuple, MemPool* tuple_pool, bool* eof, bool* fill_tuple) override; + + Status get_next(vectorized::Block* block, bool* eof) override { + return Status::NotSupported("Not Implemented get block"); + } // Close this scanner - virtual void close(); + void close() override; protected: // Read next buffer from reader diff --git a/be/src/vec/exec/vparquet_scanner.h b/be/src/vec/exec/vparquet_scanner.h index 754aabc4c3..31749248d5 100644 --- a/be/src/vec/exec/vparquet_scanner.h +++ b/be/src/vec/exec/vparquet_scanner.h @@ -44,12 +44,12 @@ public: const std::vector& broker_addresses, const std::vector& pre_filter_texprs, ScannerCounter* counter); - virtual ~VParquetScanner(); + ~VParquetScanner() override; // Open this scanner, will initialize information need to - Status open(); + Status open() override; - Status get_next(Block* block, bool* eof); + Status get_next(Block* block, bool* eof) override; private: Status _next_arrow_batch();