io.druid.segment.indexing

Class RealtimeTuningConfig

java.lang.Object

io.druid.segment.indexing.RealtimeTuningConfig

All Implemented Interfaces:

TuningConfig

public class RealtimeTuningConfig
extends Object
implements TuningConfig

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, io.druid.timeline.partition.ShardSpec shardSpec, IndexSpec indexSpec, Boolean persistInHeap, Boolean ingestOffheap, Integer bufferSize, Float aggregationBufferRatio)

Method Summary

Methods

Modifier and Type	Method and Description
float	getAggregationBufferRatio()
File	getBasePersistDirectory()
int	getBufferSize()
IndexSpec	getIndexSpec()
org.joda.time.Period	getIntermediatePersistPeriod()
int	getMaxPendingPersists()
int	getMaxRowsInMemory()
RejectionPolicyFactory	getRejectionPolicyFactory()
io.druid.timeline.partition.ShardSpec	getShardSpec()
VersioningPolicy	getVersioningPolicy()
org.joda.time.Period	getWindowPeriod()
boolean	isIngestOffheap()
boolean	isPersistInHeap()
static RealtimeTuningConfig	makeDefaultTuningConfig()
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,
                    io.druid.timeline.partition.ShardSpec shardSpec,
                    IndexSpec indexSpec,
                    Boolean persistInHeap,
                    Boolean ingestOffheap,
                    Integer bufferSize,
                    Float aggregationBufferRatio)

Method Detail

makeDefaultTuningConfig

public static RealtimeTuningConfig makeDefaultTuningConfig()

getMaxRowsInMemory

public int getMaxRowsInMemory()

getIntermediatePersistPeriod

public org.joda.time.Period getIntermediatePersistPeriod()

getWindowPeriod

public org.joda.time.Period getWindowPeriod()

getBasePersistDirectory

public File getBasePersistDirectory()

getVersioningPolicy

public VersioningPolicy getVersioningPolicy()

getRejectionPolicyFactory

public RejectionPolicyFactory getRejectionPolicyFactory()

getMaxPendingPersists

public int getMaxPendingPersists()

getShardSpec

public io.druid.timeline.partition.ShardSpec getShardSpec()

getIndexSpec

public IndexSpec getIndexSpec()

isPersistInHeap

public boolean isPersistInHeap()

isIngestOffheap

public boolean isIngestOffheap()

getBufferSize

public int getBufferSize()

getAggregationBufferRatio

public float getAggregationBufferRatio()

withVersioningPolicy

public RealtimeTuningConfig withVersioningPolicy(VersioningPolicy policy)

withBasePersistDirectory

public RealtimeTuningConfig withBasePersistDirectory(File dir)