public final class REEFEnvironment extends Object implements Runnable, AutoCloseable
Modifier and Type | Method and Description |
---|---|
void |
close()
Close and cleanup the environment.
|
static REEFEnvironment |
fromConfiguration(Configuration... configurations)
Create a new REEF environment.
|
static REEFEnvironment |
fromConfiguration(UserCredentials hostUser,
Configuration... configurations)
Create a new REEF environment.
|
ReefServiceProtos.JobStatusProto |
getLastStatus()
Get the last known status of REEF job.
|
void |
run()
Launch REEF component (Driver or Evaluator).
|
public static REEFEnvironment fromConfiguration(Configuration... configurations) throws InjectionException
configurations
- REEF component (Driver or Evaluator) configuration.
If multiple configurations are provided, they will be merged before use.
Main part of the configuration is usually read from config file by REEFLauncher.InjectionException
- Thrown on configuration error.public static REEFEnvironment fromConfiguration(UserCredentials hostUser, Configuration... configurations) throws InjectionException
hostUser
- User credentials to use when registering REEF app with the Resource Manager.
This parameter may be required for Unmanaged AM mode. Can be null.configurations
- REEF component (Driver or Evaluator) configuration.
If multiple configurations are provided, they will be merged before use.
Main part of the configuration is usually read from config file by REEFLauncher.InjectionException
- Thrown on configuration error.public void close()
close
in interface AutoCloseable
public void run()
public ReefServiceProtos.JobStatusProto getLastStatus()
Copyright © 2017 The Apache Software Foundation. All rights reserved.