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, Integer rowFlushBoundary_forBackCompatibility, Integer numShards, IndexSpec indexSpec, Integer maxPendingPersists, Boolean buildV9Directly, Boolean forceExtendableShardSpecs, Boolean reportParseExceptions)

Method Summary

Modifier and Type	Method and Description
File	getBasePersistDirectory()
IndexSpec	getIndexSpec()
org.joda.time.Period	getIntermediatePersistPeriod()
int	getMaxPendingPersists()
int	getMaxRowsInMemory()
Integer	getNumShards()
Integer	getTargetPartitionSize()
boolean	isBuildV9Directly()
boolean	isForceExtendableShardSpecs()
boolean	isReportParseExceptions()
IndexTask.IndexTuningConfig	withBasePersistDirectory(File dir)

Methods inherited from class java.lang.Object

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

Constructor Detail

IndexTuningConfig

public IndexTuningConfig(@Nullable
                         Integer targetPartitionSize,
                         @Nullable
                         Integer maxRowsInMemory,
                         @Nullable
                         Integer rowFlushBoundary_forBackCompatibility,
                         @Nullable
                         Integer numShards,
                         @Nullable
                         IndexSpec indexSpec,
                         @Nullable
                         Integer maxPendingPersists,
                         @Nullable
                         Boolean buildV9Directly,
                         @Nullable
                         Boolean forceExtendableShardSpecs,
                         @Nullable
                         Boolean reportParseExceptions)

Method Detail

withBasePersistDirectory

public IndexTask.IndexTuningConfig withBasePersistDirectory(File dir)

getTargetPartitionSize

public Integer getTargetPartitionSize()

getMaxRowsInMemory

public int getMaxRowsInMemory()

Specified by:

getMaxRowsInMemory in interface AppenderatorConfig

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

public boolean isBuildV9Directly()

isReportParseExceptions

public boolean isReportParseExceptions()

Specified by:

isReportParseExceptions in interface AppenderatorConfig

isForceExtendableShardSpecs

public boolean isForceExtendableShardSpecs()

getIntermediatePersistPeriod

public org.joda.time.Period getIntermediatePersistPeriod()

Specified by:

getIntermediatePersistPeriod in interface AppenderatorConfig