Test: support push down filter in ut#6573
Conversation
|
[REVIEW NOTIFICATION] This pull request has been approved by:
To complete the pull request process, please ask the reviewers in the list to review by filling The full list of commands accepted by this bot can be found here. DetailsReviewer can indicate their review by submitting an approval review. |
|
/run-all-tests |
|
/run-all-tests |
|
/run-all-tests |
| } | ||
|
|
||
| BlockInputStreamPtr MockStorage::getStreamFromDeltaMerge(Context & context, Int64 id) | ||
| BlockInputStreamPtr MockStorage::getStreamFromDeltaMerge(Context & context, Int64 table_id, const PushDownFilter * push_down_filter) |
There was a problem hiding this comment.
why not use shared_ptr
There was a problem hiding this comment.
why not use
shared_ptr
The filter will be used only once
| BlockInputStreamPtr in = ins[0]; | ||
| in = std::make_shared<FilterBlockInputStream>(in, before_where, filter_column_name, "test"); |
There was a problem hiding this comment.
add a assert for the size of ins
There was a problem hiding this comment.
The size will be changed by num_streams, so I didn't check it.
In future, I will pass num_streams into storage->read()
| } | ||
| CATCH | ||
|
|
||
| TEST_F(FilterExecutorTestRunner, PushDownFilter) |
There was a problem hiding this comment.
maybe need more tests
There was a problem hiding this comment.
maybe need more tests
Ok, I will test more filters
|
/run-all-tests |
Co-authored-by: SeaRise <hhssearise@foxmail.com>
|
/merge |
|
@ywqzzy: It seems you want to merge this PR, I will help you trigger all the tests: /run-all-tests You only need to trigger If you have any questions about the PR merge process, please refer to pr process. DetailsInstructions for interacting with me using PR comments are available here. If you have questions or suggestions related to my behavior, please file an issue against the ti-community-infra/tichi repository. |
|
This pull request has been accepted and is ready to merge. DetailsCommit hash: 1db7ea0 |
|
/run-all-tests |
What problem does this PR solve?
Issue Number: ref #4609
Problem Summary:
We don't push down filter to storage layer in current ut framework.
What is changed and how it works?
In
getStreamFromDeltaMerge, mockDAGQueryInfowithPushDownFilterfromtipb:SelectionCheck List
Tests
Side effects
Documentation
Release note