io.druid.indexing.kafka

Class KafkaTuningConfig

java.lang.Object

io.druid.indexing.kafka.KafkaTuningConfig

All Implemented Interfaces:

TuningConfig, AppenderatorConfig

public class KafkaTuningConfig
extends Object
implements TuningConfig, AppenderatorConfig

Constructor Summary

Constructors

Constructor and Description
KafkaTuningConfig(Integer maxRowsInMemory, Integer maxRowsPerSegment, org.joda.time.Period intermediatePersistPeriod, File basePersistDirectory, Integer maxPendingPersists, IndexSpec indexSpec, Boolean buildV9Directly, Boolean reportParseExceptions, Long handoffConditionTimeout)

Method Summary

Modifier and Type	Method and Description
File	getBasePersistDirectory()
boolean	getBuildV9Directly()
long	getHandoffConditionTimeout()
IndexSpec	getIndexSpec()
org.joda.time.Period	getIntermediatePersistPeriod()
int	getMaxPendingPersists()
int	getMaxRowsInMemory()
int	getMaxRowsPerSegment()
boolean	isReportParseExceptions()
KafkaTuningConfig	withBasePersistDirectory(File dir)

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaTuningConfig

public KafkaTuningConfig(Integer maxRowsInMemory,
                         Integer maxRowsPerSegment,
                         org.joda.time.Period intermediatePersistPeriod,
                         File basePersistDirectory,
                         Integer maxPendingPersists,
                         IndexSpec indexSpec,
                         Boolean buildV9Directly,
                         Boolean reportParseExceptions,
                         Long handoffConditionTimeout)

Method Detail

getMaxRowsInMemory

public int getMaxRowsInMemory()

Specified by:

getMaxRowsInMemory in interface AppenderatorConfig

getMaxRowsPerSegment

public int getMaxRowsPerSegment()

getIntermediatePersistPeriod

public org.joda.time.Period getIntermediatePersistPeriod()

Specified by:

getIntermediatePersistPeriod in interface AppenderatorConfig

getBasePersistDirectory

public File getBasePersistDirectory()

Specified by:

getBasePersistDirectory in interface AppenderatorConfig

getMaxPendingPersists

public int getMaxPendingPersists()

Specified by:

getMaxPendingPersists in interface AppenderatorConfig

getIndexSpec

public IndexSpec getIndexSpec()

Specified by:

getIndexSpec in interface AppenderatorConfig

getBuildV9Directly

public boolean getBuildV9Directly()

isReportParseExceptions

public boolean isReportParseExceptions()

Specified by:

isReportParseExceptions in interface AppenderatorConfig

getHandoffConditionTimeout

public long getHandoffConditionTimeout()

withBasePersistDirectory

public KafkaTuningConfig withBasePersistDirectory(File dir)