Package org.apache.druid.server.coordinator

Class ClusterCompactionConfig

java.lang.Object

org.apache.druid.server.coordinator.ClusterCompactionConfig

public class ClusterCompactionConfig
extends Object

Cluster-level compaction configs. All fields of this class are nullable. A non-null value denotes that the corresponding field has been explicitly specified.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ClusterCompactionConfig.Builder

Constructor Summary

Constructors

Constructor	Description
ClusterCompactionConfig(Double compactionTaskSlotRatio, Integer maxCompactionTaskSlots, CompactionCandidateSearchPolicy compactionPolicy, Boolean useSupervisors, CompactionEngine engine, Boolean storeCompactionStatePerSegment)

Method Summary

Modifier and Type	Method	Description
static ClusterCompactionConfig.Builder	builder()
boolean	equals(Object o)
CompactionCandidateSearchPolicy	getCompactionPolicy()
double	getCompactionTaskSlotRatio()
CompactionEngine	getEngine()
int	getMaxCompactionTaskSlots()
int	hashCode()
boolean	isStoreCompactionStatePerSegment()	Whether to persist last compaction state directly in segments for backwards compatibility.
boolean	isUseSupervisors()
ClusterCompactionConfig.Builder	toBuilder()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

ClusterCompactionConfig

public ClusterCompactionConfig(@Nullable
 Double compactionTaskSlotRatio,
 @Nullable
 Integer maxCompactionTaskSlots,
 @Nullable
 CompactionCandidateSearchPolicy compactionPolicy,
 @Nullable
 Boolean useSupervisors,
 @Nullable
 CompactionEngine engine,
 @Nullable
 Boolean storeCompactionStatePerSegment)

Method Details

getCompactionTaskSlotRatio

public double getCompactionTaskSlotRatio()

getMaxCompactionTaskSlots

public int getMaxCompactionTaskSlots()

getCompactionPolicy

public CompactionCandidateSearchPolicy getCompactionPolicy()

isUseSupervisors

public boolean isUseSupervisors()

getEngine

public CompactionEngine getEngine()

isStoreCompactionStatePerSegment

public boolean isStoreCompactionStatePerSegment()

Whether to persist last compaction state directly in segments for backwards compatibility.

In a future release this option will be removed and last compaction state will no longer be persisted in segments. Instead, it will only be stored in the metadata store with a fingerprint id that segments will reference. Some operators may want to disable this behavior early to begin saving space in segment metadatastore table entries.

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

toBuilder

public ClusterCompactionConfig.Builder toBuilder()

builder

public static ClusterCompactionConfig.Builder builder()