org.apache.reef.io.data.loading.api

Class DataLoader

java.lang.Object

org.apache.reef.io.data.loading.api.DataLoader

public class DataLoader
extends Object

The driver component for the DataLoadingService Also acts as the central point for resource requests All the allocated evaluators pass through this and the ones that need data loading have a context stacked that enables a task to get access to Data via the DataSet.

TODO: Add timeouts

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	DataLoader.EvaluatorAllocatedHandler
class	DataLoader.EvaluatorFailedHandler
class	DataLoader.StartHandler

Constructor Summary

Constructors

Constructor and Description
DataLoader(Clock clock, EvaluatorRequestor requestor, DataLoadingService dataLoadingService, int dataEvalMemoryMB, int dataEvalCore, String serializedComputeRequest)

Method Summary

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DataLoader

@Inject
public DataLoader(Clock clock,
                 EvaluatorRequestor requestor,
                 DataLoadingService dataLoadingService,
                 int dataEvalMemoryMB,
                 int dataEvalCore,
                 String serializedComputeRequest)