public static class IndexTask.IndexTuningConfig extends Object implements TuningConfig, AppenderatorConfig
Constructor and Description |
---|
IndexTuningConfig(Integer targetPartitionSize,
Integer maxRowsInMemory,
Long maxTotalRows,
Integer rowFlushBoundary_forBackCompatibility,
Integer numShards,
IndexSpec indexSpec,
Integer maxPendingPersists,
Boolean buildV9Directly,
Boolean forceExtendableShardSpecs,
Boolean forceGuaranteedRollup,
Boolean reportParseExceptions,
Long publishTimeout,
Long pushTimeout,
SegmentWriteOutMediumFactory segmentWriteOutMediumFactory) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o) |
File |
getBasePersistDirectory() |
IndexSpec |
getIndexSpec() |
org.joda.time.Period |
getIntermediatePersistPeriod() |
int |
getMaxPendingPersists() |
int |
getMaxRowsInMemory() |
Long |
getMaxTotalRows() |
Integer |
getNumShards() |
long |
getPushTimeout() |
SegmentWriteOutMediumFactory |
getSegmentWriteOutMediumFactory() |
Integer |
getTargetPartitionSize() |
int |
hashCode() |
boolean |
isBuildV9Directly()
Deprecated.
|
boolean |
isForceExtendableShardSpecs() |
boolean |
isForceGuaranteedRollup() |
boolean |
isReportParseExceptions() |
IndexTask.IndexTuningConfig |
withBasePersistDirectory(File dir) |
public IndexTuningConfig(@Nullable Integer targetPartitionSize, @Nullable Integer maxRowsInMemory, @Nullable Long maxTotalRows, @Nullable Integer rowFlushBoundary_forBackCompatibility, @Nullable Integer numShards, @Nullable IndexSpec indexSpec, @Nullable Integer maxPendingPersists, @Nullable Boolean buildV9Directly, @Nullable Boolean forceExtendableShardSpecs, @Nullable Boolean forceGuaranteedRollup, @Nullable Boolean reportParseExceptions, @Nullable Long publishTimeout, @Nullable Long pushTimeout, @Nullable SegmentWriteOutMediumFactory segmentWriteOutMediumFactory)
public IndexTask.IndexTuningConfig withBasePersistDirectory(File dir)
public Integer getTargetPartitionSize()
public int getMaxRowsInMemory()
getMaxRowsInMemory
in interface AppenderatorConfig
public Long getMaxTotalRows()
public Integer getNumShards()
public IndexSpec getIndexSpec()
getIndexSpec
in interface AppenderatorConfig
public File getBasePersistDirectory()
getBasePersistDirectory
in interface AppenderatorConfig
public int getMaxPendingPersists()
getMaxPendingPersists
in interface AppenderatorConfig
@Deprecated public boolean isBuildV9Directly()
public boolean isForceExtendableShardSpecs()
public boolean isForceGuaranteedRollup()
public boolean isReportParseExceptions()
isReportParseExceptions
in interface AppenderatorConfig
public long getPushTimeout()
public org.joda.time.Period getIntermediatePersistPeriod()
getIntermediatePersistPeriod
in interface AppenderatorConfig
@Nullable public SegmentWriteOutMediumFactory getSegmentWriteOutMediumFactory()
getSegmentWriteOutMediumFactory
in interface AppenderatorConfig
Copyright © 2011–2018. All rights reserved.