Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
20 changes: 12 additions & 8 deletions be/src/exec/broker_scan_node.h
Original file line number Diff line number Diff line change
Expand Up @@ -41,29 +41,33 @@ struct ScannerCounter;
class BrokerScanNode : public ScanNode {
public:
BrokerScanNode(ObjectPool* pool, const TPlanNode& tnode, const DescriptorTbl& descs);
virtual ~BrokerScanNode();
~BrokerScanNode() override;

// Called after create this scan node
virtual Status init(const TPlanNode& tnode, RuntimeState* state = nullptr) override;
Status init(const TPlanNode& tnode, RuntimeState* state = nullptr) override;

// Prepare partition infos & set up timer
virtual Status prepare(RuntimeState* state) override;
Status prepare(RuntimeState* state) override;

// Start broker scan using ParquetScanner or BrokerScanner.
virtual Status open(RuntimeState* state) override;
Status open(RuntimeState* state) override;

// Fill the next row batch by calling next() on the scanner,
virtual Status get_next(RuntimeState* state, RowBatch* row_batch, bool* eos) override;
Status get_next(RuntimeState* state, RowBatch* row_batch, bool* eos) override;

Status get_next(RuntimeState* state, vectorized::Block* block, bool* eos) override {
return Status::NotSupported("Not Implemented get block");
}

// Close the scanner, and report errors.
virtual Status close(RuntimeState* state) override;
Status close(RuntimeState* state) override;

// No use
virtual Status set_scan_ranges(const std::vector<TScanRangeParams>& scan_ranges) override;
Status set_scan_ranges(const std::vector<TScanRangeParams>& scan_ranges) override;

protected:
// Write debug string of this into out.
virtual void debug_string(int indentation_level, std::stringstream* out) const override;
void debug_string(int indentation_level, std::stringstream* out) const override;

// Update process status to one failed status,
// NOTE: Must hold the mutex of this scan node
Expand Down
6 changes: 5 additions & 1 deletion be/src/exec/broker_scanner.h
Original file line number Diff line number Diff line change
Expand Up @@ -56,14 +56,18 @@ class BrokerScanner : public BaseScanner {
const TBrokerScanRangeParams& params, const std::vector<TBrokerRangeDesc>& ranges,
const std::vector<TNetworkAddress>& broker_addresses,
const std::vector<TExpr>& pre_filter_texprs, ScannerCounter* counter);
virtual ~BrokerScanner();
~BrokerScanner() override;

// Open this scanner, will initialize information need to
Status open() override;

// Get next tuple
Status get_next(Tuple* tuple, MemPool* tuple_pool, bool* eof, bool* fill_tuple) override;

Status get_next(std::vector<vectorized::MutableColumnPtr>& columns, bool* eof) override {
return Status::NotSupported("Not Implemented get columns");
}

// Close this scanner
void close() override;

Expand Down