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/01/16 21:14:35 UTC
[druid] branch master updated (09efd20 -> a87db7f)
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 09efd20 fix refresh button (#9195)
add a87db7f Add HashJoinSegment, a virtual segment for joins. (#9111)
No new revisions were added by this update.
Summary of changes:
.../apache/druid/common/config/NullHandling.java | 23 +
.../java/org/apache/druid/math/expr/Exprs.java | 71 +
.../druid/common/config/NullHandlingTest.java | 90 ++
.../java/org/apache/druid/math/expr/ExprsTest.java | 99 ++
.../apache/druid/server/lookup/LoadingLookup.java | 38 +-
.../apache/druid/server/lookup/PollingLookup.java | 13 +
processing/pom.xml | 5 +
.../query/dimension/DefaultDimensionSpec.java | 7 +
.../druid/query/dimension/DimensionSpec.java | 6 +
.../query/dimension/ExtractionDimensionSpec.java | 6 +
.../query/dimension/ListFilteredDimensionSpec.java | 7 +
.../druid/query/dimension/LookupDimensionSpec.java | 15 +
.../dimension/PrefixFilteredDimensionSpec.java | 7 +
.../dimension/RegexFilteredDimensionSpec.java | 7 +
.../druid/query/extraction/MapLookupExtractor.java | 12 +
... VectorValueMatcherColumnProcessorFactory.java} | 20 +-
.../druid/query/groupby/GroupByQueryHelper.java | 1 +
.../epinephelinae/RowBasedGrouperHelper.java | 9 +-
...va => GroupByVectorColumnProcessorFactory.java} | 20 +-
.../epinephelinae/vector/VectorGroupByEngine.java | 2 +-
.../apache/druid/query/lookup/LookupExtractor.java | 13 +-
.../timeseries/TimeseriesQueryQueryToolChest.java | 2 +-
.../druid/segment/ColumnProcessorFactory.java | 56 +
.../org/apache/druid/segment/ColumnProcessors.java | 144 ++
.../druid/segment/DimensionHandlerUtils.java | 24 +-
.../segment/QueryableIndexStorageAdapter.java | 16 +-
.../ColumnCapabilities.java => RowAdapter.java} | 28 +-
.../RowBasedColumnSelectorFactory.java | 85 +-
.../org/apache/druid/segment/StorageAdapter.java | 2 -
.../VectorColumnProcessorFactory.java} | 23 +-
.../org/apache/druid/segment/VirtualColumns.java | 25 +-
.../druid/segment/column/ColumnCapabilities.java | 2 +-
.../apache/druid/segment/filter/BoundFilter.java | 4 +-
.../segment/filter/DimensionPredicateFilter.java | 4 +-
.../org/apache/druid/segment/filter/InFilter.java | 4 +-
.../apache/druid/segment/filter/LikeFilter.java | 4 +-
.../druid/segment/filter/SelectorFilter.java | 4 +-
.../segment/incremental/IncrementalIndex.java | 2 +-
.../IncrementalIndexStorageAdapter.java | 6 -
.../org/apache/druid/segment/join/Equality.java | 60 +
.../apache/druid/segment/join/HashJoinEngine.java | 211 +++
.../apache/druid/segment/join/HashJoinSegment.java | 98 ++
.../join/HashJoinSegmentStorageAdapter.java | 279 ++++
.../druid/segment/join/JoinConditionAnalysis.java | 182 +++
.../org/apache/druid/segment/join/JoinMatcher.java | 83 ++
.../org/apache/druid/segment/join/JoinType.java | 89 ++
.../org/apache/druid/segment/join/Joinable.java | 74 ++
.../apache/druid/segment/join/JoinableClause.java | 145 ++
.../join/PossiblyNullColumnValueSelector.java | 86 ++
.../join/PossiblyNullDimensionSelector.java | 191 +++
.../apache/druid/segment/join/PostJoinCursor.java | 121 ++
.../join/lookup/LookupColumnSelectorFactory.java | 113 ++
.../segment/join/lookup/LookupJoinMatcher.java | 312 +++++
.../druid/segment/join/lookup/LookupJoinable.java | 86 ++
.../table/IndexedTable.java} | 51 +-
.../table/IndexedTableColumnSelectorFactory.java | 104 ++
.../table/IndexedTableColumnValueSelector.java | 132 ++
.../join/table/IndexedTableDimensionSelector.java | 144 ++
.../join/table/IndexedTableJoinMatcher.java | 310 +++++
.../segment/join/table/IndexedTableJoinable.java | 78 ++
.../segment/join/table/RowBasedIndexedTable.java | 166 +++
.../join/table/SortedIntIntersectionIterator.java | 98 ++
.../druid/segment/transform/Transformer.java | 2 +-
.../druid/segment/virtual/ExpressionSelectors.java | 3 +-
.../query/extraction/MapLookupExtractorTest.java | 26 +-
.../topn/TopNMetricSpecOptimizationsTest.java | 6 -
.../druid/segment/filter/BaseFilterTest.java | 2 +-
.../join/HashJoinSegmentStorageAdapterTest.java | 1390 ++++++++++++++++++++
.../druid/segment/join/HashJoinSegmentTest.java | 138 ++
.../segment/join/JoinConditionAnalysisTest.java | 293 +++++
.../apache/druid/segment/join/JoinTestHelper.java | 351 +++++
.../druid/segment/join/JoinableClauseTest.java | 113 ++
.../join/PossiblyNullDimensionSelectorTest.java | 143 ++
.../join/table/RowBasedIndexedTableTest.java | 183 +++
.../table/SortedIntIntersectionIteratorTest.java | 106 ++
.../virtual/ExpressionVirtualColumnTest.java | 2 +-
.../src/test/resources/wikipedia/countries.json | 15 +
processing/src/test/resources/wikipedia/data.json | 26 +
.../src/test/resources/wikipedia/regions.json | 17 +
79 files changed, 6755 insertions(+), 180 deletions(-)
create mode 100644 core/src/main/java/org/apache/druid/math/expr/Exprs.java
create mode 100644 core/src/test/java/org/apache/druid/common/config/NullHandlingTest.java
create mode 100644 core/src/test/java/org/apache/druid/math/expr/ExprsTest.java
rename processing/src/main/java/org/apache/druid/query/filter/vector/{VectorValueMatcherColumnStrategizer.java => VectorValueMatcherColumnProcessorFactory.java} (68%)
rename processing/src/main/java/org/apache/druid/query/groupby/epinephelinae/vector/{GroupByVectorColumnStrategizer.java => GroupByVectorColumnProcessorFactory.java} (65%)
create mode 100644 processing/src/main/java/org/apache/druid/segment/ColumnProcessorFactory.java
create mode 100644 processing/src/main/java/org/apache/druid/segment/ColumnProcessors.java
copy processing/src/main/java/org/apache/druid/segment/{column/ColumnCapabilities.java => RowAdapter.java} (51%)
rename processing/src/main/java/org/apache/druid/{query/groupby => segment}/RowBasedColumnSelectorFactory.java (88%)
rename processing/src/main/java/org/apache/druid/{query/dimension/VectorColumnStrategizer.java => segment/VectorColumnProcessorFactory.java} (55%)
create mode 100644 processing/src/main/java/org/apache/druid/segment/join/Equality.java
create mode 100644 processing/src/main/java/org/apache/druid/segment/join/HashJoinEngine.java
create mode 100644 processing/src/main/java/org/apache/druid/segment/join/HashJoinSegment.java
create mode 100644 processing/src/main/java/org/apache/druid/segment/join/HashJoinSegmentStorageAdapter.java
create mode 100644 processing/src/main/java/org/apache/druid/segment/join/JoinConditionAnalysis.java
create mode 100644 processing/src/main/java/org/apache/druid/segment/join/JoinMatcher.java
create mode 100644 processing/src/main/java/org/apache/druid/segment/join/JoinType.java
create mode 100644 processing/src/main/java/org/apache/druid/segment/join/Joinable.java
create mode 100644 processing/src/main/java/org/apache/druid/segment/join/JoinableClause.java
create mode 100644 processing/src/main/java/org/apache/druid/segment/join/PossiblyNullColumnValueSelector.java
create mode 100644 processing/src/main/java/org/apache/druid/segment/join/PossiblyNullDimensionSelector.java
create mode 100644 processing/src/main/java/org/apache/druid/segment/join/PostJoinCursor.java
create mode 100644 processing/src/main/java/org/apache/druid/segment/join/lookup/LookupColumnSelectorFactory.java
create mode 100644 processing/src/main/java/org/apache/druid/segment/join/lookup/LookupJoinMatcher.java
create mode 100644 processing/src/main/java/org/apache/druid/segment/join/lookup/LookupJoinable.java
copy processing/src/main/java/org/apache/druid/segment/{column/ColumnCapabilities.java => join/table/IndexedTable.java} (50%)
create mode 100644 processing/src/main/java/org/apache/druid/segment/join/table/IndexedTableColumnSelectorFactory.java
create mode 100644 processing/src/main/java/org/apache/druid/segment/join/table/IndexedTableColumnValueSelector.java
create mode 100644 processing/src/main/java/org/apache/druid/segment/join/table/IndexedTableDimensionSelector.java
create mode 100644 processing/src/main/java/org/apache/druid/segment/join/table/IndexedTableJoinMatcher.java
create mode 100644 processing/src/main/java/org/apache/druid/segment/join/table/IndexedTableJoinable.java
create mode 100644 processing/src/main/java/org/apache/druid/segment/join/table/RowBasedIndexedTable.java
create mode 100644 processing/src/main/java/org/apache/druid/segment/join/table/SortedIntIntersectionIterator.java
create mode 100644 processing/src/test/java/org/apache/druid/segment/join/HashJoinSegmentStorageAdapterTest.java
create mode 100644 processing/src/test/java/org/apache/druid/segment/join/HashJoinSegmentTest.java
create mode 100644 processing/src/test/java/org/apache/druid/segment/join/JoinConditionAnalysisTest.java
create mode 100644 processing/src/test/java/org/apache/druid/segment/join/JoinTestHelper.java
create mode 100644 processing/src/test/java/org/apache/druid/segment/join/JoinableClauseTest.java
create mode 100644 processing/src/test/java/org/apache/druid/segment/join/PossiblyNullDimensionSelectorTest.java
create mode 100644 processing/src/test/java/org/apache/druid/segment/join/table/RowBasedIndexedTableTest.java
create mode 100644 processing/src/test/java/org/apache/druid/segment/join/table/SortedIntIntersectionIteratorTest.java
create mode 100644 processing/src/test/resources/wikipedia/countries.json
create mode 100644 processing/src/test/resources/wikipedia/data.json
create mode 100644 processing/src/test/resources/wikipedia/regions.json
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@druid.apache.org
For additional commands, e-mail: commits-help@druid.apache.org