This is an automated email from the ASF dual-hosted git repository.
capistrant pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git
from 9b4df2f2948 Increase timeout in KubernetesTaskRunnerDockerTest (#19032)
add 94cb12d24e4 Reindexing rule providers with cascading interval based
reindexing (#18939)
No new revisions were added by this update.
Summary of changes:
.../embedded/compact/AutoCompactionTest.java | 2 +-
.../embedded/compact/CompactionSupervisorTest.java | 400 ++++-
indexing-service/pom.xml | 20 +
.../org/apache/druid/guice/SupervisorModule.java | 4 +-
.../common/task/NativeCompactionRunner.java | 8 +
.../compact/CascadingReindexingTemplate.java | 806 ++++++++++
.../compact/CompactionConfigBasedJobTemplate.java | 15 +-
.../indexing/compact/CompactionSupervisorSpec.java | 6 +-
.../indexing/compact/ReindexingConfigBuilder.java | 280 ++++
.../compact/ReindexingConfigOptimizer.java | 55 +
.../compact/ReindexingDeletionRuleOptimizer.java | 251 +++
...mentGranularityTimelineValidationException.java | 81 +
.../task/ClientCompactionTaskQuerySerdeTest.java | 2 +-
.../common/task/CompactionTaskParallelRunTest.java | 8 +-
.../common/task/CompactionTaskRunBase.java | 4 +-
.../indexing/common/task/CompactionTaskTest.java | 4 +-
.../common/task/NativeCompactionRunnerTest.java | 118 ++
.../compact/CascadingReindexingTemplateTest.java | 1653 ++++++++++++++++++++
.../compact/ReindexingConfigBuilderTest.java | 327 ++++
.../ReindexingDeletionRuleOptimizerTest.java | 539 +++++++
.../druid/msq/indexing/MSQCompactionRunner.java | 14 +-
.../org/apache/druid/msq/exec/MSQReplaceTest.java | 25 +-
.../msq/indexing/MSQCompactionRunnerTest.java | 2 +-
.../input/table/DataSegmentWithLocationTest.java | 19 +-
.../segment/transform/CompactionTransformSpec.java | 22 +-
.../transform/CompactionTransformSpecTest.java | 81 +-
.../apache/druid/timeline/CompactionStateTest.java | 10 +-
.../org/apache/druid/timeline/DataSegmentTest.java | 60 +-
.../server/compaction/AbstractReindexingRule.java | 162 ++
.../druid/server/compaction/CompactionStatus.java | 26 +-
.../ComposingReindexingRuleProvider.java | 239 +++
.../DataSourceCompactibleSegmentIterator.java | 2 +-
.../compaction/InlineReindexingRuleProvider.java | 334 ++++
.../server/compaction/IntervalGranularityInfo.java | 95 ++
.../compaction/ReindexingDataSchemaRule.java | 163 ++
.../server/compaction/ReindexingDeletionRule.java | 159 ++
.../server/compaction/ReindexingIOConfigRule.java | 109 ++
.../druid/server/compaction/ReindexingRule.java | 87 ++
.../server/compaction/ReindexingRuleProvider.java | 188 +++
.../ReindexingSegmentGranularityRule.java | 128 ++
.../compaction/ReindexingTuningConfigRule.java | 118 ++
.../InlineSchemaDataSourceCompactionConfig.java | 51 +
.../compaction/AbstractReindexingRuleTest.java | 62 +
.../server/compaction/CompactionStatusTest.java | 107 ++
.../ComposingReindexingRuleProviderTest.java | 503 ++++++
.../InlineReindexingRuleProviderTest.java | 279 ++++
.../compaction/NewestSegmentFirstPolicyTest.java | 10 +-
.../compaction/ReindexingDataSchemaRuleTest.java | 370 +++++
.../compaction/ReindexingDeletionRuleTest.java | 370 +++++
.../compaction/ReindexingIOConfigRuleTest.java | 172 ++
.../ReindexingSegmentGranularityRuleTest.java | 220 +++
.../compaction/ReindexingTuningConfigRuleTest.java | 196 +++
.../coordination/LoadableDataSegmentTest.java | 31 +-
...InlineSchemaDataSourceCompactionConfigTest.java | 32 +-
.../coordinator/duty/CompactSegmentsTest.java | 3 +-
.../druid/server/http/DataSegmentPlusTest.java | 20 +-
56 files changed, 8925 insertions(+), 127 deletions(-)
create mode 100644
indexing-service/src/main/java/org/apache/druid/indexing/compact/CascadingReindexingTemplate.java
create mode 100644
indexing-service/src/main/java/org/apache/druid/indexing/compact/ReindexingConfigBuilder.java
create mode 100644
indexing-service/src/main/java/org/apache/druid/indexing/compact/ReindexingConfigOptimizer.java
create mode 100644
indexing-service/src/main/java/org/apache/druid/indexing/compact/ReindexingDeletionRuleOptimizer.java
create mode 100644
indexing-service/src/main/java/org/apache/druid/indexing/compact/SegmentGranularityTimelineValidationException.java
create mode 100644
indexing-service/src/test/java/org/apache/druid/indexing/common/task/NativeCompactionRunnerTest.java
create mode 100644
indexing-service/src/test/java/org/apache/druid/indexing/compact/CascadingReindexingTemplateTest.java
create mode 100644
indexing-service/src/test/java/org/apache/druid/indexing/compact/ReindexingConfigBuilderTest.java
create mode 100644
indexing-service/src/test/java/org/apache/druid/indexing/compact/ReindexingDeletionRuleOptimizerTest.java
create mode 100644
server/src/main/java/org/apache/druid/server/compaction/AbstractReindexingRule.java
create mode 100644
server/src/main/java/org/apache/druid/server/compaction/ComposingReindexingRuleProvider.java
create mode 100644
server/src/main/java/org/apache/druid/server/compaction/InlineReindexingRuleProvider.java
create mode 100644
server/src/main/java/org/apache/druid/server/compaction/IntervalGranularityInfo.java
create mode 100644
server/src/main/java/org/apache/druid/server/compaction/ReindexingDataSchemaRule.java
create mode 100644
server/src/main/java/org/apache/druid/server/compaction/ReindexingDeletionRule.java
create mode 100644
server/src/main/java/org/apache/druid/server/compaction/ReindexingIOConfigRule.java
create mode 100644
server/src/main/java/org/apache/druid/server/compaction/ReindexingRule.java
create mode 100644
server/src/main/java/org/apache/druid/server/compaction/ReindexingRuleProvider.java
create mode 100644
server/src/main/java/org/apache/druid/server/compaction/ReindexingSegmentGranularityRule.java
create mode 100644
server/src/main/java/org/apache/druid/server/compaction/ReindexingTuningConfigRule.java
create mode 100644
server/src/test/java/org/apache/druid/server/compaction/AbstractReindexingRuleTest.java
create mode 100644
server/src/test/java/org/apache/druid/server/compaction/ComposingReindexingRuleProviderTest.java
create mode 100644
server/src/test/java/org/apache/druid/server/compaction/InlineReindexingRuleProviderTest.java
create mode 100644
server/src/test/java/org/apache/druid/server/compaction/ReindexingDataSchemaRuleTest.java
create mode 100644
server/src/test/java/org/apache/druid/server/compaction/ReindexingDeletionRuleTest.java
create mode 100644
server/src/test/java/org/apache/druid/server/compaction/ReindexingIOConfigRuleTest.java
create mode 100644
server/src/test/java/org/apache/druid/server/compaction/ReindexingSegmentGranularityRuleTest.java
create mode 100644
server/src/test/java/org/apache/druid/server/compaction/ReindexingTuningConfigRuleTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
