public final class DataLoadingRequestBuilder extends Object implements Builder<Configuration>
Modifier and Type | Class and Description |
---|---|
static class |
DataLoadingRequestBuilder.DataLoadingComputeRequest |
static class |
DataLoadingRequestBuilder.DataLoadingEvaluatorMemoryMB |
static class |
DataLoadingRequestBuilder.DataLoadingEvaluatorNumberOfCores |
static class |
DataLoadingRequestBuilder.LoadDataIntoMemory |
static class |
DataLoadingRequestBuilder.NumberOfDesiredSplits |
Constructor and Description |
---|
DataLoadingRequestBuilder() |
Modifier and Type | Method and Description |
---|---|
Configuration |
build()
Builds a fresh instance of the object.
|
DataLoadingRequestBuilder |
loadIntoMemory(boolean inMemory) |
DataLoadingRequestBuilder |
renewFailedEvaluators(boolean renewFailedEvaluators) |
DataLoadingRequestBuilder |
setComputeRequest(EvaluatorRequest computeRequest) |
DataLoadingRequestBuilder |
setDriverConfigurationModule(ConfigurationModule driverConfigurationModule) |
DataLoadingRequestBuilder |
setInputFormatClass(Class<? extends org.apache.hadoop.mapred.InputFormat> inputFormatClass) |
DataLoadingRequestBuilder |
setInputPath(String inputPath) |
DataLoadingRequestBuilder |
setMemoryMB(int memoryMB)
Set the memory to be used for Evaluator allocated.
|
DataLoadingRequestBuilder |
setNumberOfCores(int numberOfCores)
Set the core number to be used for Evaluator allocated.
|
DataLoadingRequestBuilder |
setNumberOfDesiredSplits(int numberOfDesiredSplits) |
public DataLoadingRequestBuilder()
public DataLoadingRequestBuilder setNumberOfDesiredSplits(int numberOfDesiredSplits)
public DataLoadingRequestBuilder setMemoryMB(int memoryMB)
memoryMB
- the amount of memory in MBpublic DataLoadingRequestBuilder setNumberOfCores(int numberOfCores)
numberOfCores
- the number of corespublic DataLoadingRequestBuilder setComputeRequest(EvaluatorRequest computeRequest)
public DataLoadingRequestBuilder loadIntoMemory(boolean inMemory)
public DataLoadingRequestBuilder renewFailedEvaluators(boolean renewFailedEvaluators)
public DataLoadingRequestBuilder setDriverConfigurationModule(ConfigurationModule driverConfigurationModule)
public DataLoadingRequestBuilder setInputFormatClass(Class<? extends org.apache.hadoop.mapred.InputFormat> inputFormatClass)
public DataLoadingRequestBuilder setInputPath(String inputPath)
public Configuration build() throws BindException
Builder
build
in interface Builder<Configuration>
BindException
Copyright © 2015 The Apache Software Foundation. All rights reserved.