org.apache.druid.segment.realtime.appenderator

Interface AppenderatorConfig

All Known Implementing Classes:

RealtimeTuningConfig

public interface AppenderatorConfig

Method Summary

Modifier and Type	Method and Description
File	getBasePersistDirectory()
IndexSpec	getIndexSpec()
org.joda.time.Period	getIntermediatePersistPeriod() Period that sets frequency to persist to local storage if no other thresholds are met
long	getMaxBytesInMemory() Maximum number of bytes (estimated) to store in memory before persisting to local storage
int	getMaxPendingPersists()
int	getMaxRowsInMemory() Maximum number of rows in memory before persisting to local storage
default int	getMaxRowsPerSegment() Maximum number of rows in a single segment before pushing to deep storage
default Long	getMaxTotalRows() Maximum number of rows across all segments before pushing to deep storage
SegmentWriteOutMediumFactory	getSegmentWriteOutMediumFactory()
boolean	isReportParseExceptions()

Method Detail

isReportParseExceptions

boolean isReportParseExceptions()

getMaxRowsInMemory

int getMaxRowsInMemory()

Maximum number of rows in memory before persisting to local storage

getMaxBytesInMemory

long getMaxBytesInMemory()

Maximum number of bytes (estimated) to store in memory before persisting to local storage

getMaxPendingPersists

int getMaxPendingPersists()

getMaxRowsPerSegment

default int getMaxRowsPerSegment()

Maximum number of rows in a single segment before pushing to deep storage

getMaxTotalRows

@Nullable
default Long getMaxTotalRows()

Maximum number of rows across all segments before pushing to deep storage

getIntermediatePersistPeriod

org.joda.time.Period getIntermediatePersistPeriod()

Period that sets frequency to persist to local storage if no other thresholds are met

getIndexSpec

IndexSpec getIndexSpec()

getBasePersistDirectory

File getBasePersistDirectory()

getSegmentWriteOutMediumFactory

@Nullable
SegmentWriteOutMediumFactory getSegmentWriteOutMediumFactory()