org.apache.hadoop.hive.druid.json

Class KafkaSupervisorTuningConfig

java.lang.Object

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

org.apache.hadoop.hive.druid.json.KafkaSupervisorTuningConfig

All Implemented Interfaces:

io.druid.segment.realtime.appenderator.AppenderatorConfig

public class KafkaSupervisorTuningConfig
extends KafkaTuningConfig

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

KafkaSupervisorTuningConfig(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, Integer workerThreads, Integer chatThreads, Long chatRetries, org.joda.time.Period httpTimeout, org.joda.time.Period shutdownTimeout, org.joda.time.Period offsetFetchPeriod)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
Long	getChatRetries()
Integer	getChatThreads()
org.joda.time.Duration	getHttpTimeout()
org.joda.time.Duration	getOffsetFetchPeriod()
org.joda.time.Duration	getShutdownTimeout()
Integer	getWorkerThreads()
int	hashCode()
String	toString()

Methods inherited from class org.apache.hadoop.hive.druid.json.KafkaTuningConfig

copyOf, getBasePersistDirectory, getBuildV9Directly, getHandoffConditionTimeout, getIndexSpec, getIntermediatePersistPeriod, getMaxPendingPersists, getMaxRowsInMemory, getMaxRowsPerSegment, getSegmentWriteOutMediumFactory, isReportParseExceptions, isResetOffsetAutomatically, withBasePersistDirectory

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaSupervisorTuningConfig

public KafkaSupervisorTuningConfig(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,
                                   Integer workerThreads,
                                   Integer chatThreads,
                                   Long chatRetries,
                                   org.joda.time.Period httpTimeout,
                                   org.joda.time.Period shutdownTimeout,
                                   org.joda.time.Period offsetFetchPeriod)

Method Detail

getWorkerThreads

public Integer getWorkerThreads()

getChatThreads

public Integer getChatThreads()

getChatRetries

public Long getChatRetries()

getHttpTimeout

public org.joda.time.Duration getHttpTimeout()

getShutdownTimeout

public org.joda.time.Duration getShutdownTimeout()

getOffsetFetchPeriod

public org.joda.time.Duration getOffsetFetchPeriod()

toString

public String toString()

Overrides:

toString in class KafkaTuningConfig

equals

public boolean equals(Object o)

Overrides:

equals in class KafkaTuningConfig

hashCode

public int hashCode()

Overrides:

hashCode in class KafkaTuningConfig