public class KafkaTuningConfig extends Object implements TuningConfig, AppenderatorConfig
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) |
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) |
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)
public static KafkaTuningConfig copyOf(KafkaTuningConfig config)
public int getMaxRowsInMemory()
getMaxRowsInMemory
in interface AppenderatorConfig
public int getMaxRowsPerSegment()
public org.joda.time.Period getIntermediatePersistPeriod()
getIntermediatePersistPeriod
in interface AppenderatorConfig
public File getBasePersistDirectory()
getBasePersistDirectory
in interface AppenderatorConfig
@Deprecated public int getMaxPendingPersists()
getMaxPendingPersists
in interface AppenderatorConfig
public IndexSpec getIndexSpec()
getIndexSpec
in interface AppenderatorConfig
@Deprecated public boolean getBuildV9Directly()
public boolean isReportParseExceptions()
isReportParseExceptions
in interface AppenderatorConfig
public long getHandoffConditionTimeout()
public boolean isResetOffsetAutomatically()
@Nullable public SegmentWriteOutMediumFactory getSegmentWriteOutMediumFactory()
getSegmentWriteOutMediumFactory
in interface AppenderatorConfig
public KafkaTuningConfig withBasePersistDirectory(File dir)
Copyright © 2011–2018. All rights reserved.