io.druid.indexing.kafka

Class KafkaTuningConfig

java.lang.Object

io.druid.indexing.kafka.KafkaTuningConfig

All Implemented Interfaces:

TuningConfig, AppenderatorConfig

Direct Known Subclasses:

KafkaSupervisorTuningConfig

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, Boolean resetOffsetAutomatically)

Method Summary

Modifier and Type	Method and Description
static KafkaTuningConfig	copyOf(KafkaTuningConfig config)
boolean	equals(Object o)
File	getBasePersistDirectory()
boolean	getBuildV9Directly()
long	getHandoffConditionTimeout()
IndexSpec	getIndexSpec()
org.joda.time.Period	getIntermediatePersistPeriod()
int	getMaxPendingPersists()
int	getMaxRowsInMemory()
int	getMaxRowsPerSegment()
int	hashCode()
boolean	isReportParseExceptions()
boolean	isResetOffsetAutomatically()
String	toString()
KafkaTuningConfig	withBasePersistDirectory(File dir)
KafkaTuningConfig	withMaxRowsInMemory(int rows)

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, 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,
                         Boolean resetOffsetAutomatically)

Method Detail

copyOf

public static KafkaTuningConfig copyOf(KafkaTuningConfig config)

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()

isResetOffsetAutomatically

public boolean isResetOffsetAutomatically()

withBasePersistDirectory

public KafkaTuningConfig withBasePersistDirectory(File dir)

withMaxRowsInMemory

public KafkaTuningConfig withMaxRowsInMemory(int rows)

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