Skip to content

Commit

Permalink
reuse parquet filter push down in ch
Browse files Browse the repository at this point in the history
  • Loading branch information
taiyang-li committed Oct 10, 2023
1 parent a0d3576 commit 8bed5f9
Show file tree
Hide file tree
Showing 2 changed files with 0 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -210,10 +210,6 @@ FormatFile::InputFormatPtr ORCFormatFile::createInputFormat(const DB::Block & he

format_settings.orc.skip_stripes = std::unordered_set<int>(skip_stripe_indices.begin(), skip_stripe_indices.end());
auto input_format = std::make_shared<DB::NativeORCBlockInputFormat>(*file_format->read_buffer, header, format_settings);

std::cout << "create input format:" << filter.has_value() << " " << StackTrace().toString() << std::endl;
if (filter.has_value())
input_format->setKeyCondition(filter->key_condition);
# endif
file_format->input = input_format;
return file_format;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -50,7 +50,6 @@ namespace local_engine
ParquetFormatFile::ParquetFormatFile(
DB::ContextPtr context_, const substrait::ReadRel::LocalFiles::FileOrFiles & file_info_, ReadBufferBuilderPtr read_buffer_builder_)
: FormatFile(context_, file_info_, read_buffer_builder_)
, enable_row_group_maxmin_index(file_info_.parquet().enable_row_group_maxmin_index())
{
}

Expand Down

0 comments on commit 8bed5f9

Please sign in to comment.