| Package | Description |
|---|---|
| org.apache.reef.examples.scheduler |
Task scheduler example based on reef-webserver
|
| org.apache.reef.examples.suspend |
suspend/resume demo.
|
| org.apache.reef.io.checkpoint | |
| org.apache.reef.io.checkpoint.fs | |
| org.apache.reef.io.data.loading.api | |
| org.apache.reef.io.data.loading.impl | |
| org.apache.reef.io.network.impl |
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
|
| org.apache.reef.io.network.naming |
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
|
| org.apache.reef.io.storage.ram | |
| 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.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 |
Miscellaneous utilities, including command line static analysis (Tint), data structures and reflection stuff.
|
| org.apache.reef.tests.fail.driver | |
| org.apache.reef.tests.fail.task | |
| org.apache.reef.wake | |
| org.apache.reef.wake.impl | |
| org.apache.reef.wake.remote.impl | |
| org.apache.reef.wake.rx.impl | |
| org.apache.reef.webserver |
| Constructor and Description |
|---|
SchedulerDriver(EvaluatorRequestor requestor,
boolean retainable,
org.apache.reef.examples.scheduler.Scheduler scheduler) |
| Constructor and Description |
|---|
Control(int port,
String taskId,
String command) |
Control(int port,
String taskId,
String command) |
Control(int port,
String taskId,
String command) |
SuspendClientControl(int port) |
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,
int dataEvalMemoryMB,
int dataEvalCore,
String serializedComputeRequest) |
DataLoader(Clock clock,
EvaluatorRequestor requestor,
DataLoadingService dataLoadingService,
int dataEvalMemoryMB,
int dataEvalCore,
String serializedComputeRequest) |
DataLoader(Clock clock,
EvaluatorRequestor requestor,
DataLoadingService dataLoadingService,
int dataEvalMemoryMB,
int dataEvalCore,
String serializedComputeRequest) |
| Constructor and Description |
|---|
InputFormatLoadingService(org.apache.hadoop.mapred.InputFormat<K,V> inputFormat,
org.apache.hadoop.mapred.JobConf jobConf,
int numberOfDesiredSplits,
boolean inMemory,
String inputFormatClass,
String inputPath) |
InputFormatLoadingService(org.apache.hadoop.mapred.InputFormat<K,V> inputFormat,
org.apache.hadoop.mapred.JobConf jobConf,
int numberOfDesiredSplits,
boolean inMemory,
String inputFormatClass,
String inputPath) |
InputFormatLoadingService(org.apache.hadoop.mapred.InputFormat<K,V> inputFormat,
org.apache.hadoop.mapred.JobConf jobConf,
int numberOfDesiredSplits,
boolean inMemory,
String inputFormatClass,
String inputPath) |
InputFormatLoadingService(org.apache.hadoop.mapred.InputFormat<K,V> inputFormat,
org.apache.hadoop.mapred.JobConf jobConf,
int numberOfDesiredSplits,
boolean inMemory,
String inputFormatClass,
String inputPath) |
InputSplitExternalConstructor(org.apache.hadoop.mapred.JobConf jobConf,
String serializedInputSplit) |
JobConfExternalConstructor(String inputFormatClassName,
String inputPath) |
JobConfExternalConstructor(String inputFormatClassName,
String inputPath) |
| Constructor and Description |
|---|
BindNSToTask(NetworkService<?> ns,
IdentifierFactory idFac) |
NetworkService(IdentifierFactory factory,
int nsPort,
String nameServerAddr,
int nameServerPort,
int retryCount,
int retryTimeout,
Codec<T> codec,
TransportFactory tpFactory,
EventHandler<Message<T>> recvHandler,
EventHandler<Exception> exHandler) |
NetworkService(IdentifierFactory factory,
int nsPort,
String nameServerAddr,
int nameServerPort,
int retryCount,
int retryTimeout,
Codec<T> codec,
TransportFactory tpFactory,
EventHandler<Message<T>> recvHandler,
EventHandler<Exception> exHandler) |
NetworkService(IdentifierFactory factory,
int nsPort,
String nameServerAddr,
int nameServerPort,
int retryCount,
int retryTimeout,
Codec<T> codec,
TransportFactory tpFactory,
EventHandler<Message<T>> recvHandler,
EventHandler<Exception> exHandler) |
NetworkService(IdentifierFactory factory,
int nsPort,
String nameServerAddr,
int nameServerPort,
int retryCount,
int retryTimeout,
Codec<T> codec,
TransportFactory tpFactory,
EventHandler<Message<T>> recvHandler,
EventHandler<Exception> exHandler) |
NetworkService(IdentifierFactory factory,
int nsPort,
String nameServerAddr,
int nameServerPort,
int retryCount,
int retryTimeout,
Codec<T> codec,
TransportFactory tpFactory,
EventHandler<Message<T>> recvHandler,
EventHandler<Exception> exHandler) |
NetworkService(IdentifierFactory factory,
int nsPort,
String nameServerAddr,
int nameServerPort,
int retryCount,
int retryTimeout,
Codec<T> codec,
TransportFactory tpFactory,
EventHandler<Message<T>> recvHandler,
EventHandler<Exception> exHandler) |
NetworkService(IdentifierFactory factory,
int nsPort,
String nameServerAddr,
int nameServerPort,
int retryCount,
int retryTimeout,
Codec<T> codec,
TransportFactory tpFactory,
EventHandler<Message<T>> recvHandler,
EventHandler<Exception> exHandler) |
NetworkService(IdentifierFactory factory,
int nsPort,
String nameServerAddr,
int nameServerPort,
int retryCount,
int retryTimeout,
Codec<T> codec,
TransportFactory tpFactory,
EventHandler<Message<T>> recvHandler,
EventHandler<Exception> exHandler) |
NetworkService(IdentifierFactory factory,
int nsPort,
String nameServerAddr,
int nameServerPort,
int retryCount,
int retryTimeout,
Codec<T> codec,
TransportFactory tpFactory,
EventHandler<Message<T>> recvHandler,
EventHandler<Exception> exHandler) |
NetworkService(IdentifierFactory factory,
int nsPort,
String nameServerAddr,
int nameServerPort,
int retryCount,
int retryTimeout,
Codec<T> codec,
TransportFactory tpFactory,
EventHandler<Message<T>> recvHandler,
EventHandler<Exception> exHandler) |
UnbindNSFromTask(NetworkService<?> ns,
IdentifierFactory idFac) |
| Constructor and Description |
|---|
NameServerImpl(int port,
IdentifierFactory factory,
ReefEventStateManager reefEventStateManager)
Constructs a name server
|
NameServerImpl(int port,
IdentifierFactory factory,
ReefEventStateManager reefEventStateManager)
Constructs a name server
|
| 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 |
|---|
ReefRunnableProcessObserver(EventHandler<DriverRuntimeProtocol.ResourceStatusProto> 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 |
|---|
WakeConfiguration(String confFileName) |
| 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 |
|---|
DefaultRemoteManagerImplementation(String name,
String hostAddress,
int listeningPort,
Codec<T> codec,
EventHandler<Throwable> errorHandler,
boolean orderingGuarantee,
int numberOfTries,
int retryTimeout) |
DefaultRemoteManagerImplementation(String name,
String hostAddress,
int listeningPort,
Codec<T> codec,
EventHandler<Throwable> errorHandler,
boolean orderingGuarantee,
int numberOfTries,
int retryTimeout) |
DefaultRemoteManagerImplementation(String name,
String hostAddress,
int listeningPort,
Codec<T> codec,
EventHandler<Throwable> errorHandler,
boolean orderingGuarantee,
int numberOfTries,
int retryTimeout) |
DefaultRemoteManagerImplementation(String name,
String hostAddress,
int listeningPort,
Codec<T> codec,
EventHandler<Throwable> errorHandler,
boolean orderingGuarantee,
int numberOfTries,
int retryTimeout) |
DefaultRemoteManagerImplementation(String name,
String hostAddress,
int listeningPort,
Codec<T> codec,
EventHandler<Throwable> errorHandler,
boolean orderingGuarantee,
int numberOfTries,
int retryTimeout) |
DefaultRemoteManagerImplementation(String name,
String hostAddress,
int listeningPort,
Codec<T> codec,
EventHandler<Throwable> errorHandler,
boolean orderingGuarantee,
int numberOfTries,
int retryTimeout) |
DefaultRemoteManagerImplementation(String name,
String hostAddress,
int listeningPort,
Codec<T> codec,
EventHandler<Throwable> errorHandler,
boolean orderingGuarantee,
int numberOfTries,
int retryTimeout) |
DefaultRemoteManagerImplementation(String name,
String hostAddress,
int listeningPort,
Codec<T> codec,
EventHandler<Throwable> errorHandler,
boolean orderingGuarantee,
int numberOfTries,
int retryTimeout) |
| 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) |
HttpServerReefEventHandler(ReefEventStateManager reefStateManager,
Set<EventHandler<Void>> clientCloseHandlers,
String logLevel,
LoggingScopeFactory loggingScopeFactory,
REEFFileNames reefFileNames) |
Copyright © 2015 The Apache Software Foundation. All rights reserved.