You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@druid.apache.org by ji...@apache.org on 2020/10/10 00:42:48 UTC
[druid] branch master updated (4c78b51 -> 4d2a92f)
This is an automated email from the ASF dual-hosted git repository.
jihoonson pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git.
from 4c78b51 Update README.md (#10357)
add 4d2a92f Add caching support to join queries (#10366)
No new revisions were added by this update.
Summary of changes:
.../query/CachingClusteredClientBenchmark.java | 5 +-
.../movingaverage/MovingAverageQueryTest.java | 3 +-
.../ServerManagerForQueryRetryTest.java | 7 +-
.../java/org/apache/druid/query/DataSource.java | 10 +-
.../apache/druid/query/GlobalTableDataSource.java | 10 +
.../org/apache/druid/query/InlineDataSource.java | 2 +-
.../org/apache/druid/query/JoinDataSource.java | 8 +-
.../org/apache/druid/query/LookupDataSource.java | 2 +-
.../org/apache/druid/query/QueryDataSource.java | 2 +-
.../org/apache/druid/query/TableDataSource.java | 2 +-
.../org/apache/druid/query/UnionDataSource.java | 2 +-
.../apache/druid/query/cache/CacheKeyBuilder.java | 8 +
.../druid/query/planning/DataSourceAnalysis.java | 8 +
.../druid/query/planning/PreJoinableClause.java | 4 +-
.../druid/segment/join/JoinConditionAnalysis.java | 4 +-
.../join/{Joinables.java => JoinPrefixUtils.java} | 64 +--
.../apache/druid/segment/join/JoinableClause.java | 8 +-
.../apache/druid/segment/join/JoinableFactory.java | 13 +-
...{Joinables.java => JoinableFactoryWrapper.java} | 94 +++--
.../druid/segment/join/MapJoinableFactory.java | 33 +-
.../druid/segment/join/filter/JoinableClauses.java | 4 +-
.../join/table/BroadcastSegmentIndexedTable.java | 23 ++
.../druid/segment/join/table/IndexedTable.java | 21 +
.../join/table/ReferenceCountingIndexedTable.java | 12 +
.../segment/join/table/RowBasedIndexedTable.java | 37 ++
.../apache/druid/query/InlineDataSourceTest.java | 3 +-
.../org/apache/druid/query/JoinDataSourceTest.java | 6 +-
.../apache/druid/query/LookupDataSourceTest.java | 3 +-
.../apache/druid/query/QueryDataSourceTest.java | 6 +-
.../apache/druid/query/TableDataSourceTest.java | 3 +-
.../apache/druid/query/UnionDataSourceTest.java | 3 +-
.../druid/query/cache/CacheKeyBuilderTest.java | 6 +-
.../query/planning/DataSourceAnalysisTest.java | 14 +
.../druid/segment/join/JoinPrefixUtilsTest.java | 77 ++++
.../apache/druid/segment/join/JoinTestHelper.java | 16 +
.../segment/join/JoinableFactoryWrapperTest.java | 434 +++++++++++++++++++++
.../apache/druid/segment/join/JoinablesTest.java | 241 ------------
.../druid/segment/join/MapJoinableFactoryTest.java | 41 ++
.../apache/druid/segment/join/NoopDataSource.java | 2 +-
.../druid/segment/join/NoopJoinableFactory.java | 2 +-
.../table/BroadcastSegmentIndexedTableTest.java | 6 +
.../join/table/RowBasedIndexedTableTest.java | 9 +
.../java/org/apache/druid/client/CacheUtil.java | 2 +-
.../druid/client/CachingClusteredClient.java | 167 +++++---
.../apache/druid/client/CachingQueryRunner.java | 47 ++-
.../druid/query/ResultLevelCachingQueryRunner.java | 1 +
.../join/BroadcastTableJoinableFactory.java | 53 ++-
.../appenderator/SinkQuerySegmentWalker.java | 16 +-
.../druid/server/LocalQuerySegmentWalker.java | 9 +-
.../druid/server/coordination/ServerManager.java | 24 +-
.../org/apache/druid/client/CacheUtilTest.java | 18 +-
.../CachingClusteredClientCacheKeyManagerTest.java | 341 ++++++++++++++++
.../CachingClusteredClientFunctionalityTest.java | 5 +-
.../druid/client/CachingClusteredClientTest.java | 5 +-
.../druid/client/CachingQueryRunnerTest.java | 140 ++++---
.../QueryRunnerBasedOnClusteredClientTestBase.java | 5 +-
...egmentManagerBroadcastJoinIndexedTableTest.java | 57 ++-
.../server/TestClusterQuerySegmentWalker.java | 9 +-
58 files changed, 1600 insertions(+), 557 deletions(-)
copy processing/src/main/java/org/apache/druid/segment/join/{Joinables.java => JoinPrefixUtils.java} (50%)
rename processing/src/main/java/org/apache/druid/segment/join/{Joinables.java => JoinableFactoryWrapper.java} (56%)
create mode 100644 processing/src/test/java/org/apache/druid/segment/join/JoinPrefixUtilsTest.java
create mode 100644 processing/src/test/java/org/apache/druid/segment/join/JoinableFactoryWrapperTest.java
delete mode 100644 processing/src/test/java/org/apache/druid/segment/join/JoinablesTest.java
create mode 100644 server/src/test/java/org/apache/druid/client/CachingClusteredClientCacheKeyManagerTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@druid.apache.org
For additional commands, e-mail: commits-help@druid.apache.org