database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[refactor](shuffle) remove unused code (#12442)

Browse Source
This commit is contained in:
Gabriel
2022-09-08 09:15:25 +08:00
committed by GitHub
parent 018b4b7e1e
commit 41bc6b857d
2 changed files with 0 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
be/src/vec/sink/vdata_stream_sender.cpp
View File

@ -185,22 +185,6 @@ Status VDataStreamSender::Channel::send_block(PBlock* block, bool eos) {
return Status::OK();
}
Status VDataStreamSender::Channel::add_row(Block* block, int row) {
if (_fragment_instance_id.lo == -1) {
return Status::OK();
}
if (_mutable_block.get() == nullptr) {
_mutable_block.reset(new MutableBlock(block->clone_empty()));
}
_mutable_block->add_row(block, row);
if (_mutable_block->rows() == _parent->state()->batch_size()) {
RETURN_IF_ERROR(send_current_block());
}
return Status::OK();
}
Status VDataStreamSender::Channel::add_rows(Block* block, const std::vector<int>& rows) {
if (_fragment_instance_id.lo == -1) {
return Status::OK();

1
be/src/vec/sink/vdata_stream_sender.h
View File

@ -214,7 +214,6 @@ public:
// if batch is nullptr, send the eof packet
Status send_block(PBlock* block, bool eos = false);
Status add_row(Block* block, int row);
Status add_rows(Block* block, const std::vector<int>& row);
Status send_current_block(bool eos = false);