public class RealtimeTuningConfig extends Object implements TuningConfig
Constructor and Description |
---|
RealtimeTuningConfig(Integer maxRowsInMemory,
org.joda.time.Period intermediatePersistPeriod,
org.joda.time.Period windowPeriod,
File basePersistDirectory,
VersioningPolicy versioningPolicy,
RejectionPolicyFactory rejectionPolicyFactory,
Integer maxPendingPersists,
io.druid.timeline.partition.ShardSpec shardSpec,
IndexSpec indexSpec,
Boolean buildV9Directly,
int persistThreadPriority,
int mergeThreadPriority,
Boolean reportParseExceptions) |
Modifier and Type | Method and Description |
---|---|
File |
getBasePersistDirectory() |
Boolean |
getBuildV9Directly() |
IndexSpec |
getIndexSpec() |
org.joda.time.Period |
getIntermediatePersistPeriod() |
int |
getMaxPendingPersists() |
int |
getMaxRowsInMemory() |
int |
getMergeThreadPriority() |
int |
getPersistThreadPriority() |
RejectionPolicyFactory |
getRejectionPolicyFactory() |
io.druid.timeline.partition.ShardSpec |
getShardSpec() |
VersioningPolicy |
getVersioningPolicy() |
org.joda.time.Period |
getWindowPeriod() |
boolean |
isReportParseExceptions() |
static RealtimeTuningConfig |
makeDefaultTuningConfig() |
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, io.druid.timeline.partition.ShardSpec shardSpec, IndexSpec indexSpec, Boolean buildV9Directly, int persistThreadPriority, int mergeThreadPriority, Boolean reportParseExceptions)
public static RealtimeTuningConfig makeDefaultTuningConfig()
public int getMaxRowsInMemory()
public org.joda.time.Period getIntermediatePersistPeriod()
public org.joda.time.Period getWindowPeriod()
public File getBasePersistDirectory()
public VersioningPolicy getVersioningPolicy()
public RejectionPolicyFactory getRejectionPolicyFactory()
public int getMaxPendingPersists()
public io.druid.timeline.partition.ShardSpec getShardSpec()
public IndexSpec getIndexSpec()
public Boolean getBuildV9Directly()
public int getPersistThreadPriority()
public int getMergeThreadPriority()
public boolean isReportParseExceptions()
public RealtimeTuningConfig withVersioningPolicy(VersioningPolicy policy)
public RealtimeTuningConfig withBasePersistDirectory(File dir)
Copyright © 2011–2016. All rights reserved.