public class DataLoader extends Object
DataSet
.
TODO: Add timeouts
Modifier and Type | Class and Description |
---|---|
class |
DataLoader.EvaluatorAllocatedHandler |
class |
DataLoader.EvaluatorFailedHandler |
class |
DataLoader.StartHandler |
Constructor and Description |
---|
DataLoader(Clock clock,
EvaluatorRequestor requestor,
DataLoadingService dataLoadingService,
Set<String> serializedComputeRequests,
Set<String> serializedDataRequests)
Allows to specify compute and data evaluator requests in particular
locations.
|
@Inject public DataLoader(Clock clock, EvaluatorRequestor requestor, DataLoadingService dataLoadingService, Set<String> serializedComputeRequests, Set<String> serializedDataRequests)
clock
- the clockrequestor
- the evaluator requestordataLoadingService
- the data loading serviceserializedComputeRequests
- serialized compute requests (evaluators that will not load data)serializedDataRequests
- serialized data requests (evaluators that will load data). It
cannot be empty (to maintain previous functionality)Copyright © 2017 The Apache Software Foundation. All rights reserved.