io.druid.indexing.kafka.supervisor

Class KafkaSupervisorTuningConfig

java.lang.Object

io.druid.indexing.kafka.KafkaTuningConfig

io.druid.indexing.kafka.supervisor.KafkaSupervisorTuningConfig

All Implemented Interfaces:

TuningConfig, AppenderatorConfig

public class KafkaSupervisorTuningConfig
extends KafkaTuningConfig

Constructor Summary

Constructors

Constructor and Description

KafkaSupervisorTuningConfig(Integer maxRowsInMemory, Integer maxRowsPerSegment, org.joda.time.Period intermediatePersistPeriod, File basePersistDirectory, Integer maxPendingPersists, 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)

Method Summary

Modifier and Type	Method and Description
Long	getChatRetries()
Integer	getChatThreads()
org.joda.time.Duration	getHttpTimeout()
org.joda.time.Duration	getShutdownTimeout()
Integer	getWorkerThreads()
String	toString()

Methods inherited from class io.druid.indexing.kafka.KafkaTuningConfig

copyOf, equals, getBasePersistDirectory, getBuildV9Directly, getHandoffConditionTimeout, getIndexSpec, getIntermediatePersistPeriod, getMaxPendingPersists, getMaxRowsInMemory, getMaxRowsPerSegment, hashCode, isReportParseExceptions, isResetOffsetAutomatically, withBasePersistDirectory, withMaxRowsInMemory

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

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

toString

public String toString()

Overrides:

toString in class KafkaTuningConfig