Package | Description |
---|---|
org.apache.reef.bridge.client |
Contains the client of the bridge.
|
org.apache.reef.client |
Client APIs for REEF.
|
org.apache.reef.examples.data.loading |
A line counter example using data loading service.
|
org.apache.reef.examples.data.output |
Example application using the output service.
|
org.apache.reef.examples.group.bgd.utils |
Utility functions for BGD.
|
org.apache.reef.examples.group.broadcast |
Broadcast Group Communication example.
|
org.apache.reef.examples.hello |
The Hello REEF example for the HDInsight.
|
org.apache.reef.examples.helloCLR |
The Hello REEF example for the CLR.
|
org.apache.reef.examples.hellohttp |
Distributed shell example based on REEF HTTP Server component.
|
org.apache.reef.examples.scheduler.client |
Task scheduler example client classes.
|
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.tang |
Public interfaces and factories for Tang's core API.
|
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.implementation.java |
Private implementation classes that configure and inject code written
in Java.
|
org.apache.reef.tang.util |
Utilities for Tang.
|
org.apache.reef.tests |
Tests for REEF implementations.
|
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.tests.messaging.driver |
Tests the messaging channel between client and driver.
|
org.apache.reef.tests.yarn.failure |
Tests for YARN failures.
|
Modifier and Type | Method and Description |
---|---|
static void |
YarnJobSubmissionClient.main(String[] args)
.NET client calls into this main method for job submission.
|
static void |
YarnBootstrapREEFLauncher.main(String[] args) |
static void |
LocalClient.main(String[] args) |
static void |
JobResourceUploader.main(String[] args)
This class is invoked from Org.Apache.REEF.Client.Yarn.LegacyJobResourceUploader in .NET code.
|
Modifier and Type | Method and Description |
---|---|
static DriverLauncher |
DriverLauncher.getLauncher(Configuration runtimeConfiguration)
Instantiate a launcher for the given Configuration.
|
Modifier and Type | Method and Description |
---|---|
static void |
DataLoadingREEF.main(String[] args) |
Modifier and Type | Method and Description |
---|---|
static void |
OutputServiceREEF.main(String[] args) |
Modifier and Type | Method and Description |
---|---|
static void |
SubConfiguration.main(String[] args) |
Modifier and Type | Method and Description |
---|---|
static void |
BroadcastREEF.main(String[] args) |
static LauncherStatus |
BroadcastREEF.runBGDReef(Configuration runtimeConfiguration) |
Modifier and Type | Method and Description |
---|---|
static void |
HelloHDInsight.main(String[] args) |
static void |
HelloReefYarnTcp.main(String[] args)
Start Hello REEF job.
|
static void |
HelloREEFYarnRestart.main(String[] args)
Start HelloREEFYarnRestart job.
|
static void |
HelloREEFYarn.main(String[] args)
Start Hello REEF job.
|
static void |
HelloREEFNoClient.main(String[] args) |
static void |
HelloREEFMesos.main(String[] args)
MASTER_IP is set to "localhost:5050".
|
static void |
HelloREEF.main(String[] args)
Start Hello REEF job.
|
static void |
HelloJVMOptionsREEF.main(String[] args)
Start HelloJVMOptions REEF job.
|
static void |
HelloREEFNoClient.runHelloReefWithoutClient(Configuration runtimeConf)
Used in the HDInsight example.
|
Modifier and Type | Method and Description |
---|---|
static void |
HelloCLR.main(String[] args)
Start Hello REEF job.
|
static LauncherStatus |
HelloCLR.runHelloCLR(Configuration runtimeConf,
int timeOut,
File clrFolder) |
Modifier and Type | Method and Description |
---|---|
static void |
HelloREEFHttpYarn.main(String[] args)
Start Hello REEF job.
|
static void |
HelloREEFHttp.main(String[] args)
Main program.
|
static LauncherStatus |
HelloREEFHttp.runHelloReef(Configuration runtimeConf,
int timeOut)
Run Hello Reef with merged configuration.
|
Modifier and Type | Method and Description |
---|---|
static void |
SchedulerREEFYarn.main(String[] args)
Launch the scheduler with YARN client configuration.
|
static void |
SchedulerREEF.main(String[] args)
Main program.
|
static void |
SchedulerREEF.runTaskScheduler(Configuration runtimeConf,
String[] args)
Run the Task scheduler.
|
Modifier and Type | Method and Description |
---|---|
Topology |
TopologyFactory.getNewInstance(Class<? extends Name<String>> operatorName,
Class<? extends Topology> topologyClass)
Instantiates a new Topology instance.
|
CommunicationGroupDriver |
CommunicationGroupDriverFactory.getNewInstance(Class<? extends Name<String>> groupName,
Class<? extends Topology> topologyClass,
BroadcastingEventHandler<GroupCommunicationMessage> commGroupMessageHandler,
int numberOfTasks,
int customFanOut)
Deprecated.
in 0.14.
Instantiates a new CommunicationGroupDriver instance.
|
CommunicationGroupDriver |
CommunicationGroupDriverFactory.getNewInstance(Class<? extends Name<String>> groupName,
Class<? extends Topology> topologyClass,
int numberOfTasks,
int customFanOut)
Instantiates a new CommunicationGroupDriver instance.
|
Modifier and Type | Method and Description |
---|---|
<U> U |
Injector.getInstance(Class<U> iface)
Gets an instance of iface, or the implementation that has been bound to it.
|
<U> U |
Injector.getInstance(String iface)
Gets an instance of iface, or the implementation that has been bound to it.
|
<U> U |
Injector.getNamedInstance(Class<? extends Name<U>> iface)
Gets the value stored for the given named parameter.
|
Modifier and Type | Method and Description |
---|---|
static void |
TimerV1.main(String[] args) |
static void |
PrintTypeHierarchy.main(String[] args) |
Modifier and Type | Method and Description |
---|---|
static void |
TimerMock.main(String[] args) |
Modifier and Type | Method and Description |
---|---|
<U> U |
InjectorImpl.getInstance(Class<U> clazz) |
<U> U |
InjectorImpl.getInstance(String clazz) |
<T> T |
InjectorImpl.getNamedInstance(Class<? extends Name<T>> clazz) |
<T> T |
InjectorImpl.getNamedParameter(Class<? extends Name<T>> clazz) |
Modifier and Type | Method and Description |
---|---|
static void |
ValidateConfiguration.main(String[] argv) |
void |
ValidateConfiguration.validatePlan() |
Modifier and Type | Method and Description |
---|---|
static TestDriverLauncher |
TestDriverLauncher.getLauncher(Configuration runtimeConfiguration)
Instantiate a launcher for the given Configuration.
|
Modifier and Type | Method and Description |
---|---|
static LauncherStatus |
FailClient.run(Class<?> failMsgClass,
Configuration runtimeConfig,
int timeOut) |
Modifier and Type | Method and Description |
---|---|
static LauncherStatus |
Client.run(Class<? extends Task> failTaskClass,
Configuration runtimeConfig,
int timeOut) |
Modifier and Type | Method and Description |
---|---|
static LauncherStatus |
DriverMessaging.run(Configuration runtimeConfiguration,
int launcherTimeout) |
Modifier and Type | Method and Description |
---|---|
static void |
FailureREEF.main(String[] args) |
static LauncherStatus |
FailureREEF.runFailureReef(Configuration runtimeConfig,
int timeout) |
Copyright © 2016 The Apache Software Foundation. All rights reserved.