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/22 22:55:04 UTC
[druid] branch master updated (d541cbe -> d886463)
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 d541cbe Support both IndexTuningConfig and ParallelIndexTuningConfig for compaction task (#9222)
add d886463 Add join-related DataSource types, and analysis functionality. (#9235)
No new revisions were added by this update.
Summary of changes:
.../query/CachingClusteredClientBenchmark.java | 2 +-
.../overlord/SingleTaskBackgroundRunner.java | 2 +-
.../java/org/apache/druid/query/BaseQuery.java | 8 +-
.../java/org/apache/druid/query/DataSource.java | 63 ++-
.../org/apache/druid/query/DataSourceUtil.java | 31 --
.../apache/druid/query/DefaultQueryMetrics.java | 20 +-
.../org/apache/druid/query/InlineDataSource.java | 241 +++++++++++
.../org/apache/druid/query/JoinDataSource.java | 212 +++++++++
.../org/apache/druid/query/LookupDataSource.java | 125 ++++++
.../main/java/org/apache/druid/query/Queries.java | 1 +
.../org/apache/druid/query/QueryDataSource.java | 45 +-
.../org/apache/druid/query/TableDataSource.java | 48 +-
.../org/apache/druid/query/UnionDataSource.java | 54 ++-
.../druid/query/planning/DataSourceAnalysis.java | 282 ++++++++++++
.../druid/query/planning/PreJoinableClause.java | 107 +++++
.../apache/druid/segment/join/JoinableClause.java | 5 +-
.../org/apache/druid/segment/join/Joinables.java | 55 +++
.../org/apache/druid/query/DataSourceTest.java | 10 +-
.../apache/druid/query/InlineDataSourceTest.java | 295 +++++++++++++
.../org/apache/druid/query/JoinDataSourceTest.java | 160 +++++++
.../apache/druid/query/LookupDataSourceTest.java | 102 +++++
.../apache/druid/query/QueryDataSourceTest.java | 156 +++++++
.../apache/druid/query/TableDataSourceTest.java | 115 +++++
.../apache/druid/query/UnionDataSourceTest.java | 144 ++++++
.../apache/druid/query/UnionQueryRunnerTest.java | 2 +-
.../query/metadata/SegmentMetadataQueryTest.java | 4 +-
.../query/planning/DataSourceAnalysisTest.java | 482 +++++++++++++++++++++
.../query/planning/PreJoinableClauseTest.java | 71 +++
.../apache/druid/segment/join/JoinablesTest.java | 77 ++++
.../org/apache/druid/client/BrokerServerView.java | 3 +-
.../java/org/apache/druid/client/CacheUtil.java | 154 +++++--
.../druid/client/CachingClusteredClient.java | 4 +-
.../apache/druid/client/CachingQueryRunner.java | 9 +-
.../apache/druid/client/CoordinatorServerView.java | 2 +-
.../apache/druid/client/ResultLevelCacheUtil.java | 90 ----
.../druid/query/ResultLevelCachingQueryRunner.java | 17 +-
.../appenderator/SinkQuerySegmentWalker.java | 7 +
.../druid/server/ClientQuerySegmentWalker.java | 29 +-
.../org/apache/druid/server/QueryLifecycle.java | 4 +-
.../java/org/apache/druid/server/QueryManager.java | 3 +-
.../org/apache/druid/server/QueryResource.java | 2 +-
.../druid/server/coordination/ServerManager.java | 20 +-
.../druid/server/log/LoggingRequestLogger.java | 31 +-
.../server/router/TieredBrokerHostSelector.java | 2 +-
.../org/apache/druid/client/CacheUtilTest.java | 192 ++++++++
.../druid/sql/calcite/rel/DruidOuterQueryRel.java | 5 +-
.../druid/sql/calcite/rel/DruidQueryRel.java | 6 +-
.../org/apache/druid/sql/calcite/rel/DruidRel.java | 6 +-
.../druid/sql/calcite/rel/DruidSemiJoin.java | 10 +-
.../druid/sql/calcite/rel/DruidUnionRel.java | 6 +-
50 files changed, 3252 insertions(+), 269 deletions(-)
delete mode 100644 processing/src/main/java/org/apache/druid/query/DataSourceUtil.java
create mode 100644 processing/src/main/java/org/apache/druid/query/InlineDataSource.java
create mode 100644 processing/src/main/java/org/apache/druid/query/JoinDataSource.java
create mode 100644 processing/src/main/java/org/apache/druid/query/LookupDataSource.java
create mode 100644 processing/src/main/java/org/apache/druid/query/planning/DataSourceAnalysis.java
create mode 100644 processing/src/main/java/org/apache/druid/query/planning/PreJoinableClause.java
create mode 100644 processing/src/main/java/org/apache/druid/segment/join/Joinables.java
create mode 100644 processing/src/test/java/org/apache/druid/query/InlineDataSourceTest.java
create mode 100644 processing/src/test/java/org/apache/druid/query/JoinDataSourceTest.java
create mode 100644 processing/src/test/java/org/apache/druid/query/LookupDataSourceTest.java
create mode 100644 processing/src/test/java/org/apache/druid/query/QueryDataSourceTest.java
create mode 100644 processing/src/test/java/org/apache/druid/query/TableDataSourceTest.java
create mode 100644 processing/src/test/java/org/apache/druid/query/UnionDataSourceTest.java
create mode 100644 processing/src/test/java/org/apache/druid/query/planning/DataSourceAnalysisTest.java
create mode 100644 processing/src/test/java/org/apache/druid/query/planning/PreJoinableClauseTest.java
create mode 100644 processing/src/test/java/org/apache/druid/segment/join/JoinablesTest.java
delete mode 100644 server/src/main/java/org/apache/druid/client/ResultLevelCacheUtil.java
create mode 100644 server/src/test/java/org/apache/druid/client/CacheUtilTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@druid.apache.org
For additional commands, e-mail: commits-help@druid.apache.org