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, SegmentWriteOutMediumFactory segmentWriteOutMediumFactory)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaTuningConfig

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

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

@Deprecated
public int getMaxPendingPersists()

Deprecated.

Specified by:

getMaxPendingPersists in interface AppenderatorConfig

getIndexSpec

public IndexSpec getIndexSpec()

Specified by:

getIndexSpec in interface AppenderatorConfig

getBuildV9Directly

@Deprecated
public boolean getBuildV9Directly()

Deprecated.

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

isReportParseExceptions

public boolean isReportParseExceptions()

Specified by:

isReportParseExceptions in interface AppenderatorConfig

getHandoffConditionTimeout

public long getHandoffConditionTimeout()

isResetOffsetAutomatically

public boolean isResetOffsetAutomatically()

getSegmentWriteOutMediumFactory

@Nullable
public SegmentWriteOutMediumFactory getSegmentWriteOutMediumFactory()

Specified by:

getSegmentWriteOutMediumFactory in interface AppenderatorConfig

withBasePersistDirectory

public KafkaTuningConfig withBasePersistDirectory(File dir)

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