Skip to content

Commit

Permalink
format
Browse files Browse the repository at this point in the history
Signed-off-by: zombee0 <[email protected]>
  • Loading branch information
zombee0 committed Jan 16, 2025
1 parent 70c57ae commit 092016f
Show file tree
Hide file tree
Showing 3 changed files with 6 additions and 6 deletions.
4 changes: 2 additions & 2 deletions be/src/exec/hdfs_scanner.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -187,8 +187,8 @@ Status HdfsScanner::_build_scanner_context() {
opts.pred_tree_params = _runtime_state->fragment_ctx()->pred_tree_params();
ctx.conjuncts_manager = std::make_unique<ScanConjunctsManager>(std::move(opts));
RETURN_IF_ERROR(ctx.conjuncts_manager->parse_conjuncts());
auto* predicate_parser = opts.obj_pool->add(
new ConnectorPredicateParser(&_scanner_params.tuple_desc->decoded_slots()));
auto* predicate_parser =
opts.obj_pool->add(new ConnectorPredicateParser(&_scanner_params.tuple_desc->decoded_slots()));
ASSIGN_OR_RETURN(ctx.predicate_tree,
ctx.conjuncts_manager->get_predicate_tree(predicate_parser, ctx.predicate_free_pool));
ctx.rf_scan_range_pruner = opts.obj_pool->add(
Expand Down
4 changes: 2 additions & 2 deletions be/src/formats/parquet/column_reader_factory.h
Original file line number Diff line number Diff line change
Expand Up @@ -28,8 +28,8 @@ class ColumnReaderFactory {
const TypeDescriptor& col_type,
const TIcebergSchemaField* iceberg_schema_field);

static StatusOr<ColumnReaderPtr> create(ColumnReaderPtr raw_reader, const GlobalDictMap* dict,
const SlotId slot_id, int64_t num_rows);
static StatusOr<ColumnReaderPtr> create(ColumnReaderPtr raw_reader, const GlobalDictMap* dict, const SlotId slot_id,
int64_t num_rows);

private:
// for struct type without schema change
Expand Down
4 changes: 2 additions & 2 deletions be/src/formats/parquet/complex_column_reader.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -128,8 +128,8 @@ Status ListColumnReader::fill_dst_column(ColumnPtr& dst, ColumnPtr& src) {
array_column_dst = down_cast<ArrayColumn*>(dst.get());
}
array_column_dst->offsets_column()->swap_column(*(array_column_src->offsets_column()));
RETURN_IF_ERROR(_element_reader->fill_dst_column(
array_column_dst->elements_column(), array_column_src->elements_column()));
RETURN_IF_ERROR(
_element_reader->fill_dst_column(array_column_dst->elements_column(), array_column_src->elements_column()));
return Status::OK();
}

Expand Down

0 comments on commit 092016f

Please sign in to comment.