public abstract class AbstractBootYarnClusterTests
extends org.springframework.yarn.test.junit.AbstractYarnClusterTests
| Modifier and Type | Class and Description |
|---|---|
static class |
AbstractBootYarnClusterTests.EmptyConfig
Empty Spring @
Configuration
class which can be referenced from tests solely using JavaConfig. |
| Constructor and Description |
|---|
AbstractBootYarnClusterTests() |
| Modifier and Type | Method and Description |
|---|---|
void |
setYarnClient(org.springframework.yarn.client.YarnClient yarnClient) |
protected org.springframework.yarn.test.junit.ApplicationInfo |
submitApplicationAndWait(Object source,
String[] args)
Submits application and wait state.
|
protected org.springframework.yarn.test.junit.ApplicationInfo |
submitApplicationAndWait(Object source,
String[] args,
long timeout,
TimeUnit unit)
Submits application and wait state.
|
protected org.springframework.yarn.test.junit.ApplicationInfo |
submitApplicationAndWaitState(Object source,
String[] args,
long timeout,
TimeUnit unit,
YarnApplicationState... applicationStates)
Submits application and wait state.
|
getApplicationContext, getConfiguration, getState, getYarnClient, getYarnCluster, killApplication, setApplicationContext, setConfiguration, setYarnCluster, submitApplication, submitApplicationAndWait, submitApplicationAndWait, submitApplicationAndWaitState, waitStatepublic void setYarnClient(org.springframework.yarn.client.YarnClient yarnClient)
setYarnClient in class org.springframework.yarn.test.junit.AbstractYarnClusterTestsprotected org.springframework.yarn.test.junit.ApplicationInfo submitApplicationAndWait(Object source, String[] args) throws Exception
source - the boot application config sourceargs - the boot application argsException - if exception occurredApplicationInfo,
submitApplicationAndWaitState(Object, String[], long, TimeUnit, YarnApplicationState...)protected org.springframework.yarn.test.junit.ApplicationInfo submitApplicationAndWait(Object source, String[] args, long timeout, TimeUnit unit) throws Exception
source - the boot application config sourceargs - the boot application argstimeout - the timeout for waitunit - the unit for timeoutException - if exception occurredApplicationInfo,
submitApplicationAndWaitState(Object, String[], long, TimeUnit, YarnApplicationState...)protected org.springframework.yarn.test.junit.ApplicationInfo submitApplicationAndWaitState(Object source, String[] args, long timeout, TimeUnit unit, YarnApplicationState... applicationStates) throws Exception
NULL
if something failed or final known state after the wait/poll operations.
Array of application states can be used to return immediately from wait
loop if state is matched.source - the boot application config sourceargs - the boot application argstimeout - the timeout for waitunit - the unit for timeoutapplicationStates - the application states to waitException - if exception occurredApplicationInfo