Package | Description |
---|---|
org.apache.reef.client |
Client APIs for REEF.
|
org.apache.reef.driver.restart |
This package provides restart event service handlers.
|
org.apache.reef.examples.data.output |
Example application using the output service.
|
org.apache.reef.examples.hello |
The Hello REEF example for the HDInsight.
|
org.apache.reef.examples.scheduler.driver |
Task scheduler example driver classes.
|
org.apache.reef.io.data.loading.api |
Data Loading Service API.
|
org.apache.reef.io.watcher |
Watcher subscribes events and writes them to the destination using a certain EventStream.
|
org.apache.reef.io.watcher.util |
Utility classes for Watcher.
|
org.apache.reef.javabridge.generic |
Generic java bridge driver/client.
|
org.apache.reef.runtime.common.driver |
Implementation of the Driver-side REEF APIs.
|
org.apache.reef.runtime.common.evaluator |
Evaluator-side implementation of the REEF API.
|
org.apache.reef.tests.fail.driver |
Tests for Driver-side failures.
|
org.apache.reef.tests.library.driver |
Commonly used event handler implementations in our tests.
|
org.apache.reef.tests.rack.awareness |
Tests for Rack-awareness.
|
org.apache.reef.tests.watcher |
Test reef.io.watcher.
|
org.apache.reef.util.logging |
Logging handler for clr bridge.
|
org.apache.reef.wake.impl |
Wake's implementation.
|
org.apache.reef.webserver |
HTTP Server component to implement a REST API for the Driver or Evaluators.
|
Modifier and Type | Field and Description |
---|---|
static RequiredImpl<EventHandler<StartTime>> |
DriverServiceConfiguration.ON_DRIVER_STARTED
The event handler invoked right after the driver boots up.
|
static RequiredImpl<EventHandler<StartTime>> |
DriverConfiguration.ON_DRIVER_STARTED
The event handler invoked right after the driver boots up.
|
Modifier and Type | Method and Description |
---|---|
StartTime |
DriverRestartedImpl.getStartTime() |
StartTime |
DriverRestarted.getStartTime() |
Modifier and Type | Method and Description |
---|---|
void |
DriverRestartManager.onRestart(StartTime startTime,
List<EventHandler<DriverRestarted>> orderedHandlers)
Recovers the list of alive and failed evaluators and inform the driver restart handlers and inform the
evaluator failure handlers based on the specific runtime.
|
Modifier and Type | Method and Description |
---|---|
void |
OutputServiceDriver.StartHandler.onNext(StartTime startTime) |
Modifier and Type | Method and Description |
---|---|
void |
HelloJVMOptionsDriver.StartHandler.onNext(StartTime startTime) |
void |
HelloDriver.StartHandler.onNext(StartTime startTime) |
Modifier and Type | Method and Description |
---|---|
void |
SchedulerDriver.StartHandler.onNext(StartTime startTime) |
Modifier and Type | Method and Description |
---|---|
void |
DataLoader.StartHandler.onNext(StartTime startTime) |
Modifier and Type | Method and Description |
---|---|
void |
Watcher.DriverStartHandler.onNext(StartTime startTime) |
Modifier and Type | Method and Description |
---|---|
static AvroStartTime |
WatcherAvroUtil.toAvroStartTime(StartTime startTime) |
Modifier and Type | Method and Description |
---|---|
void |
JobDriver.StartHandler.onNext(StartTime startTime) |
Modifier and Type | Method and Description |
---|---|
void |
DriverStartHandler.onNext(StartTime startTime) |
Modifier and Type | Method and Description |
---|---|
void |
PIDStoreStartHandler.onNext(StartTime startTime) |
Modifier and Type | Method and Description |
---|---|
void |
FailDriverDelayedMsg.StartHandler.onNext(StartTime time) |
void |
DriverFailOnFail.StartHandler.onNext(StartTime time) |
Modifier and Type | Method and Description |
---|---|
void |
OnDriverStartedAllocateOne.onNext(StartTime startTime) |
Modifier and Type | Method and Description |
---|---|
void |
OnDriverStartedAllocateOneInRack.onNext(StartTime startTime) |
Modifier and Type | Method and Description |
---|---|
void |
WatcherTestDriver.DriverStartedHandler.onNext(StartTime value) |
Modifier and Type | Method and Description |
---|---|
LoggingScope |
LoggingScopeFactory.driverRestart(StartTime startTime)
This is to measure the time in calling driverRestartHandler.
|
LoggingScope |
LoggingScopeFactory.driverStart(StartTime startTime)
The method is to measure the time used to start the driver.
|
Modifier and Type | Method and Description |
---|---|
void |
MissingStartHandlerHandler.onNext(StartTime value) |
Modifier and Type | Method and Description |
---|---|
void |
ReefEventStateManager.StartStateHandler.onNext(StartTime startTime) |
Copyright © 2016 The Apache Software Foundation. All rights reserved.