org.apache.hadoop.hive.druid.json

Class KafkaTuningConfig

java.lang.Object

org.apache.hadoop.hive.druid.json.KafkaTuningConfig

All Implemented Interfaces:

io.druid.segment.realtime.appenderator.AppenderatorConfig

Direct Known Subclasses:

KafkaSupervisorTuningConfig

public class KafkaTuningConfig
extends Object
implements io.druid.segment.realtime.appenderator.AppenderatorConfig

This class is copied from druid source code in order to avoid adding additional dependencies on druid-indexing-service.

Constructor Summary

Constructors

Constructor and Description
KafkaTuningConfig(Integer maxRowsInMemory, Integer maxRowsPerSegment, org.joda.time.Period intermediatePersistPeriod, File basePersistDirectory, Integer maxPendingPersists, io.druid.segment.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() Deprecated.
long	getHandoffConditionTimeout() Deprecated.
io.druid.segment.IndexSpec	getIndexSpec()
org.joda.time.Period	getIntermediatePersistPeriod()
int	getMaxPendingPersists()
int	getMaxRowsInMemory()
int	getMaxRowsPerSegment()
io.druid.segment.writeout.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(Integer maxRowsInMemory,
                         Integer maxRowsPerSegment,
                         org.joda.time.Period intermediatePersistPeriod,
                         File basePersistDirectory,
                         Integer maxPendingPersists,
                         io.druid.segment.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 io.druid.segment.realtime.appenderator.AppenderatorConfig

getMaxRowsPerSegment

public int getMaxRowsPerSegment()

getIntermediatePersistPeriod

public org.joda.time.Period getIntermediatePersistPeriod()

Specified by:

getIntermediatePersistPeriod in interface io.druid.segment.realtime.appenderator.AppenderatorConfig

getBasePersistDirectory

public File getBasePersistDirectory()

Specified by:

getBasePersistDirectory in interface io.druid.segment.realtime.appenderator.AppenderatorConfig

getSegmentWriteOutMediumFactory

@Nullable
public io.druid.segment.writeout.SegmentWriteOutMediumFactory getSegmentWriteOutMediumFactory()

Specified by:

getSegmentWriteOutMediumFactory in interface io.druid.segment.realtime.appenderator.AppenderatorConfig

getMaxPendingPersists

public int getMaxPendingPersists()

Specified by:

getMaxPendingPersists in interface io.druid.segment.realtime.appenderator.AppenderatorConfig

getIndexSpec

public io.druid.segment.IndexSpec getIndexSpec()

Specified by:

getIndexSpec in interface io.druid.segment.realtime.appenderator.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 io.druid.segment.realtime.appenderator.AppenderatorConfig

getHandoffConditionTimeout

@Deprecated
public long getHandoffConditionTimeout()

Deprecated.

isResetOffsetAutomatically

public boolean isResetOffsetAutomatically()

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