public abstract class AbstractYarnClusterTests extends Object implements ApplicationContextAware
| Modifier and Type | Field and Description |
|---|---|
protected ApplicationContext |
applicationContext |
protected Configuration |
configuration |
protected org.springframework.yarn.client.YarnClient |
yarnClient |
protected YarnCluster |
yarnCluster |
| Constructor and Description |
|---|
AbstractYarnClusterTests() |
| Modifier and Type | Method and Description |
|---|---|
ApplicationContext |
getApplicationContext()
Gets the
ApplicationContext for tests. |
Configuration |
getConfiguration()
Gets the running cluster runtime
Configuration for tests. |
protected YarnApplicationState |
getState(ApplicationId applicationId)
Get the current application state.
|
org.springframework.yarn.client.YarnClient |
getYarnClient()
Gets the
YarnClient. |
YarnCluster |
getYarnCluster()
Gets the running
YarnCluster for tests. |
protected void |
killApplication(ApplicationId applicationId)
Kill the application.
|
void |
setApplicationContext(ApplicationContext applicationContext) |
void |
setConfiguration(Configuration configuration)
Sets the
Configuration. |
void |
setYarnClient(org.springframework.yarn.client.YarnClient yarnClient)
Sets the
YarnClient. |
void |
setYarnCluster(YarnCluster yarnCluster)
Sets the
YarnCluster |
protected ApplicationId |
submitApplication()
Submit an application.
|
protected ApplicationInfo |
submitApplicationAndWait()
Submits application and wait state.
|
protected ApplicationInfo |
submitApplicationAndWait(long timeout,
TimeUnit unit)
Submits application and wait state.
|
protected ApplicationInfo |
submitApplicationAndWaitState(long timeout,
TimeUnit unit,
YarnApplicationState... applicationStates)
Submits application and wait state.
|
protected YarnApplicationState |
waitState(ApplicationId applicationId,
long timeout,
TimeUnit unit,
YarnApplicationState... applicationStates)
Waits state.
|
protected ApplicationContext applicationContext
protected Configuration configuration
protected YarnCluster yarnCluster
protected org.springframework.yarn.client.YarnClient yarnClient
public ApplicationContext getApplicationContext()
ApplicationContext for tests.public final void setApplicationContext(ApplicationContext applicationContext)
setApplicationContext in interface ApplicationContextAwarepublic Configuration getConfiguration()
Configuration for tests.@Autowired public void setConfiguration(Configuration configuration)
Configuration.configuration - the Configurationpublic YarnCluster getYarnCluster()
YarnCluster for tests.@Autowired public void setYarnCluster(YarnCluster yarnCluster)
YarnClusteryarnCluster - the Yarn clusterpublic org.springframework.yarn.client.YarnClient getYarnClient()
YarnClient.@Autowired public void setYarnClient(org.springframework.yarn.client.YarnClient yarnClient)
YarnClient.yarnClient - the Yarn clientprotected ApplicationInfo submitApplicationAndWait() throws Exception
Exception - if exception occurredApplicationInfo,
submitApplicationAndWaitState(long, TimeUnit, YarnApplicationState...)protected ApplicationInfo submitApplicationAndWait(long timeout, TimeUnit unit) throws Exception
timeout - the timeout for waitunit - the unit for timeoutException - if exception occurredApplicationInfo,
submitApplicationAndWaitState(long, TimeUnit, YarnApplicationState...)protected ApplicationInfo submitApplicationAndWaitState(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.timeout - the timeout for waitunit - the unit for timeoutapplicationStates - the application states to waitException - if exception occurredApplicationInfoprotected ApplicationId submitApplication()
ApplicationIdprotected YarnApplicationState waitState(ApplicationId applicationId, 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.applicationId - the application idtimeout - the timeout for waitunit - the unit for timeoutapplicationStates - the application states to waitNULL if timeoutException - if exception occurredprotected void killApplication(ApplicationId applicationId)
applicationId - the application idprotected YarnApplicationState getState(ApplicationId applicationId)
applicationId - Yarn app application idNULL if not found