Package org.apache.druid.server.compaction

Class ReindexingDataSchemaRule

java.lang.Object

org.apache.druid.server.compaction.AbstractReindexingRule

org.apache.druid.server.compaction.ReindexingDataSchemaRule

All Implemented Interfaces:

ReindexingRule

public class ReindexingDataSchemaRule
extends AbstractReindexingRule

A ReindexingRule that specifies a data schema for reindexing tasks to configure.

This rule allows users to specify dimensionsspec metricsspec, query granularity, rollup, and projections for reindexing tasks to apply

This is a non-additive rule. Multiple data schema rules cannot be applied to the same interval being reindexed.

Example inline usage:

{@code
 {
   "id": "change-query-granularity-30d",
   "olderThan": "P30D",
   "queryGranularity": "HOUR",
   "rollup": true
 }</pre>

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.druid.server.compaction.ReindexingRule

ReindexingRule.AppliesToMode

Constructor Summary

Constructors

Constructor	Description
ReindexingDataSchemaRule(String id, String description, org.joda.time.Period olderThan, UserCompactionTaskDimensionsConfig dimensionsSpec, AggregatorFactory[] metricsSpec, Granularity queryGranularity, Boolean rollup, List<AggregateProjectionSpec> projections)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
UserCompactionTaskDimensionsConfig	getDimensionsSpec()
AggregatorFactory[]	getMetricsSpec()
List<AggregateProjectionSpec>	getProjections()
Granularity	getQueryGranularity()
Boolean	getRollup()
int	hashCode()
String	toString()

Methods inherited from class org.apache.druid.server.compaction.AbstractReindexingRule

appliesTo, getDescription, getId, getOlderThan

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Details

ReindexingDataSchemaRule

public ReindexingDataSchemaRule(@Nonnull
 String id,
 @Nullable
 String description,
 @Nonnull
 org.joda.time.Period olderThan,
 @Nullable
 UserCompactionTaskDimensionsConfig dimensionsSpec,
 @Nullable
 AggregatorFactory[] metricsSpec,
 @Nullable
 Granularity queryGranularity,
 @Nullable
 Boolean rollup,
 @Nullable
 List<AggregateProjectionSpec> projections)

Method Details

getDimensionsSpec

public UserCompactionTaskDimensionsConfig getDimensionsSpec()

getProjections

public List<AggregateProjectionSpec> getProjections()

getMetricsSpec

public AggregatorFactory[] getMetricsSpec()

getQueryGranularity

public Granularity getQueryGranularity()

getRollup

public Boolean getRollup()

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object