Package | Description |
---|---|
org.apache.reef.io.data.loading.api |
Data Loading Service API.
|
Modifier and Type | Method and Description |
---|---|
DataLoadingRequestBuilder |
DataLoadingRequestBuilder.addComputeRequest(EvaluatorRequest computeRequest)
Adds a single request to the compute requests list.
|
DataLoadingRequestBuilder |
DataLoadingRequestBuilder.addComputeRequests(List<EvaluatorRequest> computeRequests)
Adds the requests to the compute requests list.
|
DataLoadingRequestBuilder |
DataLoadingRequestBuilder.addDataRequest(EvaluatorRequest dataRequest)
Adds a single request to the data requests list.
|
DataLoadingRequestBuilder |
DataLoadingRequestBuilder.addDataRequests(List<EvaluatorRequest> dataRequests)
Adds the requests to the data requests list.
|
DataLoadingRequestBuilder |
DataLoadingRequestBuilder.loadIntoMemory(boolean inMemory) |
DataLoadingRequestBuilder |
DataLoadingRequestBuilder.renewFailedEvaluators(boolean renewFailedEvaluators) |
DataLoadingRequestBuilder |
DataLoadingRequestBuilder.setDistributedDataSet(DistributedDataSet distributedDataSet)
Sets the distributed data set.
|
DataLoadingRequestBuilder |
DataLoadingRequestBuilder.setDriverConfigurationModule(ConfigurationModule driverConfigurationModule) |
DataLoadingRequestBuilder |
DataLoadingRequestBuilder.setInputFormatClass(Class<? extends org.apache.hadoop.mapred.InputFormat> inputFormatClass) |
DataLoadingRequestBuilder |
DataLoadingRequestBuilder.setInputPath(String inputPath)
Sets the path of the folder where the data is.
|
DataLoadingRequestBuilder |
DataLoadingRequestBuilder.setNumberOfDesiredSplits(int numberOfDesiredSplits) |
Copyright © 2016 The Apache Software Foundation. All rights reserved.