Package org.apache.druid.server.coordinator

Interface DataSourceCompactionConfig

All Known Implementing Classes:

CatalogDataSourceCompactionConfig, InlineSchemaDataSourceCompactionConfig

public interface DataSourceCompactionConfig

Field Summary

Fields

Modifier and Type	Field	Description
static final int	DEFAULT_COMPACTION_TASK_PRIORITY	Must be synced with Tasks.DEFAULT_MERGE_TASK_PRIORITY
static final long	DEFAULT_INPUT_SEGMENT_SIZE_BYTES
static final org.joda.time.Period	DEFAULT_SKIP_OFFSET_FROM_LATEST

Method Summary

Modifier and Type	Method	Description
String	getDataSource()
UserCompactionTaskDimensionsConfig	getDimensionsSpec()
CompactionEngine	getEngine()
UserCompactionTaskGranularityConfig	getGranularitySpec()
long	getInputSegmentSizeBytes()
UserCompactionTaskIOConfig	getIoConfig()
Integer	getMaxRowsPerSegment()	Deprecated.
AggregatorFactory[]	getMetricsSpec()
List<AggregateProjectionSpec>	getProjections()
Granularity	getSegmentGranularity()
org.joda.time.Period	getSkipOffsetFromLatest()
Map<String,Object>	getTaskContext()
int	getTaskPriority()
CompactionTransformSpec	getTransformSpec()
UserCompactionTaskQueryTuningConfig	getTuningConfig()
default CompactionState	toCompactionState()	Converts this compaction config to a CompactionState.
CompactionConfigValidationResult	validate(ClusterCompactionConfig clusterCompactionConfig)	Validates that the compaction config is well-formed and can be executed.

Field Details

DEFAULT_COMPACTION_TASK_PRIORITY

static final int DEFAULT_COMPACTION_TASK_PRIORITY

Must be synced with Tasks.DEFAULT_MERGE_TASK_PRIORITY

See Also:

• Constant Field Values

DEFAULT_INPUT_SEGMENT_SIZE_BYTES

static final long DEFAULT_INPUT_SEGMENT_SIZE_BYTES

See Also:

• Constant Field Values

DEFAULT_SKIP_OFFSET_FROM_LATEST

static final org.joda.time.Period DEFAULT_SKIP_OFFSET_FROM_LATEST

Method Details

getDataSource

String getDataSource()

validate

CompactionConfigValidationResult validate(ClusterCompactionConfig clusterCompactionConfig)

Validates that the compaction config is well-formed and can be executed.

getEngine

@Nullable
CompactionEngine getEngine()

getTaskPriority

int getTaskPriority()

getInputSegmentSizeBytes

long getInputSegmentSizeBytes()

getMaxRowsPerSegment

@Deprecated
@Nullable
Integer getMaxRowsPerSegment()

Deprecated.

getSkipOffsetFromLatest

org.joda.time.Period getSkipOffsetFromLatest()

getTuningConfig

@Nullable
UserCompactionTaskQueryTuningConfig getTuningConfig()

getIoConfig

@Nullable
UserCompactionTaskIOConfig getIoConfig()

getTaskContext

@Nullable
Map<String,Object> getTaskContext()

getSegmentGranularity

@Nullable
Granularity getSegmentGranularity()

getGranularitySpec

@Nullable
UserCompactionTaskGranularityConfig getGranularitySpec()

getProjections

@Nullable
List<AggregateProjectionSpec> getProjections()

getTransformSpec

@Nullable
CompactionTransformSpec getTransformSpec()

getDimensionsSpec

@Nullable
UserCompactionTaskDimensionsConfig getDimensionsSpec()

getMetricsSpec

@Nullable
AggregatorFactory[] getMetricsSpec()

toCompactionState

default CompactionState toCompactionState()

Converts this compaction config to a CompactionState.

For IndexSpec and DimensionsSpec, we convert to their effective specs so that the fingerprint and associated state reflect the actual layout of the segments after compaction (with all missing defaults not included in the compaction config filled in). This is consistent with how DataSegment.lastCompactionState has been computed historically.