public final class FailClient extends Object
Modifier and Type | Method and Description |
---|---|
static LauncherStatus |
runClient(Class<?> failMsgClass,
Configuration runtimeConfig,
int timeOut)
Run REEF on specified runtime and fail (raise an exception) in a specified class.
|
static ReefServiceProtos.JobStatusProto |
runInProcess(Class<?> failMsgClass,
Configuration runtimeConfig,
int timeOut)
Run REEF in-process using specified runtime and fail (raise an exception) in a specified class.
|
public static LauncherStatus runClient(Class<?> failMsgClass, Configuration runtimeConfig, int timeOut) throws InjectionException
failMsgClass
- A class that should fail during the test.runtimeConfig
- REEF runtime configuration. Can be e.g. Local or YARN.timeOut
- REEF application timeout.InjectionException
- configuration error.public static ReefServiceProtos.JobStatusProto runInProcess(Class<?> failMsgClass, Configuration runtimeConfig, int timeOut) throws InjectionException
failMsgClass
- A class that should fail during the test.runtimeConfig
- REEF runtime configuration. Can be e.g. Local or YARN.timeOut
- REEF application timeout - not used yet.InjectionException
- configuration error.Copyright © 2017 The Apache Software Foundation. All rights reserved.