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

Interface DataLoadingService

All Known Implementing Classes:

InputFormatLoadingService

public interface DataLoadingService

All data loading services should implement this interface.

Method Summary

Methods

Modifier and Type	Method and Description
String	getComputeContextIdPrefix()
Configuration	getContextConfiguration(AllocatedEvaluator allocatedEvaluator)
int	getNumberOfPartitions() Access to the number of partitions suggested by this DataSource.
Configuration	getServiceConfiguration(AllocatedEvaluator allocatedEvaluator)
boolean	isComputeContext(ActiveContext context)
boolean	isDataLoadedContext(ActiveContext context) Distinguishes data loaded contexts from compute contexts.

Method Detail

getNumberOfPartitions

int getNumberOfPartitions()

Access to the number of partitions suggested by this DataSource.

Returns:

the number of partitions suggested by this DataSource.

getContextConfiguration

Configuration getContextConfiguration(AllocatedEvaluator allocatedEvaluator)

Returns:

the context configuration for the given Evaluator.

getServiceConfiguration

Configuration getServiceConfiguration(AllocatedEvaluator allocatedEvaluator)

Returns:

the service configuration for the given Evaluator.

getComputeContextIdPrefix

String getComputeContextIdPrefix()

Returns:

Return the prefix to be used to enumerate context ids for compute requests fired other than the data load contexts.

isDataLoadedContext

boolean isDataLoadedContext(ActiveContext context)

Distinguishes data loaded contexts from compute contexts.

Returns:

true if this context has been loaded with data.

isComputeContext

boolean isComputeContext(ActiveContext context)

Returns:

true if this is a computation context, false otherwise. (e.g. this is a data loading context).