public class RealtimeTuningConfig extends Object implements TuningConfig, AppenderatorConfig
Constructor and Description |
---|
RealtimeTuningConfig(Integer maxRowsInMemory,
org.joda.time.Period intermediatePersistPeriod,
org.joda.time.Period windowPeriod,
File basePersistDirectory,
VersioningPolicy versioningPolicy,
RejectionPolicyFactory rejectionPolicyFactory,
Integer maxPendingPersists,
ShardSpec shardSpec,
IndexSpec indexSpec,
Boolean buildV9Directly,
int persistThreadPriority,
int mergeThreadPriority,
Boolean reportParseExceptions,
Long handoffConditionTimeout,
Long alertTimeout,
SegmentWriteOutMediumFactory segmentWriteOutMediumFactory) |
Modifier and Type | Method and Description |
---|---|
long |
getAlertTimeout() |
File |
getBasePersistDirectory() |
Boolean |
getBuildV9Directly()
Deprecated.
|
long |
getHandoffConditionTimeout() |
IndexSpec |
getIndexSpec() |
org.joda.time.Period |
getIntermediatePersistPeriod() |
int |
getMaxPendingPersists() |
int |
getMaxRowsInMemory() |
int |
getMergeThreadPriority() |
int |
getPersistThreadPriority() |
RejectionPolicyFactory |
getRejectionPolicyFactory() |
SegmentWriteOutMediumFactory |
getSegmentWriteOutMediumFactory() |
ShardSpec |
getShardSpec() |
VersioningPolicy |
getVersioningPolicy() |
org.joda.time.Period |
getWindowPeriod() |
boolean |
isReportParseExceptions() |
static RealtimeTuningConfig |
makeDefaultTuningConfig(File basePersistDirectory) |
RealtimeTuningConfig |
withBasePersistDirectory(File dir) |
RealtimeTuningConfig |
withVersioningPolicy(VersioningPolicy policy) |
public RealtimeTuningConfig(Integer maxRowsInMemory, org.joda.time.Period intermediatePersistPeriod, org.joda.time.Period windowPeriod, File basePersistDirectory, VersioningPolicy versioningPolicy, RejectionPolicyFactory rejectionPolicyFactory, Integer maxPendingPersists, ShardSpec shardSpec, IndexSpec indexSpec, Boolean buildV9Directly, int persistThreadPriority, int mergeThreadPriority, Boolean reportParseExceptions, Long handoffConditionTimeout, Long alertTimeout, @Nullable SegmentWriteOutMediumFactory segmentWriteOutMediumFactory)
public static RealtimeTuningConfig makeDefaultTuningConfig(@Nullable File basePersistDirectory)
public int getMaxRowsInMemory()
getMaxRowsInMemory
in interface AppenderatorConfig
public org.joda.time.Period getIntermediatePersistPeriod()
getIntermediatePersistPeriod
in interface AppenderatorConfig
public org.joda.time.Period getWindowPeriod()
public File getBasePersistDirectory()
getBasePersistDirectory
in interface AppenderatorConfig
public VersioningPolicy getVersioningPolicy()
public RejectionPolicyFactory getRejectionPolicyFactory()
public int getMaxPendingPersists()
getMaxPendingPersists
in interface AppenderatorConfig
public ShardSpec getShardSpec()
public IndexSpec getIndexSpec()
getIndexSpec
in interface AppenderatorConfig
@Deprecated public Boolean getBuildV9Directly()
public int getPersistThreadPriority()
public int getMergeThreadPriority()
public boolean isReportParseExceptions()
isReportParseExceptions
in interface AppenderatorConfig
public long getHandoffConditionTimeout()
public long getAlertTimeout()
@Nullable public SegmentWriteOutMediumFactory getSegmentWriteOutMediumFactory()
getSegmentWriteOutMediumFactory
in interface AppenderatorConfig
public RealtimeTuningConfig withVersioningPolicy(VersioningPolicy policy)
public RealtimeTuningConfig withBasePersistDirectory(File dir)
Copyright © 2011–2018. All rights reserved.