public class HadoopTuningConfig extends Object implements TuningConfig
Constructor and Description |
---|
HadoopTuningConfig(String workingPath,
String version,
PartitionsSpec partitionsSpec,
Map<Long,List<HadoopyShardSpec>> shardSpecs,
IndexSpec indexSpec,
Integer maxRowsInMemory,
boolean leaveIntermediate,
Boolean cleanupOnFailure,
boolean overwriteFiles,
boolean ignoreInvalidRows,
Map<String,String> jobProperties,
boolean combineText,
Boolean useCombiner,
Integer maxRowsInMemoryCOMPAT,
Boolean buildV9Directly,
Integer numBackgroundPersistThreads,
boolean forceExtendableShardSpecs,
boolean useExplicitVersion,
List<String> allowedHadoopPrefix) |
Modifier and Type | Method and Description |
---|---|
Boolean |
getBuildV9Directly()
Deprecated.
|
IndexSpec |
getIndexSpec() |
Map<String,String> |
getJobProperties() |
int |
getNumBackgroundPersistThreads() |
PartitionsSpec |
getPartitionsSpec() |
int |
getRowFlushBoundary() |
Map<Long,List<HadoopyShardSpec>> |
getShardSpecs() |
boolean |
getUseCombiner() |
List<String> |
getUserAllowedHadoopPrefix() |
String |
getVersion() |
String |
getWorkingPath() |
Boolean |
isCleanupOnFailure() |
boolean |
isCombineText() |
boolean |
isForceExtendableShardSpecs() |
boolean |
isIgnoreInvalidRows() |
boolean |
isLeaveIntermediate() |
boolean |
isOverwriteFiles() |
boolean |
isUseExplicitVersion() |
static HadoopTuningConfig |
makeDefaultTuningConfig() |
HadoopTuningConfig |
withShardSpecs(Map<Long,List<HadoopyShardSpec>> specs) |
HadoopTuningConfig |
withVersion(String ver) |
HadoopTuningConfig |
withWorkingPath(String path) |
public HadoopTuningConfig(String workingPath, String version, PartitionsSpec partitionsSpec, Map<Long,List<HadoopyShardSpec>> shardSpecs, IndexSpec indexSpec, Integer maxRowsInMemory, boolean leaveIntermediate, Boolean cleanupOnFailure, boolean overwriteFiles, boolean ignoreInvalidRows, Map<String,String> jobProperties, boolean combineText, Boolean useCombiner, Integer maxRowsInMemoryCOMPAT, Boolean buildV9Directly, Integer numBackgroundPersistThreads, boolean forceExtendableShardSpecs, boolean useExplicitVersion, List<String> allowedHadoopPrefix)
public static HadoopTuningConfig makeDefaultTuningConfig()
public String getWorkingPath()
public String getVersion()
public PartitionsSpec getPartitionsSpec()
public Map<Long,List<HadoopyShardSpec>> getShardSpecs()
public IndexSpec getIndexSpec()
public int getRowFlushBoundary()
public boolean isLeaveIntermediate()
public Boolean isCleanupOnFailure()
public boolean isOverwriteFiles()
public boolean isIgnoreInvalidRows()
public boolean isCombineText()
public boolean getUseCombiner()
@Deprecated public Boolean getBuildV9Directly()
public int getNumBackgroundPersistThreads()
public boolean isForceExtendableShardSpecs()
public boolean isUseExplicitVersion()
public HadoopTuningConfig withWorkingPath(String path)
public HadoopTuningConfig withVersion(String ver)
public HadoopTuningConfig withShardSpecs(Map<Long,List<HadoopyShardSpec>> specs)
Copyright © 2011–2018. All rights reserved.