io.druid.indexing.common.task

Class IndexTask.IndexTuningConfig

java.lang.Object

io.druid.indexing.common.task.IndexTask.IndexTuningConfig

All Implemented Interfaces:

TuningConfig, AppenderatorConfig

Enclosing class:

IndexTask

public static class IndexTask.IndexTuningConfig
extends Object
implements TuningConfig, AppenderatorConfig

Constructor Summary

Constructors

Constructor and Description

IndexTuningConfig(Integer targetPartitionSize, Integer maxRowsInMemory, Long maxTotalRows, Integer rowFlushBoundary_forBackCompatibility, Integer numShards, IndexSpec indexSpec, Integer maxPendingPersists, Boolean buildV9Directly, Boolean forceExtendableShardSpecs, Boolean forceGuaranteedRollup, Boolean reportParseExceptions, Long publishTimeout, Long pushTimeout, SegmentWriteOutMediumFactory segmentWriteOutMediumFactory)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
File	getBasePersistDirectory()
IndexSpec	getIndexSpec()
org.joda.time.Period	getIntermediatePersistPeriod()
int	getMaxPendingPersists()
int	getMaxRowsInMemory()
Long	getMaxTotalRows()
Integer	getNumShards()
long	getPushTimeout()
SegmentWriteOutMediumFactory	getSegmentWriteOutMediumFactory()
Integer	getTargetPartitionSize()
int	hashCode()
boolean	isBuildV9Directly() Deprecated.
boolean	isForceExtendableShardSpecs()
boolean	isForceGuaranteedRollup()
boolean	isReportParseExceptions()
IndexTask.IndexTuningConfig	withBasePersistDirectory(File dir)

Methods inherited from class java.lang.Object

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

Constructor Detail

IndexTuningConfig

public IndexTuningConfig(@Nullable
                         Integer targetPartitionSize,
                         @Nullable
                         Integer maxRowsInMemory,
                         @Nullable
                         Long maxTotalRows,
                         @Nullable
                         Integer rowFlushBoundary_forBackCompatibility,
                         @Nullable
                         Integer numShards,
                         @Nullable
                         IndexSpec indexSpec,
                         @Nullable
                         Integer maxPendingPersists,
                         @Nullable
                         Boolean buildV9Directly,
                         @Nullable
                         Boolean forceExtendableShardSpecs,
                         @Nullable
                         Boolean forceGuaranteedRollup,
                         @Nullable
                         Boolean reportParseExceptions,
                         @Nullable
                         Long publishTimeout,
                         @Nullable
                         Long pushTimeout,
                         @Nullable
                         SegmentWriteOutMediumFactory segmentWriteOutMediumFactory)

Method Detail

withBasePersistDirectory

public IndexTask.IndexTuningConfig withBasePersistDirectory(File dir)

getTargetPartitionSize

public Integer getTargetPartitionSize()

getMaxRowsInMemory

public int getMaxRowsInMemory()

Specified by:

getMaxRowsInMemory in interface AppenderatorConfig

getMaxTotalRows

public Long getMaxTotalRows()

getNumShards

public Integer getNumShards()

getIndexSpec

public IndexSpec getIndexSpec()

Specified by:

getIndexSpec in interface AppenderatorConfig

getBasePersistDirectory

public File getBasePersistDirectory()

Specified by:

getBasePersistDirectory in interface AppenderatorConfig

getMaxPendingPersists

public int getMaxPendingPersists()

Specified by:

getMaxPendingPersists in interface AppenderatorConfig

isBuildV9Directly

@Deprecated
public boolean isBuildV9Directly()

Deprecated.

Always returns true, doesn't affect the version being built.

isForceExtendableShardSpecs

public boolean isForceExtendableShardSpecs()

isForceGuaranteedRollup

public boolean isForceGuaranteedRollup()

isReportParseExceptions

public boolean isReportParseExceptions()

Specified by:

isReportParseExceptions in interface AppenderatorConfig

getPushTimeout

public long getPushTimeout()

getIntermediatePersistPeriod

public org.joda.time.Period getIntermediatePersistPeriod()

Specified by:

getIntermediatePersistPeriod in interface AppenderatorConfig

getSegmentWriteOutMediumFactory

@Nullable
public SegmentWriteOutMediumFactory getSegmentWriteOutMediumFactory()

Specified by:

getSegmentWriteOutMediumFactory in interface AppenderatorConfig

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object