Package org.apache.druid.timeline

Class CompactionState

java.lang.Object

org.apache.druid.timeline.CompactionState

public class CompactionState
extends Object

This class describes what compaction task spec was used to create a given segment. The compaction task is a task that reads Druid segments and overwrites them with new ones. Since this task always reads segments in the same order, the same task spec will always create the same set of segments (not same segment ID, but same content). Note that this class doesn't include all fields in the compaction task spec. Only the configurations that can affect the content of segment should be included.

See Also:

• DataSegment.lastCompactionState

Constructor Summary

Constructors

Constructor	Description
CompactionState(PartitionsSpec partitionsSpec, DimensionsSpec dimensionsSpec, List<AggregatorFactory> metricsSpec, CompactionTransformSpec transformSpec, IndexSpec indexSpec, GranularitySpec granularitySpec, List<AggregateProjectionSpec> projections)

Method Summary

Modifier and Type	Method	Description
static Function<Set<DataSegment>,Set<DataSegment>>	addCompactionStateToSegments(PartitionsSpec partitionsSpec, DimensionsSpec dimensionsSpec, List<AggregatorFactory> metricsSpec, CompactionTransformSpec transformSpec, IndexSpec indexSpec, GranularitySpec granularitySpec, List<AggregateProjectionSpec> projections)
boolean	equals(Object o)
DimensionsSpec	getDimensionsSpec()
GranularitySpec	getGranularitySpec()
IndexSpec	getIndexSpec()
List<AggregatorFactory>	getMetricsSpec()
PartitionsSpec	getPartitionsSpec()
List<AggregateProjectionSpec>	getProjections()
CompactionTransformSpec	getTransformSpec()
int	hashCode()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

CompactionState

public CompactionState(PartitionsSpec partitionsSpec,
 DimensionsSpec dimensionsSpec,
 List<AggregatorFactory> metricsSpec,
 CompactionTransformSpec transformSpec,
 IndexSpec indexSpec,
 GranularitySpec granularitySpec,
 @Nullable
 List<AggregateProjectionSpec> projections)

Method Details

getPartitionsSpec

public PartitionsSpec getPartitionsSpec()

getDimensionsSpec

public DimensionsSpec getDimensionsSpec()

getMetricsSpec

public List<AggregatorFactory> getMetricsSpec()

getTransformSpec

public CompactionTransformSpec getTransformSpec()

getIndexSpec

public IndexSpec getIndexSpec()

getGranularitySpec

public GranularitySpec getGranularitySpec()

getProjections

@Nullable
public List<AggregateProjectionSpec> getProjections()

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

addCompactionStateToSegments

public static Function<Set<DataSegment>,Set<DataSegment>> addCompactionStateToSegments(PartitionsSpec partitionsSpec,
 DimensionsSpec dimensionsSpec,
 List<AggregatorFactory> metricsSpec,
 CompactionTransformSpec transformSpec,
 IndexSpec indexSpec,
 GranularitySpec granularitySpec,
 @Nullable
 List<AggregateProjectionSpec> projections)