Package | Description |
---|---|
org.apache.twill.api |
Classes in this package provides core functionality of the Twill library.
|
org.apache.twill.api.security | |
org.apache.twill.internal |
This package provides internal classes for Twill.
|
org.apache.twill.yarn |
Classes in this package implement the Twill API for Apache Hadoop YARN.
|
Modifier and Type | Method and Description |
---|---|
RunId |
TwillContext.getApplicationRunId()
Returns the
RunId of this running application. |
RunId |
ServiceController.getRunId()
Returns the
RunId of the running application. |
RunId |
EventHandlerContext.getRunId() |
RunId |
TwillContext.getRunId()
Returns the
RunId of this running instance of TwillRunnable . |
Modifier and Type | Method and Description |
---|---|
TwillController |
TwillRunner.lookup(String applicationName,
RunId runId)
Gets a
TwillController for the given application and runId. |
SecureStore |
SecureStoreUpdater.update(String application,
RunId runId)
Deprecated.
Invoked when an update to SecureStore is needed.
|
Modifier and Type | Method and Description |
---|---|
abstract void |
SecureStoreRenewer.renew(String application,
RunId runId,
SecureStoreWriter secureStoreWriter)
Renew the secure store for an application run.
|
Modifier and Type | Field and Description |
---|---|
protected RunId |
AbstractTwillService.runId |
Modifier and Type | Method and Description |
---|---|
static RunId |
RunIds.fromString(String str) |
static RunId |
RunIds.generate() |
RunId |
BasicTwillContext.getApplicationRunId() |
RunId |
AbstractExecutionServiceController.getRunId() |
RunId |
BasicTwillContext.getRunId() |
RunId |
TwillRuntimeSpecification.getTwillAppRunId() |
Modifier and Type | Method and Description |
---|---|
TwillContainerController |
TwillContainerLauncher.start(RunId runId,
int instanceId,
Class<?> mainClass,
String classPath,
Location logLevelLocation)
Start execution run for a class in a container.
|
Constructor and Description |
---|
AbstractExecutionServiceController(RunId runId) |
AbstractTwillController(String appName,
RunId runId,
ZKClient zkClient,
boolean logCollectionEnabled,
Iterable<LogHandler> logHandlers) |
AbstractTwillService(ZKClient zkClient,
RunId runId) |
AbstractZKServiceController(RunId runId,
ZKClient zkClient) |
BasicTwillContext(RunId runId,
RunId appRunId,
InetAddress host,
String[] args,
String[] appArgs,
TwillRunnableSpecification spec,
int instanceId,
DiscoveryService discoveryService,
DiscoveryServiceClient discoveryServiceClient,
ZKClient zkClient,
int instanceCount,
int allowedMemoryMB,
int virtualCores) |
TwillRuntimeSpecification(TwillSpecification twillSpecification,
String fsUser,
URI twillAppDir,
String zkConnectStr,
RunId twillRunId,
String twillAppName,
String rmSchedulerAddr,
Map<String,Map<String,String>> logLevels,
Map<String,Integer> maxRetries,
Map<String,String> config,
Map<String,Map<String,String>> runnableConfigs) |
TwillZKPathService(ZKClient zkClient,
RunId runId) |
Modifier and Type | Method and Description |
---|---|
TwillController |
YarnTwillRunnerService.lookup(String applicationName,
RunId runId) |
Copyright © 2013-2020 The Apache Software Foundation. All rights reserved.