public class KafkaSupervisorTuningConfig extends KafkaTuningConfig
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,
SegmentWriteOutMediumFactory segmentWriteOutMediumFactory,
Integer workerThreads,
Integer chatThreads,
Long chatRetries,
org.joda.time.Period httpTimeout,
org.joda.time.Period shutdownTimeout,
org.joda.time.Period offsetFetchPeriod) |
Modifier and Type | Method and Description |
---|---|
Long |
getChatRetries() |
Integer |
getChatThreads() |
org.joda.time.Duration |
getHttpTimeout() |
org.joda.time.Duration |
getOffsetFetchPeriod() |
org.joda.time.Duration |
getShutdownTimeout() |
Integer |
getWorkerThreads() |
String |
toString() |
copyOf, equals, getBasePersistDirectory, getBuildV9Directly, getHandoffConditionTimeout, getIndexSpec, getIntermediatePersistPeriod, getMaxPendingPersists, getMaxRowsInMemory, getMaxRowsPerSegment, getSegmentWriteOutMediumFactory, hashCode, isReportParseExceptions, isResetOffsetAutomatically, withBasePersistDirectory
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, @Nullable SegmentWriteOutMediumFactory segmentWriteOutMediumFactory, Integer workerThreads, Integer chatThreads, Long chatRetries, org.joda.time.Period httpTimeout, org.joda.time.Period shutdownTimeout, org.joda.time.Period offsetFetchPeriod)
public Integer getWorkerThreads()
public Integer getChatThreads()
public Long getChatRetries()
public org.joda.time.Duration getHttpTimeout()
public org.joda.time.Duration getShutdownTimeout()
public org.joda.time.Duration getOffsetFetchPeriod()
public String toString()
toString
in class KafkaTuningConfig
Copyright © 2011–2018. All rights reserved.