Skip to content

Commit

Permalink
format code
Browse files Browse the repository at this point in the history
  • Loading branch information
gnehil committed Feb 8, 2025
1 parent 41a16cf commit 1879b62
Show file tree
Hide file tree
Showing 2 changed files with 11 additions and 9 deletions.
16 changes: 9 additions & 7 deletions be/src/olap/push_handler.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -683,8 +683,9 @@ Status PushBrokerReader::_get_next_reader() {
return Status::OK();
}

Status PushBrokerReader::_convert_bitmap(vectorized::Block* block, vectorized::ColumnWithTypeAndName& arg,
uint32_t idx, vectorized::DataTypePtr return_type) {
Status PushBrokerReader::_convert_bitmap(vectorized::Block* block,
vectorized::ColumnWithTypeAndName& arg, uint32_t idx,
vectorized::DataTypePtr return_type) {
const vectorized::ColumnPtr& src_column = arg.column;
const vectorized::ColumnPtr& inner_column =
arg.type->is_nullable() ? assert_cast<const vectorized::ColumnNullable&>(*src_column)
Expand Down Expand Up @@ -721,13 +722,14 @@ Status PushBrokerReader::_convert_bitmap(vectorized::Block* block, vectorized::C
"bitmap_from_base64", {arg_base64}, return_type);

RETURN_IF_ERROR(func_bitmap_from_base64->execute(nullptr, *block, {idx}, idx,
arg_base64.column->size()));
arg_base64.column->size()));
block->get_by_position(idx).type = std::move(return_type);
return Status::OK();
}

Status PushBrokerReader::_convert_hll(vectorized::Block* block, vectorized::ColumnWithTypeAndName& arg,
uint32_t idx, vectorized::DataTypePtr return_type) {
Status PushBrokerReader::_convert_hll(vectorized::Block* block,
vectorized::ColumnWithTypeAndName& arg, uint32_t idx,
vectorized::DataTypePtr return_type) {
const vectorized::ColumnPtr& src_column = arg.column;
const vectorized::ColumnPtr& inner_column =
arg.type->is_nullable() ? assert_cast<const vectorized::ColumnNullable&>(*src_column)
Expand Down Expand Up @@ -766,8 +768,8 @@ Status PushBrokerReader::_convert_hll(vectorized::Block* block, vectorized::Colu
auto func_hll_from_base64 = vectorized::SimpleFunctionFactory::instance().get_function(
"hll_from_base64", {arg_base64}, return_type);

RETURN_IF_ERROR(func_hll_from_base64->execute(nullptr, *block, {idx}, idx,
arg_base64.column->size()));
RETURN_IF_ERROR(
func_hll_from_base64->execute(nullptr, *block, {idx}, idx, arg_base64.column->size()));
block->get_by_position(idx).type = std::move(return_type);
return Status::OK();
}
Expand Down
4 changes: 2 additions & 2 deletions be/src/olap/push_handler.h
Original file line number Diff line number Diff line change
Expand Up @@ -107,9 +107,9 @@ class PushBrokerReader {
Status _convert_to_output_block(vectorized::Block* block);
Status _init_expr_ctxes();
Status _convert_bitmap(vectorized::Block* block, vectorized::ColumnWithTypeAndName& arg,
uint32_t idx, vectorized::DataTypePtr return_type);
uint32_t idx, vectorized::DataTypePtr return_type);
Status _convert_hll(vectorized::Block* block, vectorized::ColumnWithTypeAndName& arg,
uint32_t idx, vectorized::DataTypePtr return_type);
uint32_t idx, vectorized::DataTypePtr return_type);

private:
bool _ready;
Expand Down

0 comments on commit 1879b62

Please sign in to comment.