Package | Description |
---|---|
org.apache.reef.examples.data.loading |
A line counter example using data loading service.
|
org.apache.reef.examples.group.bgd |
Runs BGD on the given runtime.
|
org.apache.reef.io.data.loading.api |
Data Loading Service API.
|
org.apache.reef.io.data.loading.impl |
Implementations of Data Loading Service.
|
Constructor and Description |
---|
LineCounter(DataLoadingService dataLoadingService) |
Constructor and Description |
---|
BGDDriver(DataLoadingService dataLoadingService,
GroupCommDriver groupCommDriver,
ConfigurationSerializer confSerializer,
BGDControlParameters bgdControlParameters) |
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.
|
Modifier and Type | Class and Description |
---|---|
class |
InputFormatLoadingService<K,V>
An implementation of
DataLoadingService
that uses the Hadoop InputFormat to find
partitions of data and request resources. |
Copyright © 2016 The Apache Software Foundation. All rights reserved.