io.druid.segment.indexing

Class RealtimeTuningConfig

java.lang.Object

io.druid.segment.indexing.RealtimeTuningConfig

All Implemented Interfaces:

TuningConfig, AppenderatorConfig

public class RealtimeTuningConfig
extends Object
implements TuningConfig, AppenderatorConfig

Constructor Summary

Constructors

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)

Method Summary

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RealtimeTuningConfig

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)

Method Detail

makeDefaultTuningConfig

public static RealtimeTuningConfig makeDefaultTuningConfig(@Nullable
                                                           File basePersistDirectory)

getMaxRowsInMemory

public int getMaxRowsInMemory()

Specified by:

getMaxRowsInMemory in interface AppenderatorConfig

getIntermediatePersistPeriod

public org.joda.time.Period getIntermediatePersistPeriod()

Specified by:

getIntermediatePersistPeriod in interface AppenderatorConfig

getWindowPeriod

public org.joda.time.Period getWindowPeriod()

getBasePersistDirectory

public File getBasePersistDirectory()

Specified by:

getBasePersistDirectory in interface AppenderatorConfig

getVersioningPolicy

public VersioningPolicy getVersioningPolicy()

getRejectionPolicyFactory

public RejectionPolicyFactory getRejectionPolicyFactory()

getMaxPendingPersists

public int getMaxPendingPersists()

Specified by:

getMaxPendingPersists in interface AppenderatorConfig

getShardSpec

public ShardSpec getShardSpec()

getIndexSpec

public IndexSpec getIndexSpec()

Specified by:

getIndexSpec in interface AppenderatorConfig

getBuildV9Directly

@Deprecated
public Boolean getBuildV9Directly()

Deprecated.

Always returns true, doesn't affect the version being built.

getPersistThreadPriority

public int getPersistThreadPriority()

getMergeThreadPriority

public int getMergeThreadPriority()

isReportParseExceptions

public boolean isReportParseExceptions()

Specified by:

isReportParseExceptions in interface AppenderatorConfig

getHandoffConditionTimeout

public long getHandoffConditionTimeout()

getAlertTimeout

public long getAlertTimeout()

getSegmentWriteOutMediumFactory

@Nullable
public SegmentWriteOutMediumFactory getSegmentWriteOutMediumFactory()

Specified by:

getSegmentWriteOutMediumFactory in interface AppenderatorConfig

withVersioningPolicy

public RealtimeTuningConfig withVersioningPolicy(VersioningPolicy policy)

withBasePersistDirectory

public RealtimeTuningConfig withBasePersistDirectory(File dir)