| Package | Description |
|---|---|
| org.apache.reef.examples.group.bgd |
Runs BGD on the given runtime.
|
| org.apache.reef.examples.group.bgd.parameters |
Parameters for BGD.
|
| org.apache.reef.examples.group.broadcast |
Broadcast Group Communication example.
|
| org.apache.reef.examples.suspend |
Suspend/resume demo.
|
| org.apache.reef.io.checkpoint |
Checkpoints that provide APIs and implementations to store and retrieve the state of a task.
|
| org.apache.reef.io.checkpoint.fs |
FileSystem based checkpoints.
|
| org.apache.reef.io.data.loading.api |
Data Loading Service API.
|
| org.apache.reef.io.data.loading.impl |
Implementations of Data Loading Service.
|
| org.apache.reef.io.network.group.impl.driver |
This package contains the implementation of the driver side of the
Group Communication Service using the tree/flat topology.
|
| org.apache.reef.io.network.group.impl.operators |
Implementations for Group Communication Operators.
|
| org.apache.reef.io.network.group.impl.task |
Implementations for Elastic Group Communications Task-side API.
|
| org.apache.reef.io.network.impl |
TODO: Document.
|
| org.apache.reef.io.network.naming |
TODO: Document.
|
| org.apache.reef.io.storage.ram |
Implementations for RAM-based storage service.
|
| org.apache.reef.poison.context |
Fault Injection into REEF contexts.
|
| org.apache.reef.poison.task |
Fault Injection into REEF tasks.
|
| org.apache.reef.runtime.common.driver.client |
Objects representing the Client on the Driver.
|
| org.apache.reef.runtime.common.launch |
Common launch code between Driver and Evaluator.
|
| org.apache.reef.runtime.local.process |
Infrastructure for managing processes.
|
| org.apache.reef.tang.examples |
Example code from the tutorial on Tang's home page.
|
| org.apache.reef.tang.examples.timer |
A more complicated version of the Timer example, including delegating
interfaces to default implementations.
|
| org.apache.reef.tang.util |
Utilities for Tang.
|
| org.apache.reef.tests.fail.driver |
Tests for Driver-side failures.
|
| org.apache.reef.tests.fail.task |
Tests for Tasks fail in various cases.
|
| org.apache.reef.wake.impl |
Wake's implementation.
|
| org.apache.reef.wake.remote.ports |
TCP port providers.
|
| org.apache.reef.wake.rx.impl |
Wake's RX-style communication implementation.
|
| org.apache.reef.webserver |
HTTP Server component to implement a REST API for the Driver or Evaluators.
|
| Constructor and Description |
|---|
BGDClient(String input,
int numSplits,
int memory,
int fanOut,
BGDControlParameters bgdControlParameters) |
BGDClient(String input,
int numSplits,
int memory,
int fanOut,
BGDControlParameters bgdControlParameters) |
BGDClient(String input,
int numSplits,
int memory,
int fanOut,
BGDControlParameters bgdControlParameters) |
BGDClient(String input,
int numSplits,
int memory,
int fanOut,
BGDControlParameters bgdControlParameters) |
MasterTask(GroupCommClient groupCommClient,
int dimensions,
double lambda,
int maxIters,
boolean rampup,
StepSizes ts) |
MasterTask(GroupCommClient groupCommClient,
int dimensions,
double lambda,
int maxIters,
boolean rampup,
StepSizes ts) |
MasterTask(GroupCommClient groupCommClient,
int dimensions,
double lambda,
int maxIters,
boolean rampup,
StepSizes ts) |
MasterTask(GroupCommClient groupCommClient,
int dimensions,
double lambda,
int maxIters,
boolean rampup,
StepSizes ts) |
SlaveTask(GroupCommClient groupCommClient,
ExampleList dataSet,
LossFunction lossFunction,
double pFailure,
StepSizes ts) |
| Constructor and Description |
|---|
BGDControlParameters(int dimensions,
double lambda,
double eps,
double eta,
double probOfSuccessfulIteration,
int iters,
boolean rampup,
int minParts,
BGDLossType lossType) |
BGDControlParameters(int dimensions,
double lambda,
double eps,
double eta,
double probOfSuccessfulIteration,
int iters,
boolean rampup,
int minParts,
BGDLossType lossType) |
BGDControlParameters(int dimensions,
double lambda,
double eps,
double eta,
double probOfSuccessfulIteration,
int iters,
boolean rampup,
int minParts,
BGDLossType lossType) |
BGDControlParameters(int dimensions,
double lambda,
double eps,
double eta,
double probOfSuccessfulIteration,
int iters,
boolean rampup,
int minParts,
BGDLossType lossType) |
BGDControlParameters(int dimensions,
double lambda,
double eps,
double eta,
double probOfSuccessfulIteration,
int iters,
boolean rampup,
int minParts,
BGDLossType lossType) |
BGDControlParameters(int dimensions,
double lambda,
double eps,
double eta,
double probOfSuccessfulIteration,
int iters,
boolean rampup,
int minParts,
BGDLossType lossType) |
BGDControlParameters(int dimensions,
double lambda,
double eps,
double eta,
double probOfSuccessfulIteration,
int iters,
boolean rampup,
int minParts,
BGDLossType lossType) |
BGDControlParameters(int dimensions,
double lambda,
double eps,
double eta,
double probOfSuccessfulIteration,
int iters,
boolean rampup,
int minParts,
BGDLossType lossType) |
BGDLossType(String lossFunctionStr) |
| Constructor and Description |
|---|
BroadcastDriver(EvaluatorRequestor requestor,
GroupCommDriver groupCommDriver,
ConfigurationSerializer confSerializer,
int dimensions,
int numberOfReceivers) |
BroadcastDriver(EvaluatorRequestor requestor,
GroupCommDriver groupCommDriver,
ConfigurationSerializer confSerializer,
int dimensions,
int numberOfReceivers) |
MasterTask(GroupCommClient groupCommClient,
int dimensions) |
| Constructor and Description |
|---|
Control(int port,
String taskId,
String command,
TransportFactory tpFactory) |
Control(int port,
String taskId,
String command,
TransportFactory tpFactory) |
Control(int port,
String taskId,
String command,
TransportFactory tpFactory) |
SuspendClientControl(int port,
TransportFactory tpFactory) |
SuspendTestTask(CheckpointService checkpointService,
int numCycles,
int delay)
Task constructor: invoked by TANG.
|
SuspendTestTask(CheckpointService checkpointService,
int numCycles,
int delay)
Task constructor: invoked by TANG.
|
| Constructor and Description |
|---|
RandomNameCNS(String prefix) |
SimpleNamingService(String name) |
| Constructor and Description |
|---|
FSCheckPointServiceConfiguration.FileSystemConstructor(boolean isLocal) |
| 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.
|
DataLoader(Clock clock,
EvaluatorRequestor requestor,
DataLoadingService dataLoadingService,
Set<String> serializedComputeRequests,
Set<String> serializedDataRequests)
Allows to specify compute and data evaluator requests in particular
locations.
|
| Constructor and Description |
|---|
InputFormatLoadingService(EvaluatorToPartitionStrategy<org.apache.hadoop.mapred.InputSplit> evaluatorToPartitionStrategy,
boolean inMemory,
String inputFormatClass) |
InputFormatLoadingService(EvaluatorToPartitionStrategy<org.apache.hadoop.mapred.InputSplit> evaluatorToPartitionStrategy,
boolean inMemory,
String inputFormatClass) |
InputSplitExternalConstructor(org.apache.hadoop.mapred.JobConf jobConf,
String serializedInputSplit) |
JobConfExternalConstructor(String inputFormatClassName,
String inputPath) |
JobConfExternalConstructor(String inputFormatClassName,
String inputPath) |
| Constructor and Description |
|---|
GroupCommDriverImpl(ConfigurationSerializer confSerializer,
String driverId,
int fanOut,
LocalAddressProvider localAddressProvider,
TransportFactory tpFactory,
NameServer nameService)
Deprecated.
in 0.12. Use Tang to obtain an instance of this instead.
|
GroupCommDriverImpl(ConfigurationSerializer confSerializer,
String driverId,
int fanOut,
LocalAddressProvider localAddressProvider,
TransportFactory tpFactory,
NameServer nameService)
Deprecated.
in 0.12. Use Tang to obtain an instance of this instead.
|
| Constructor and Description |
|---|
CommunicationGroupClientImpl(String groupName,
String taskId,
String driverId,
GroupCommNetworkHandler groupCommNetworkHandler,
Set<String> operatorConfigs,
ConfigurationSerializer configSerializer,
NetworkService<GroupCommunicationMessage> netService)
Deprecated.
in 0.14.
Use the private constructor that receives an
injector as a parameter instead. |
CommunicationGroupClientImpl(String groupName,
String taskId,
String driverId,
GroupCommNetworkHandler groupCommNetworkHandler,
Set<String> operatorConfigs,
ConfigurationSerializer configSerializer,
NetworkService<GroupCommunicationMessage> netService)
Deprecated.
in 0.14.
Use the private constructor that receives an
injector as a parameter instead. |
CommunicationGroupClientImpl(String groupName,
String taskId,
String driverId,
GroupCommNetworkHandler groupCommNetworkHandler,
Set<String> operatorConfigs,
ConfigurationSerializer configSerializer,
NetworkService<GroupCommunicationMessage> netService)
Deprecated.
in 0.14.
Use the private constructor that receives an
injector as a parameter instead. |
CommunicationGroupClientImpl(String groupName,
String taskId,
String driverId,
GroupCommNetworkHandler groupCommNetworkHandler,
Set<String> operatorConfigs,
ConfigurationSerializer configSerializer,
NetworkService<GroupCommunicationMessage> netService)
Deprecated.
in 0.14.
Use the private constructor that receives an
injector as a parameter instead. |
GroupCommClientImpl(Set<String> groupConfigs,
String taskId,
GroupCommNetworkHandler groupCommNetworkHandler,
NetworkService<ReefNetworkGroupCommProtos.GroupCommMessage> netService,
ConfigurationSerializer configSerializer)
Deprecated.
in 0.14.
Use the other constructor that receives an
injector as a parameter instead.
The parameters taskId and netService can be removed from the other constructor when
this constructor gets deleted. |
GroupCommClientImpl(Set<String> groupConfigs,
String taskId,
GroupCommNetworkHandler groupCommNetworkHandler,
NetworkService<ReefNetworkGroupCommProtos.GroupCommMessage> netService,
ConfigurationSerializer configSerializer)
Deprecated.
in 0.14.
Use the other constructor that receives an
injector as a parameter instead.
The parameters taskId and netService can be removed from the other constructor when
this constructor gets deleted. |
| Constructor and Description |
|---|
BindNSToTask(NetworkService<?> ns,
IdentifierFactory idFac) |
NetworkService(IdentifierFactory factory,
int nsPort,
NameResolver nameResolver,
Codec<T> codec,
TransportFactory tpFactory,
EventHandler<Message<T>> recvHandler,
EventHandler<Exception> exHandler,
LocalAddressProvider localAddressProvider)
Deprecated.
in 0.12. Use Tang to obtain an instance of this instead.
|
NetworkService(IdentifierFactory factory,
int nsPort,
NameResolver nameResolver,
Codec<T> codec,
TransportFactory tpFactory,
EventHandler<Message<T>> recvHandler,
EventHandler<Exception> exHandler,
LocalAddressProvider localAddressProvider)
Deprecated.
in 0.12. Use Tang to obtain an instance of this instead.
|
NetworkService(IdentifierFactory factory,
int nsPort,
NameResolver nameResolver,
Codec<T> codec,
TransportFactory tpFactory,
EventHandler<Message<T>> recvHandler,
EventHandler<Exception> exHandler,
LocalAddressProvider localAddressProvider)
Deprecated.
in 0.12. Use Tang to obtain an instance of this instead.
|
NetworkService(IdentifierFactory factory,
int nsPort,
NameResolver nameResolver,
Codec<T> codec,
TransportFactory tpFactory,
EventHandler<Message<T>> recvHandler,
EventHandler<Exception> exHandler,
LocalAddressProvider localAddressProvider)
Deprecated.
in 0.12. Use Tang to obtain an instance of this instead.
|
NetworkService(IdentifierFactory factory,
int nsPort,
NameResolver nameResolver,
Codec<T> codec,
TransportFactory tpFactory,
EventHandler<Message<T>> recvHandler,
EventHandler<Exception> exHandler,
LocalAddressProvider localAddressProvider)
Deprecated.
in 0.12. Use Tang to obtain an instance of this instead.
|
NetworkService(IdentifierFactory factory,
int nsPort,
NameResolver nameResolver,
Codec<T> codec,
TransportFactory tpFactory,
EventHandler<Message<T>> recvHandler,
EventHandler<Exception> exHandler,
LocalAddressProvider localAddressProvider)
Deprecated.
in 0.12. Use Tang to obtain an instance of this instead.
|
UnbindNSFromTask(NetworkService<?> ns,
IdentifierFactory idFac) |
| Constructor and Description |
|---|
NameServerImpl(int port,
IdentifierFactory factory,
LocalAddressProvider localAddressProvider)
Deprecated.
in 0.12. Use Tang to obtain an instance of this or, better, NameServer, instead.
|
NameServerImpl(int port,
IdentifierFactory factory,
LocalAddressProvider localAddressProvider)
Deprecated.
in 0.12. Use Tang to obtain an instance of this or, better, NameServer, instead.
|
| Constructor and Description |
|---|
CodecRamMap(RamStorageService ramStore,
Codec<T> c) |
| Constructor and Description |
|---|
PoisonedContextStartHandler(double crashProbability,
int timeOut,
Clock clock) |
PoisonedContextStartHandler(double crashProbability,
int timeOut,
Clock clock) |
| Constructor and Description |
|---|
PoisonedTaskStartHandler(double crashProbability,
int timeOut,
Clock clock) |
PoisonedTaskStartHandler(double crashProbability,
int timeOut,
Clock clock) |
| Constructor and Description |
|---|
ClientConnection(RemoteManager remoteManager,
String clientRID,
String jobIdentifier) |
ClientConnection(RemoteManager remoteManager,
String clientRID,
String jobIdentifier) |
| Constructor and Description |
|---|
ProfilingStopHandler(String launchID) |
| Constructor and Description |
|---|
ReefRunnableProcessObserver(EventHandler<ResourceStatusEvent> resourceStatusHandler,
InjectionFuture<ResourceManager> resourceManager) |
| Constructor and Description |
|---|
PrintTypeHierarchy(int id)
Constructor to test the parameter injection.
|
Timer(int seconds) |
TimerV1(int seconds) |
| Constructor and Description |
|---|
TimerImpl(int seconds) |
| Constructor and Description |
|---|
ValidateConfiguration(File ch,
File inConfig,
File outConfig) |
ValidateConfiguration(File ch,
File inConfig,
File outConfig) |
ValidateConfiguration(File ch,
File inConfig,
File outConfig) |
ValidateConfiguration(String injectedClass,
File ch,
File inConfig,
File outConfig) |
ValidateConfiguration(String injectedClass,
File ch,
File inConfig,
File outConfig) |
ValidateConfiguration(String injectedClass,
File ch,
File inConfig,
File outConfig) |
ValidateConfiguration(String injectedClass,
File ch,
File inConfig,
File outConfig) |
| Constructor and Description |
|---|
FailDriver(String failMsgClassName,
EvaluatorRequestor requestor,
Clock clock) |
| Constructor and Description |
|---|
Driver(String failTaskName,
EvaluatorRequestor requestor) |
| Constructor and Description |
|---|
ForkPoolStage(EventHandler<T> handler,
WakeSharedPool sharedPool) |
ForkPoolStage(String stageName,
EventHandler<T> handler,
WakeSharedPool sharedPool) |
ForkPoolStage(String stageName,
EventHandler<T> handler,
WakeSharedPool sharedPool) |
SingleThreadStage(EventHandler<T> handler,
int capacity)
Constructs a single thread stage.
|
SingleThreadStage(EventHandler<T> handler,
int capacity)
Constructs a single thread stage.
|
SingleThreadStage(String name,
EventHandler<T> handler,
int capacity)
Constructs a single thread stage.
|
SingleThreadStage(String name,
EventHandler<T> handler,
int capacity)
Constructs a single thread stage.
|
SingleThreadStage(String name,
EventHandler<T> handler,
int capacity)
Constructs a single thread stage.
|
SyncStage(EventHandler<T> handler)
Constructs a synchronous stage.
|
SyncStage(String name,
EventHandler<T> handler)
Constructs a synchronous stage.
|
SyncStage(String name,
EventHandler<T> handler)
Constructs a synchronous stage.
|
SyncStage(String name,
EventHandler<T> handler,
EventHandler<Throwable> errorHandler)
Constructs a synchronous stage.
|
SyncStage(String name,
EventHandler<T> handler,
EventHandler<Throwable> errorHandler)
Constructs a synchronous stage.
|
SyncStage(String name,
EventHandler<T> handler,
EventHandler<Throwable> errorHandler)
Constructs a synchronous stage.
|
ThreadPoolStage(EventHandler<T> handler,
ExecutorService executor)
Constructs a thread-pool stage.
|
ThreadPoolStage(EventHandler<T> handler,
ExecutorService executor)
Constructs a thread-pool stage.
|
ThreadPoolStage(EventHandler<T> handler,
ExecutorService executor,
EventHandler<Throwable> errorHandler)
Constructs a thread-pool stage.
|
ThreadPoolStage(EventHandler<T> handler,
ExecutorService executor,
EventHandler<Throwable> errorHandler)
Constructs a thread-pool stage.
|
ThreadPoolStage(EventHandler<T> handler,
ExecutorService executor,
EventHandler<Throwable> errorHandler)
Constructs a thread-pool stage.
|
ThreadPoolStage(EventHandler<T> handler,
int numThreads)
Constructs a thread-pool stage.
|
ThreadPoolStage(EventHandler<T> handler,
int numThreads)
Constructs a thread-pool stage.
|
ThreadPoolStage(String name,
EventHandler<T> handler,
ExecutorService executor)
Constructs a thread-pool stage.
|
ThreadPoolStage(String name,
EventHandler<T> handler,
ExecutorService executor)
Constructs a thread-pool stage.
|
ThreadPoolStage(String name,
EventHandler<T> handler,
ExecutorService executor)
Constructs a thread-pool stage.
|
ThreadPoolStage(String name,
EventHandler<T> handler,
ExecutorService executor,
EventHandler<Throwable> errorHandler)
Constructs a thread-pool stage.
|
ThreadPoolStage(String name,
EventHandler<T> handler,
ExecutorService executor,
EventHandler<Throwable> errorHandler)
Constructs a thread-pool stage.
|
ThreadPoolStage(String name,
EventHandler<T> handler,
ExecutorService executor,
EventHandler<Throwable> errorHandler)
Constructs a thread-pool stage.
|
ThreadPoolStage(String name,
EventHandler<T> handler,
ExecutorService executor,
EventHandler<Throwable> errorHandler)
Constructs a thread-pool stage.
|
ThreadPoolStage(String name,
EventHandler<T> handler,
int numThreads)
Constructs a thread-pool stage.
|
ThreadPoolStage(String name,
EventHandler<T> handler,
int numThreads)
Constructs a thread-pool stage.
|
ThreadPoolStage(String name,
EventHandler<T> handler,
int numThreads)
Constructs a thread-pool stage.
|
ThreadPoolStage(String name,
EventHandler<T> handler,
int numThreads,
EventHandler<Throwable> errorHandler)
Constructs a thread-pool stage.
|
ThreadPoolStage(String name,
EventHandler<T> handler,
int numThreads,
EventHandler<Throwable> errorHandler)
Constructs a thread-pool stage.
|
ThreadPoolStage(String name,
EventHandler<T> handler,
int numThreads,
EventHandler<Throwable> errorHandler)
Constructs a thread-pool stage.
|
ThreadPoolStage(String name,
EventHandler<T> handler,
int numThreads,
EventHandler<Throwable> errorHandler)
Constructs a thread-pool stage.
|
TimerStage(EventHandler<PeriodicEvent> handler,
long period)
Constructs a timer stage with no initial delay.
|
TimerStage(EventHandler<PeriodicEvent> handler,
long period)
Constructs a timer stage with no initial delay.
|
TimerStage(EventHandler<PeriodicEvent> handler,
long initialDelay,
long period)
Constructs a timer stage.
|
TimerStage(EventHandler<PeriodicEvent> handler,
long initialDelay,
long period)
Constructs a timer stage.
|
TimerStage(EventHandler<PeriodicEvent> handler,
long initialDelay,
long period)
Constructs a timer stage.
|
TimerStage(String name,
EventHandler<PeriodicEvent> handler,
long period)
Constructs a timer stage with no initial delay.
|
TimerStage(String name,
EventHandler<PeriodicEvent> handler,
long period)
Constructs a timer stage with no initial delay.
|
TimerStage(String name,
EventHandler<PeriodicEvent> handler,
long period)
Constructs a timer stage with no initial delay.
|
TimerStage(String name,
EventHandler<PeriodicEvent> handler,
long initialDelay,
long period)
Constructs a timer stage.
|
TimerStage(String name,
EventHandler<PeriodicEvent> handler,
long initialDelay,
long period)
Constructs a timer stage.
|
TimerStage(String name,
EventHandler<PeriodicEvent> handler,
long initialDelay,
long period)
Constructs a timer stage.
|
TimerStage(String name,
EventHandler<PeriodicEvent> handler,
long initialDelay,
long period)
Constructs a timer stage.
|
WakeSharedPool(int parallelism) |
| Constructor and Description |
|---|
RangeTcpPortProvider(int portRangeBegin,
int portRangeCount,
int portRangeTryCount) |
RangeTcpPortProvider(int portRangeBegin,
int portRangeCount,
int portRangeTryCount) |
RangeTcpPortProvider(int portRangeBegin,
int portRangeCount,
int portRangeTryCount) |
| Constructor and Description |
|---|
RxSyncStage(Observer<T> observer)
Constructs a Rx synchronous stage.
|
RxSyncStage(String name,
Observer<T> observer)
Constructs a Rx synchronous stage.
|
RxSyncStage(String name,
Observer<T> observer)
Constructs a Rx synchronous stage.
|
RxThreadPoolStage(Observer<T> observer,
int numThreads)
Constructs a Rx thread pool stage.
|
RxThreadPoolStage(Observer<T> observer,
int numThreads)
Constructs a Rx thread pool stage.
|
RxThreadPoolStage(String name,
Observer<T> observer,
int numThreads)
Constructs a Rx thread pool stage.
|
RxThreadPoolStage(String name,
Observer<T> observer,
int numThreads)
Constructs a Rx thread pool stage.
|
RxThreadPoolStage(String name,
Observer<T> observer,
int numThreads)
Constructs a Rx thread pool stage.
|
| Constructor and Description |
|---|
HttpServerReefEventHandler(ReefEventStateManager reefStateManager,
Set<EventHandler<Void>> clientCloseHandlers,
String logLevel,
LoggingScopeFactory loggingScopeFactory,
REEFFileNames reefFileNames,
InjectionFuture<ProgressProvider> progressProvider) |
HttpServerReefEventHandler(ReefEventStateManager reefStateManager,
Set<EventHandler<Void>> clientCloseHandlers,
String logLevel,
LoggingScopeFactory loggingScopeFactory,
REEFFileNames reefFileNames,
InjectionFuture<ProgressProvider> progressProvider) |
Copyright © 2016 The Apache Software Foundation. All rights reserved.