You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@druid.apache.org by gi...@apache.org on 2020/02/08 00:23:48 UTC
[druid] branch master updated (e81230f -> ad8afc5)
This is an automated email from the ASF dual-hosted git repository.
gian pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git.
from e81230f Refactoring some codes around ingestion (#9274)
add ad8afc5 Join filter pushdown initial implementation (#9301)
No new revisions were added by this update.
Summary of changes:
.../segment/QueryableIndexStorageAdapter.java | 12 +-
.../org/apache/druid/segment/filter/AndFilter.java | 20 +
.../apache/druid/segment/filter/BoundFilter.java | 23 +
.../org/apache/druid/segment/filter/Filters.java | 22 +
.../org/apache/druid/segment/filter/InFilter.java | 23 +
.../org/apache/druid/segment/filter/OrFilter.java | 20 +
.../druid/segment/filter/SelectorFilter.java | 32 +
.../join/HashJoinSegmentStorageAdapter.java | 23 +-
.../org/apache/druid/segment/join/Joinable.java | 16 +
.../join/filter/AllNullColumnSelectorFactory.java | 28 +-
.../segment/join/filter/JoinFilterAnalysis.java | 99 ++
.../segment/join/filter/JoinFilterAnalyzer.java | 521 ++++++++
.../JoinFilterColumnCorrelationAnalysis.java | 69 ++
.../druid/segment/join/filter/JoinFilterSplit.java | 98 ++
.../druid/segment/join/lookup/LookupJoinable.java | 26 +
.../segment/join/table/IndexedTableJoinable.java | 41 +
.../segment/virtual/ExpressionVirtualColumn.java | 26 +
.../apache/druid/segment/filter/AndFilterTest.java | 7 +
.../druid/segment/filter/BoundFilterTest.java | 11 +
.../apache/druid/segment/filter/InFilterTest.java | 11 +
.../apache/druid/segment/filter/OrFilterTest.java | 10 +-
.../druid/segment/filter/SelectorFilterTest.java | 7 +
.../BaseHashJoinSegmentStorageAdapterTest.java | 209 ++++
.../join/HashJoinSegmentStorageAdapterTest.java | 212 +---
.../druid/segment/join/JoinFilterAnalyzerTest.java | 1256 ++++++++++++++++++++
.../join/table/RowBasedIndexedTableTest.java | 2 +-
.../src/test/resources/wikipedia/countries.json | 2 +
processing/src/test/resources/wikipedia/data.json | 2 +
.../src/test/resources/wikipedia/regions.json | 2 +
29 files changed, 2620 insertions(+), 210 deletions(-)
copy extensions-core/druid-bloom-filter/src/main/java/org/apache/druid/query/aggregation/bloom/NoopBloomFilterAggregator.java => processing/src/main/java/org/apache/druid/segment/join/filter/AllNullColumnSelectorFactory.java (56%)
create mode 100644 processing/src/main/java/org/apache/druid/segment/join/filter/JoinFilterAnalysis.java
create mode 100644 processing/src/main/java/org/apache/druid/segment/join/filter/JoinFilterAnalyzer.java
create mode 100644 processing/src/main/java/org/apache/druid/segment/join/filter/JoinFilterColumnCorrelationAnalysis.java
create mode 100644 processing/src/main/java/org/apache/druid/segment/join/filter/JoinFilterSplit.java
copy core/src/test/java/org/apache/druid/java/util/metrics/JvmPidDiscovererTest.java => processing/src/test/java/org/apache/druid/segment/filter/OrFilterTest.java (78%)
create mode 100644 processing/src/test/java/org/apache/druid/segment/join/BaseHashJoinSegmentStorageAdapterTest.java
create mode 100644 processing/src/test/java/org/apache/druid/segment/join/JoinFilterAnalyzerTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@druid.apache.org
For additional commands, e-mail: commits-help@druid.apache.org