- abort() - Static method in class org.apache.twill.api.EventHandler.TimeoutAction
-
- aborted() - Method in class org.apache.twill.api.EventHandler
-
Invoked by the application when the application is aborted because of timeout.
- ABORTED - Static variable in class org.apache.twill.internal.ContainerExitCodes
-
Containers killed by the framework, either due to being released by
the application or being 'lost' due to node failures etc.
- AbstractExecutionServiceController - Class in org.apache.twill.internal
-
An abstract base class for implementing
ServiceController
that deal with Service state transition and
listener callback.
- AbstractExecutionServiceController(RunId) - Constructor for class org.apache.twill.internal.AbstractExecutionServiceController
-
- AbstractTwillController - Class in org.apache.twill.internal
-
A abstract base class for
TwillController
implementation that uses Zookeeper to controller a
running twill application.
- AbstractTwillController(String, RunId, ZKClient, boolean, Iterable<LogHandler>) - Constructor for class org.apache.twill.internal.AbstractTwillController
-
- AbstractTwillRunnable - Class in org.apache.twill.api
-
This abstract class provides default implementation of the
TwillRunnable
.
- AbstractTwillRunnable() - Constructor for class org.apache.twill.api.AbstractTwillRunnable
-
- AbstractTwillRunnable(Map<String, String>) - Constructor for class org.apache.twill.api.AbstractTwillRunnable
-
- AbstractTwillService - Class in org.apache.twill.internal
-
A base implementation of Service
that uses ZooKeeper to transmit states and messages.
- AbstractTwillService(ZKClient, RunId) - Constructor for class org.apache.twill.internal.AbstractTwillService
-
- AbstractZKClient - Class in org.apache.twill.zookeeper
-
An abstract base implementation of
ZKClient
that simplifies implementation by providing forwarding for
methods that are meant to be delegated to other methods.
- AbstractZKClient() - Constructor for class org.apache.twill.zookeeper.AbstractZKClient
-
- AbstractZKServiceController - Class in org.apache.twill.internal
-
An abstract base class for implementing a
ServiceController
using ZooKeeper as a means for
communicating with the remote service.
- AbstractZKServiceController(RunId, ZKClient) - Constructor for class org.apache.twill.internal.AbstractZKServiceController
-
- accept(String, URL, URL) - Method in class org.apache.twill.api.ClassAcceptor
-
Invoked to determine if class can be accepted.
- ACLData - Interface in org.apache.twill.zookeeper
-
- add(String, File) - Method in interface org.apache.twill.api.TwillSpecification.Builder.LocalFileAdder
-
- add(String, URI) - Method in interface org.apache.twill.api.TwillSpecification.Builder.LocalFileAdder
-
- add(String, File, boolean) - Method in interface org.apache.twill.api.TwillSpecification.Builder.LocalFileAdder
-
- add(String, URI, boolean) - Method in interface org.apache.twill.api.TwillSpecification.Builder.LocalFileAdder
-
- add(String, File, String) - Method in interface org.apache.twill.api.TwillSpecification.Builder.LocalFileAdder
-
- add(String, URI, String) - Method in interface org.apache.twill.api.TwillSpecification.Builder.LocalFileAdder
-
- add(String, File) - Method in class org.apache.twill.api.TwillSpecification.Builder.MoreFile
-
- add(String, URI) - Method in class org.apache.twill.api.TwillSpecification.Builder.MoreFile
-
- add(String, File, boolean) - Method in class org.apache.twill.api.TwillSpecification.Builder.MoreFile
-
- add(String, URI, boolean) - Method in class org.apache.twill.api.TwillSpecification.Builder.MoreFile
-
- add(String, File, String) - Method in class org.apache.twill.api.TwillSpecification.Builder.MoreFile
-
- add(String, URI, String) - Method in class org.apache.twill.api.TwillSpecification.Builder.MoreFile
-
- add(Hosts, String, String...) - Method in interface org.apache.twill.api.TwillSpecification.Builder.MorePlacementPolicies
-
Specify hosts for a list of runnables.
- add(Racks, String, String...) - Method in interface org.apache.twill.api.TwillSpecification.Builder.MorePlacementPolicies
-
Specify racks for a list of runnables.
- add(Hosts, Racks, String, String...) - Method in interface org.apache.twill.api.TwillSpecification.Builder.MorePlacementPolicies
-
Specify hosts and racks for a list of runnables.
- add(TwillSpecification.PlacementPolicy.Type, String, String...) - Method in interface org.apache.twill.api.TwillSpecification.Builder.MorePlacementPolicies
-
Specify a placement policy for a list of runnables.
- add(TwillRunnable) - Method in interface org.apache.twill.api.TwillSpecification.Builder.MoreRunnable
-
- add(TwillRunnable, ResourceSpecification) - Method in interface org.apache.twill.api.TwillSpecification.Builder.MoreRunnable
-
- add(String, TwillRunnable) - Method in interface org.apache.twill.api.TwillSpecification.Builder.MoreRunnable
-
- add(String, TwillRunnable, ResourceSpecification) - Method in interface org.apache.twill.api.TwillSpecification.Builder.MoreRunnable
-
- add(Hosts, String, String...) - Method in class org.apache.twill.api.TwillSpecification.Builder.PlacementPolicySetter
-
- add(Racks, String, String...) - Method in class org.apache.twill.api.TwillSpecification.Builder.PlacementPolicySetter
-
- add(Hosts, Racks, String, String...) - Method in class org.apache.twill.api.TwillSpecification.Builder.PlacementPolicySetter
-
- add(TwillSpecification.PlacementPolicy.Type, String, String...) - Method in class org.apache.twill.api.TwillSpecification.Builder.PlacementPolicySetter
-
- add(TwillRunnable) - Method in class org.apache.twill.api.TwillSpecification.Builder.RunnableSetter
-
- add(TwillRunnable, ResourceSpecification) - Method in class org.apache.twill.api.TwillSpecification.Builder.RunnableSetter
-
- add(String, TwillRunnable) - Method in class org.apache.twill.api.TwillSpecification.Builder.RunnableSetter
-
- add(String, TwillRunnable, ResourceSpecification) - Method in class org.apache.twill.api.TwillSpecification.Builder.RunnableSetter
-
- add(String, int, long) - Method in interface org.apache.twill.kafka.client.KafkaConsumer.Preparer
-
Consumes messages from a given offset.
- add(ByteBuffer, Object) - Method in interface org.apache.twill.kafka.client.KafkaPublisher.Preparer
-
Adds the given message to the message set, partitioned with the given partition key.
- addAuthInfo(String, byte[]) - Method in class org.apache.twill.zookeeper.ZKClientService.Builder
-
Adds an authorization information.
- addChangeListener(BrokerService.BrokerChangeListener, Executor) - Method in interface org.apache.twill.kafka.client.BrokerService
-
Adds a listener to changes in broker list managed by this service.
- addCommand(String, String...) - Method in interface org.apache.twill.internal.ProcessLauncher.PrepareLaunchContext
-
Adds a command line to run in the container process.
- addConnectionWatcher(Watcher) - Method in class org.apache.twill.zookeeper.ForwardingZKClient
-
- addConnectionWatcher(Watcher) - Method in interface org.apache.twill.zookeeper.ZKClient
-
Adds a Watcher
that will be called whenever connection state change.
- addEnvironment(String, V) - Method in interface org.apache.twill.internal.ProcessLauncher.PrepareLaunchContext
-
Adds a key value pair to the container environment.
- addFromBeginning(String, int) - Method in interface org.apache.twill.kafka.client.KafkaConsumer.Preparer
-
Consumes messages from the earliest message available.
- addJVMOptions(String) - Method in interface org.apache.twill.api.TwillPreparer
-
This methods adds extra JVM options that will be passed to the java command line for every runnable
of the application started through this
TwillPreparer
instance.
- addLatest(String, int) - Method in interface org.apache.twill.kafka.client.KafkaConsumer.Preparer
-
Consumes messages from the latest message.
- addListener(Service.Listener, Executor) - Method in class org.apache.twill.internal.AbstractExecutionServiceController
-
- addListener(Service.Listener, Executor) - Method in class org.apache.twill.zookeeper.ForwardingZKClientService
-
- addLogHandler(LogHandler) - Method in interface org.apache.twill.api.TwillController
-
- addLogHandler(LogHandler) - Method in interface org.apache.twill.api.TwillPreparer
-
Adds a
LogHandler
for receiving an application log.
- addLogHandler(LogHandler) - Method in class org.apache.twill.internal.AbstractTwillController
-
- addOption(String, String) - Method in class org.apache.twill.api.Command.Builder
-
- addOptions(Map<String, String>) - Method in class org.apache.twill.api.Command.Builder
-
- addResources(LocalFile...) - Method in interface org.apache.twill.internal.ProcessLauncher.PrepareLaunchContext
-
Adds list of files to be localized for the container.
- addResources(Iterable<LocalFile>) - Method in interface org.apache.twill.internal.ProcessLauncher.PrepareLaunchContext
-
Adds list of files to be localized for the container.
- addRunResources(String, TwillRunResources) - Method in class org.apache.twill.internal.DefaultResourceReport
-
Add resources used by an instance of the runnable.
- addSecureStore(SecureStore) - Method in interface org.apache.twill.api.TwillPreparer
-
Adds security credentials for the runtime environment to gives application access to resources.
- AfterConfigs() - Constructor for class org.apache.twill.api.TwillRunnableSpecification.Builder.AfterConfigs
-
- AfterInstances() - Constructor for class org.apache.twill.api.ResourceSpecification.Builder.AfterInstances
-
- AfterMemory() - Constructor for class org.apache.twill.api.ResourceSpecification.Builder.AfterMemory
-
- AfterName() - Constructor for class org.apache.twill.api.TwillRunnableSpecification.Builder.AfterName
-
- AfterName() - Constructor for class org.apache.twill.api.TwillSpecification.Builder.AfterName
-
- AfterUplink() - Constructor for class org.apache.twill.api.ResourceSpecification.Builder.AfterUplink
-
- announce(String, int) - Method in interface org.apache.twill.api.ServiceAnnouncer
-
Registers an endpoint that could be discovered by external party.
- announce(String, int, byte[]) - Method in interface org.apache.twill.api.ServiceAnnouncer
-
Registers an endpoint that could be discovered by external party with a payload.
- announce(String, int) - Method in class org.apache.twill.internal.BasicTwillContext
-
- announce(String, int, byte[]) - Method in class org.apache.twill.internal.BasicTwillContext
-
- anyOrder() - Method in interface org.apache.twill.api.TwillSpecification.Builder.AfterPlacementPolicy
-
No particular execution order is needed.
- anyOrder() - Method in interface org.apache.twill.api.TwillSpecification.Builder.AfterRunnable
-
- anyOrder() - Method in class org.apache.twill.api.TwillSpecification.Builder.PlacementPolicySetter
-
- anyOrder() - Method in class org.apache.twill.api.TwillSpecification.Builder.RunnableSetter
-
- append(String) - Method in interface org.apache.twill.filesystem.Location
-
Appends the child to the current
Location
.
- APPLICATION_CLASSPATH - Static variable in class org.apache.twill.internal.Constants.Files
-
- APPLICATION_JAR - Static variable in class org.apache.twill.internal.Constants.Files
-
- APPLICATION_MAX_START_SECONDS - Static variable in class org.apache.twill.internal.Constants
-
Maximum number of seconds for AM to start.
- APPLICATION_MAX_STOP_SECONDS - Static variable in class org.apache.twill.internal.Constants
-
Maximum number of seconds for AM to stop.
- ApplicationBundler - Class in org.apache.twill.internal
-
This class builds jar files based on class dependencies.
- ApplicationBundler(Iterable<String>) - Constructor for class org.apache.twill.internal.ApplicationBundler
-
Constructs an ApplicationBundler.
- ApplicationBundler(Iterable<String>, Iterable<String>) - Constructor for class org.apache.twill.internal.ApplicationBundler
-
Constructs an ApplicationBundler.
- ApplicationBundler(ClassAcceptor) - Constructor for class org.apache.twill.internal.ApplicationBundler
-
Constructs an ApplicationBundler.
- apply() - Method in class org.apache.twill.api.TwillSpecification.Builder.MoreFile
-
- Arguments(String, String, String, String[]) - Constructor for class org.apache.twill.ext.BundledJarRunner.Arguments
-
- Arguments - Class in org.apache.twill.internal
-
Class that encapsulate application arguments and per runnable arguments.
- Arguments(List<String>, Multimap<String, String>) - Constructor for class org.apache.twill.internal.Arguments
-
- ARGUMENTS - Static variable in class org.apache.twill.internal.Constants.Files
-
- awaitTerminated() - Method in interface org.apache.twill.api.ServiceController
-
Waits for termination of the remote service.
- awaitTerminated(long, TimeUnit) - Method in interface org.apache.twill.api.ServiceController
-
Waits for termination of the remote service for no more than the given timeout limit.
- awaitTerminated() - Method in class org.apache.twill.internal.AbstractExecutionServiceController
-
- awaitTerminated(long, TimeUnit) - Method in class org.apache.twill.internal.AbstractExecutionServiceController
-
- cancel() - Method in interface org.apache.twill.common.Cancellable
-
Attempts to cancel execution of this task.
- cancel() - Method in interface org.apache.twill.internal.ProcessController
-
Request to stop the running process.
- Cancellable - Interface in org.apache.twill.common
-
Something, usually a task, that can be cancelled.
- chainStart(Service, Service...) - Static method in class org.apache.twill.internal.Services
-
Starts a list of Service
one by one.
- chainStop(Service, Service...) - Static method in class org.apache.twill.internal.Services
-
Stops a list of Service
one by one.
- changed(BrokerService) - Method in class org.apache.twill.kafka.client.BrokerService.BrokerChangeListener
-
Invoked when there is a change in the broker list.
- changeInstances(String, int) - Method in interface org.apache.twill.api.TwillController
-
Changes the number of running instances of a given runnable.
- changeInstances(String, int) - Method in class org.apache.twill.internal.AbstractTwillController
-
- ClassAcceptor - Class in org.apache.twill.api
-
Class that can be used to determine if class can be accepted.
- ClassAcceptor() - Constructor for class org.apache.twill.api.ClassAcceptor
-
- CLASSPATH - Static variable in class org.apache.twill.internal.Constants.Files
-
- close() - Method in class org.apache.twill.discovery.ZKDiscoveryService
-
- Command - Interface in org.apache.twill.api
-
Represents command objects.
- Command.Builder - Class in org.apache.twill.api
-
Builder for creating
Command
object.
- completed() - Method in class org.apache.twill.api.EventHandler
-
Invoked by the application when all containers complete.
- completed(int) - Method in interface org.apache.twill.internal.TwillContainerController
-
Calls to indicated that the container that this controller is associated with is completed.
- CompositeService - Class in org.apache.twill.internal
-
A Service
that starts/stops list of services in order.
- CompositeService(Service...) - Constructor for class org.apache.twill.internal.CompositeService
-
- CompositeService(Iterable<? extends Service>) - Constructor for class org.apache.twill.internal.CompositeService
-
- Compression - Enum in org.apache.twill.kafka.client
-
An Enum representing different compression codec options for publishing messages.
- Configs - Class in org.apache.twill.api
-
Defines keys and default values constants being used for configuration.
- Configs.Defaults - Class in org.apache.twill.api
-
Defines default configuration values.
- Configs.Keys - Class in org.apache.twill.api
-
Defines keys being used in configuration.
- configure() - Method in class org.apache.twill.api.AbstractTwillRunnable
-
- configure() - Method in class org.apache.twill.api.EventHandler
-
- configure() - Method in interface org.apache.twill.api.TwillApplication
-
Invoked when launching the application on the client side.
- configure() - Method in interface org.apache.twill.api.TwillRunnable
-
Called at submission time.
- configure() - Method in class org.apache.twill.ext.BundledJarRunnable
-
- configure() - Method in class org.apache.twill.internal.SingleRunnableApplication
-
- Constants - Class in org.apache.twill.internal
-
This class contains collection of common constants used in Twill.
- Constants.Files - Class in org.apache.twill.internal
-
Constants for names of internal files that are shared between client, AM and containers.
- CONSTRAINED_PROVISION_REQUEST_TIMEOUT - Static variable in class org.apache.twill.internal.Constants
-
Milliseconds AM should wait for RM to allocate a constrained provision request.
- consume(KafkaConsumer.MessageCallback) - Method in interface org.apache.twill.kafka.client.KafkaConsumer.Preparer
-
- ContainerExitCodes - Class in org.apache.twill.internal
-
Collection of known exit code.
- ContainerExitCodes() - Constructor for class org.apache.twill.internal.ContainerExitCodes
-
- ContainerInfo - Interface in org.apache.twill.internal
-
Represents information of the container that the processing is/will be running in.
- containerLaunched(String, int, String) - Method in class org.apache.twill.api.EventHandler
-
Invoked by the application when new container is launched for a
TwillRunnable
.
- ContainerLiveNodeData - Class in org.apache.twill.internal
-
- ContainerLiveNodeData(String, String, String, Map<String, String>) - Constructor for class org.apache.twill.internal.ContainerLiveNodeData
-
- containerStopped(String, int, String, int) - Method in class org.apache.twill.api.EventHandler
-
Invoked by the application when the container allocated for a
TwillRunnable
is stopped.
- contains(Discoverable) - Method in interface org.apache.twill.discovery.ServiceDiscovered
-
Checks if the given discoverable contains in the current discovery list.
- context - Variable in class org.apache.twill.api.EventHandler
-
- CoreSetter() - Constructor for class org.apache.twill.api.ResourceSpecification.Builder.CoreSetter
-
- create(String) - Method in class org.apache.twill.filesystem.FileContextLocationFactory
-
- create(URI) - Method in class org.apache.twill.filesystem.FileContextLocationFactory
-
- create(String) - Method in class org.apache.twill.filesystem.LocalLocationFactory
-
- create(URI) - Method in class org.apache.twill.filesystem.LocalLocationFactory
-
- create(String) - Method in interface org.apache.twill.filesystem.LocationFactory
-
Creates an instance of
Location
of the given path.
- create(URI) - Method in interface org.apache.twill.filesystem.LocationFactory
-
- create(Credentials) - Static method in class org.apache.twill.yarn.YarnSecureStore
-
- create(String, byte[], CreateMode) - Method in class org.apache.twill.zookeeper.AbstractZKClient
-
- create(String, byte[], CreateMode, boolean) - Method in class org.apache.twill.zookeeper.AbstractZKClient
-
- create(String, byte[], CreateMode, Iterable<ACL>) - Method in class org.apache.twill.zookeeper.AbstractZKClient
-
- create(String, byte[], CreateMode, boolean, Iterable<ACL>) - Method in class org.apache.twill.zookeeper.ForwardingZKClient
-
- create(String, byte[], CreateMode) - Method in interface org.apache.twill.zookeeper.ZKClient
-
Creates a path in zookeeper.
- create(String, byte[], CreateMode, boolean) - Method in interface org.apache.twill.zookeeper.ZKClient
-
Creates a path in zookeeper.
- create(String, byte[], CreateMode, Iterable<ACL>) - Method in interface org.apache.twill.zookeeper.ZKClient
-
Creates a path in zookeeper.
- create(String, byte[], CreateMode, boolean, Iterable<ACL>) - Method in interface org.apache.twill.zookeeper.ZKClient
-
Creates a path in zookeeper, with given data and create mode.
- createAppLocation(Configuration, String, URI) - Method in class org.apache.twill.internal.ServiceMain
-
Returns the
Location
for the application based on the app directory.
- createArguments() - Method in class org.apache.twill.ext.BundledJarRunner.Arguments.Builder
-
- createBundle(Location, Iterable<Class<?>>) - Method in class org.apache.twill.internal.ApplicationBundler
-
- createBundle(Location, Class<?>, Class<?>...) - Method in class org.apache.twill.internal.ApplicationBundler
-
- createBundle(Location, Iterable<Class<?>>, Iterable<URI>) - Method in class org.apache.twill.internal.ApplicationBundler
-
Creates a jar file which includes all the given classes and all the classes that they depended on.
- createDaemonThreadFactory(String) - Static method in class org.apache.twill.common.Threads
-
Handy method to create
ThreadFactory
that creates daemon threads with the given name format.
- createDeleteIfExists(ZKClient, String, byte[], CreateMode, boolean, ACL...) - Static method in class org.apache.twill.zookeeper.ZKOperations
-
Creates a ZK node of the given path.
- createLock(String) - Method in interface org.apache.twill.api.TwillContext
-
- createLock(String) - Method in class org.apache.twill.internal.BasicTwillContext
-
- createNew() - Method in interface org.apache.twill.filesystem.Location
-
Atomically creates a new, empty file named by this abstract pathname if and only if a file with this name
does not yet exist.
- createNew(String) - Method in interface org.apache.twill.filesystem.Location
-
Atomically creates a new, empty file named by this abstract pathname if and only if a file with this name
does not yet exist.
- createZKClient() - Method in class org.apache.twill.internal.ServiceMain
-
- CREDENTIALS - Static variable in class org.apache.twill.internal.Constants.Files
-
- generate() - Static method in class org.apache.twill.internal.RunIds
-
- get() - Method in class org.apache.twill.api.Hosts
-
Get the list of hosts.
- get() - Method in class org.apache.twill.api.Racks
-
Get the list of racks.
- getAck() - Method in enum org.apache.twill.kafka.client.KafkaPublisher.Ack
-
Returns the numerical ack number as understand by Kafka server.
- getACL() - Method in interface org.apache.twill.zookeeper.ACLData
-
- getACL(String) - Method in class org.apache.twill.zookeeper.ForwardingZKClient
-
- getACL(String) - Method in interface org.apache.twill.zookeeper.ZKClient
-
Retrieves the Stat and ACL being set at the given path.
- getActualInstances() - Method in class org.apache.twill.api.EventHandler.TimeoutEvent
-
- getAMExtraOptions() - Method in class org.apache.twill.internal.JvmOptions
-
Returns the extra options for the application master.
- getAMMinHeapRatio() - Method in class org.apache.twill.internal.TwillRuntimeSpecification
-
Returns the minimum heap ratio for the application master.
- getAMReservedMemory() - Method in class org.apache.twill.internal.TwillRuntimeSpecification
-
Returns the reserved non-heap memory size in MB for the application master.
- getApplicationArguments() - Method in interface org.apache.twill.api.TwillContext
-
- getApplicationArguments() - Method in class org.apache.twill.internal.BasicTwillContext
-
- getApplicationId() - Method in interface org.apache.twill.api.ResourceReport
-
Get the id of the application master.
- getApplicationId() - Method in class org.apache.twill.internal.DefaultResourceReport
-
Get the id of the application master.
- getApplicationName() - Method in interface org.apache.twill.api.EventHandlerContext
-
- getApplicationName() - Method in interface org.apache.twill.api.TwillRunner.LiveInfo
-
Returns name of the application.
- getApplicationRunId() - Method in interface org.apache.twill.api.TwillContext
-
Returns the
RunId
of this running application.
- getApplicationRunId() - Method in class org.apache.twill.internal.BasicTwillContext
-
- getAppMasterResources() - Method in interface org.apache.twill.api.ResourceReport
-
Get the resources application master is using.
- getAppMasterResources() - Method in class org.apache.twill.internal.DefaultResourceReport
-
Get the resources application master is using.
- getArgument(String) - Method in class org.apache.twill.api.AbstractTwillRunnable
-
- getArguments() - Method in class org.apache.twill.api.AbstractTwillRunnable
-
- getArguments() - Method in interface org.apache.twill.api.TwillContext
-
Returns the runtime arguments that are passed to the
TwillRunnable
.
- getArguments() - Method in class org.apache.twill.ext.BundledJarRunnable
-
- getArguments() - Method in class org.apache.twill.internal.Arguments
-
- getArguments() - Method in class org.apache.twill.internal.BasicTwillContext
-
- getBrokerList() - Method in interface org.apache.twill.kafka.client.BrokerService
-
Returns a comma separate string of all current brokers.
- getBrokers() - Method in interface org.apache.twill.kafka.client.BrokerService
-
Returns a live iterable that gives information for all the known brokers.
- getCause() - Method in interface org.apache.twill.api.logging.LogThrowable
-
- getChildren(String) - Method in class org.apache.twill.zookeeper.AbstractZKClient
-
- getChildren(String, Watcher) - Method in class org.apache.twill.zookeeper.ForwardingZKClient
-
- getChildren() - Method in interface org.apache.twill.zookeeper.NodeChildren
-
- getChildren(String) - Method in interface org.apache.twill.zookeeper.ZKClient
-
Gets the list of children nodes under the given path.
- getChildren(String, Watcher) - Method in interface org.apache.twill.zookeeper.ZKClient
-
Gets the list of children nodes under the given path and leave a watcher on the node for watching node
deletion and children nodes creation/deletion.
- getClassName() - Method in interface org.apache.twill.api.EventHandlerSpecification
-
- getClassName() - Method in interface org.apache.twill.api.logging.LogThrowable
-
Returns the name of the Throwable class.
- getClassName() - Method in interface org.apache.twill.api.TwillRunnableSpecification
-
- getClassName() - Method in class org.apache.twill.internal.DefaultEventHandlerSpecification
-
- getClassName() - Method in class org.apache.twill.internal.DefaultTwillRunnableSpecification
-
- getCodec() - Method in enum org.apache.twill.kafka.client.Compression
-
- getCommand() - Method in interface org.apache.twill.api.Command
-
- getCompletionFuture(Service) - Static method in class org.apache.twill.internal.Services
-
Returns a ListenableFuture
that will be completed when the given service is stopped.
- getConfig() - Method in class org.apache.twill.internal.TwillRuntimeSpecification
-
Returns the configuration for the application.
- getConfigs() - Method in class org.apache.twill.api.EventHandler
-
Returns set of configurations available at runtime for access.
- getConfigs() - Method in interface org.apache.twill.api.EventHandlerSpecification
-
- getConfigs() - Method in interface org.apache.twill.api.TwillRunnableSpecification
-
- getConfigs() - Method in class org.apache.twill.internal.DefaultEventHandlerSpecification
-
- getConfigs() - Method in class org.apache.twill.internal.DefaultTwillRunnableSpecification
-
- getConfiguration() - Method in class org.apache.twill.filesystem.FileContextLocationFactory
-
- getConnectString() - Method in class org.apache.twill.zookeeper.ForwardingZKClient
-
- getConnectString() - Method in interface org.apache.twill.zookeeper.ZKClient
-
Returns the connection string used for connecting to Zookeeper.
- getConsumer() - Method in interface org.apache.twill.kafka.client.KafkaClient
-
- getContainerId() - Method in interface org.apache.twill.api.TwillRunResources
-
- getContainerId() - Method in class org.apache.twill.internal.ContainerLiveNodeData
-
- getContainerId() - Method in class org.apache.twill.internal.DefaultTwillRunResources
-
- getContainerInfo() - Method in interface org.apache.twill.internal.ProcessLauncher
-
Returns information about the container that this launch would launch process in.
- getContext() - Method in class org.apache.twill.api.AbstractTwillRunnable
-
- getControllers() - Method in interface org.apache.twill.api.TwillRunner.LiveInfo
-
- getCores() - Method in interface org.apache.twill.api.ResourceSpecification
-
Deprecated.
- getCores() - Method in class org.apache.twill.internal.DefaultResourceSpecification
-
Deprecated.
- getData(String) - Method in class org.apache.twill.zookeeper.AbstractZKClient
-
- getData(String, Watcher) - Method in class org.apache.twill.zookeeper.ForwardingZKClient
-
- getData() - Method in interface org.apache.twill.zookeeper.NodeData
-
- getData(String) - Method in interface org.apache.twill.zookeeper.ZKClient
-
Gets the data stored in the given path.
- getData(String, Watcher) - Method in interface org.apache.twill.zookeeper.ZKClient
-
Gets the data stored in the given path and leave a watcher on the node for watching deletion/data changes on
the node.
- getDebugOptions() - Method in class org.apache.twill.internal.JvmOptions
-
- getDebugPort() - Method in interface org.apache.twill.api.TwillRunResources
-
- getDebugPort() - Method in class org.apache.twill.internal.ContainerLiveNodeData
-
- getDebugPort() - Method in class org.apache.twill.internal.DefaultTwillRunResources
-
- getDelegate() - Method in class org.apache.twill.filesystem.ForwardingLocationFactory
-
- getDelegate() - Method in class org.apache.twill.zookeeper.ForwardingZKClient
-
- getDownlink() - Method in interface org.apache.twill.api.ResourceSpecification
-
Returns the downlink bandwidth in Mbps.
- getDownlink() - Method in class org.apache.twill.internal.DefaultResourceSpecification
-
- getEventHandler() - Method in interface org.apache.twill.api.TwillSpecification
-
- getEventHandler() - Method in class org.apache.twill.internal.DefaultTwillSpecification
-
- getExpectedInstances() - Method in class org.apache.twill.api.EventHandler.TimeoutEvent
-
- getFileContext() - Method in class org.apache.twill.filesystem.FileContextLocationFactory
-
Returns the FileContext
for the current user based on UserGroupInformation.getCurrentUser()
.
- getFileName() - Method in interface org.apache.twill.api.logging.LogEntry
-
Returns the source file name where the log emitted.
- getFsUser() - Method in class org.apache.twill.internal.TwillRuntimeSpecification
-
- getGroup() - Method in interface org.apache.twill.filesystem.Location
-
Returns the group of the location.
- getHomeLocation() - Method in class org.apache.twill.filesystem.FileContextLocationFactory
-
- getHomeLocation() - Method in class org.apache.twill.filesystem.LocalLocationFactory
-
- getHomeLocation() - Method in interface org.apache.twill.filesystem.LocationFactory
-
Returns the home location.
- getHost() - Method in interface org.apache.twill.api.logging.LogEntry
-
Returns hostname of where the log emitted.
- getHost() - Method in interface org.apache.twill.api.TwillContext
-
Returns the hostname that the runnable is running on.
- getHost() - Method in interface org.apache.twill.api.TwillRunResources
-
- getHost() - Method in class org.apache.twill.internal.BasicTwillContext
-
- getHost() - Method in interface org.apache.twill.internal.ContainerInfo
-
Returns the host information of the container.
- getHost() - Method in class org.apache.twill.internal.ContainerLiveNodeData
-
- getHost() - Method in class org.apache.twill.internal.DefaultTwillRunResources
-
- getHost() - Method in class org.apache.twill.internal.EnvContainerInfo
-
- getHost() - Method in class org.apache.twill.kafka.client.BrokerInfo
-
- getHostname() - Method in class org.apache.twill.internal.ServiceMain
-
- getHosts() - Method in interface org.apache.twill.api.TwillSpecification.PlacementPolicy
-
- getHosts() - Method in class org.apache.twill.internal.DefaultTwillSpecification.DefaultPlacementPolicy
-
- getId() - Method in interface org.apache.twill.api.RunId
-
- getId() - Method in interface org.apache.twill.internal.ContainerInfo
-
Returns the ID of the container.
- getId() - Method in class org.apache.twill.internal.EnvContainerInfo
-
- getInputStream() - Method in interface org.apache.twill.filesystem.Location
-
- getInstanceCount() - Method in interface org.apache.twill.api.TwillContext
-
Returns the number of running instances assigned for this
TwillRunnable
.
- getInstanceCount() - Method in class org.apache.twill.internal.BasicTwillContext
-
- getInstanceId() - Method in interface org.apache.twill.api.TwillContext
-
Returns an integer id from 0 to (instanceCount - 1).
- getInstanceId() - Method in interface org.apache.twill.api.TwillRunResources
-
- getInstanceId() - Method in class org.apache.twill.internal.BasicTwillContext
-
- getInstanceId() - Method in class org.apache.twill.internal.DefaultTwillRunResources
-
- getInstanceId() - Method in interface org.apache.twill.internal.TwillContainerController
-
- getInstancePath() - Method in class org.apache.twill.internal.AbstractZKServiceController
-
Returns the zookeeper node path for the ephemeral instance node for this runId.
- getInstances() - Method in interface org.apache.twill.api.ResourceSpecification
-
Returns number of execution instances.
- getInstances() - Method in class org.apache.twill.internal.DefaultResourceSpecification
-
- getJarFileName() - Method in class org.apache.twill.ext.BundledJarRunner.Arguments
-
- getJVMOptions() - Method in class org.apache.twill.yarn.YarnTwillRunnerService
-
Returns any extra JVM options that have been set.
- getKafkaZKConnect() - Method in class org.apache.twill.internal.TwillRuntimeSpecification
-
Returns the ZK connection string for the Kafka used for log collections,
or null
if log collection is disabled.
- getLastModified() - Method in interface org.apache.twill.api.LocalFile
-
Returns the the last modified time of the file or -1
if unknown.
- getLastModified() - Method in class org.apache.twill.internal.DefaultLocalFile
-
- getLeader(String, int) - Method in interface org.apache.twill.kafka.client.BrokerService
-
Returns the broker information of the current leader of the given topic and partition.
- getLibFolder() - Method in class org.apache.twill.ext.BundledJarRunner.Arguments
-
- getLineNumber() - Method in interface org.apache.twill.api.logging.LogEntry
-
Returns the line number in the source file where the log emitted.
- getLiveNodeData() - Method in class org.apache.twill.internal.AbstractTwillService
-
Returns an Object to be stored in the live node.
- getLiveNodeData() - Method in interface org.apache.twill.internal.TwillContainerController
-
- getLiveNodeGson() - Method in class org.apache.twill.internal.AbstractTwillService
-
- getLocalFiles() - Method in interface org.apache.twill.api.RuntimeSpecification
-
- getLocalFiles() - Method in class org.apache.twill.internal.DefaultRuntimeSpecification
-
- getLocationFactory() - Method in interface org.apache.twill.filesystem.Location
-
Returns the location factory used to create this instance.
- getLoggerName() - Method in interface org.apache.twill.api.logging.LogEntry
-
Returns name of the logger.
- getLogLevel() - Method in interface org.apache.twill.api.logging.LogEntry
-
- getLogLevel() - Method in interface org.apache.twill.api.TwillRunResources
-
- getLogLevel() - Method in class org.apache.twill.internal.DefaultTwillRunResources
-
Deprecated.
- getLogLevels() - Method in interface org.apache.twill.api.TwillRunResources
-
- getLogLevels() - Method in class org.apache.twill.internal.ContainerLiveNodeData
-
- getLogLevels() - Method in class org.apache.twill.internal.DefaultTwillRunResources
-
- getLogLevels() - Method in class org.apache.twill.internal.TwillRuntimeSpecification
-
- getMainArgs() - Method in class org.apache.twill.ext.BundledJarRunner.Arguments
-
- getMainClassName() - Method in class org.apache.twill.ext.BundledJarRunner.Arguments
-
- getMaxHeapMemoryMB() - Method in interface org.apache.twill.api.TwillRunResources
-
- getMaxHeapMemoryMB() - Method in class org.apache.twill.internal.DefaultTwillRunResources
-
- getMaxHeapMemoryMB() - Method in class org.apache.twill.internal.TwillContainerLauncher
-
Returns the maximum heap memory size in MB of the Java process launched in the container.
- getMaxMemoryMB() - Method in interface org.apache.twill.api.TwillContext
-
Returns the amount of memory in MB the runnable is allowed to use.
- getMaxMemoryMB() - Method in class org.apache.twill.internal.BasicTwillContext
-
- getMaxRetries() - Method in class org.apache.twill.internal.TwillRuntimeSpecification
-
- getMemoryMB() - Method in interface org.apache.twill.api.TwillRunResources
-
- getMemoryMB() - Method in class org.apache.twill.internal.DefaultTwillRunResources
-
- getMemoryMB() - Method in class org.apache.twill.internal.EnvContainerInfo
-
- getMemoryMB() - Method in interface org.apache.twill.internal.ResourceCapability
-
Returns memory size in MB.
- getMemorySize() - Method in interface org.apache.twill.api.ResourceSpecification
-
Returns the memory size in MB.
- getMemorySize() - Method in class org.apache.twill.internal.DefaultResourceSpecification
-
- getMessage() - Method in interface org.apache.twill.api.logging.LogEntry
-
Returns the log message.
- getMessage() - Method in interface org.apache.twill.api.logging.LogThrowable
-
Returns the message contained inside the Throwable.
- getMinHeapRatio(String) - Method in class org.apache.twill.internal.TwillRuntimeSpecification
-
Returns the minimum heap ratio for the given runnable.
- getName() - Method in interface org.apache.twill.api.LocalFile
-
- getName() - Method in interface org.apache.twill.api.RuntimeSpecification
-
- getName() - Method in interface org.apache.twill.api.TwillRunnableSpecification
-
- getName() - Method in interface org.apache.twill.api.TwillSpecification
-
- getName() - Method in class org.apache.twill.discovery.Discoverable
-
- getName() - Method in interface org.apache.twill.discovery.ServiceDiscovered
-
Returns the name of the service being discovered.
- getName() - Method in interface org.apache.twill.filesystem.Location
-
- getName() - Method in class org.apache.twill.internal.DefaultLocalFile
-
- getName() - Method in class org.apache.twill.internal.DefaultRuntimeSpecification
-
- getName() - Method in class org.apache.twill.internal.DefaultTwillRunnableSpecification
-
- getName() - Method in class org.apache.twill.internal.DefaultTwillSpecification
-
- getNames() - Method in interface org.apache.twill.api.TwillSpecification.Order
-
- getNames() - Method in interface org.apache.twill.api.TwillSpecification.PlacementPolicy
-
- getNames() - Method in class org.apache.twill.internal.DefaultTwillSpecification.DefaultOrder
-
- getNames() - Method in class org.apache.twill.internal.DefaultTwillSpecification.DefaultPlacementPolicy
-
- getNextOffset() - Method in interface org.apache.twill.kafka.client.FetchedMessage
-
Returns the offset for the next message to be read.
- getOffset() - Method in interface org.apache.twill.kafka.client.FetchedMessage
-
Returns the offset for the current message.
- getOptions() - Method in interface org.apache.twill.api.Command
-
- getOrders() - Method in interface org.apache.twill.api.TwillSpecification
-
- getOrders() - Method in class org.apache.twill.internal.DefaultTwillSpecification
-
- getOutputStream() - Method in interface org.apache.twill.filesystem.Location
-
- getOutputStream(String) - Method in interface org.apache.twill.filesystem.Location
-
Creates an
OutputStream
for this location with the given permission.
- getOwner() - Method in interface org.apache.twill.filesystem.Location
-
Returns the owner of the location.
- getPartition() - Method in class org.apache.twill.kafka.client.TopicPartition
-
- getPattern() - Method in interface org.apache.twill.api.LocalFile
-
- getPattern() - Method in class org.apache.twill.internal.DefaultLocalFile
-
- getPayload() - Method in class org.apache.twill.discovery.Discoverable
-
- getPayload() - Method in interface org.apache.twill.kafka.client.FetchedMessage
-
- getPermissions() - Method in interface org.apache.twill.filesystem.Location
-
Returns the permissions of this
Location
.
- getPlacementPolicies() - Method in interface org.apache.twill.api.TwillSpecification
-
- getPlacementPolicies() - Method in class org.apache.twill.internal.DefaultTwillSpecification
-
- getPort() - Method in interface org.apache.twill.internal.ContainerInfo
-
Returns the port for communicating to the container host.
- getPort() - Method in class org.apache.twill.internal.EnvContainerInfo
-
- getPort() - Method in class org.apache.twill.kafka.client.BrokerInfo
-
- getPublisher(KafkaPublisher.Ack, Compression) - Method in interface org.apache.twill.kafka.client.KafkaClient
-
- getRacks() - Method in interface org.apache.twill.api.TwillSpecification.PlacementPolicy
-
- getRacks() - Method in class org.apache.twill.internal.DefaultTwillSpecification.DefaultPlacementPolicy
-
- getReport() - Method in interface org.apache.twill.internal.ProcessController
-
- getRequestPath() - Method in interface org.apache.twill.zookeeper.OperationFuture
-
- getRequestTime() - Method in class org.apache.twill.api.EventHandler.TimeoutEvent
-
- getReservedMemory(String) - Method in class org.apache.twill.internal.TwillRuntimeSpecification
-
Returns the reserved non-heap memory size in MB for the given runnable.
- getResourceReport() - Method in interface org.apache.twill.api.TwillController
-
Get a snapshot of the resources used by the application, broken down by each runnable.
- getResources() - Method in interface org.apache.twill.api.ResourceReport
-
Get all the run resources being used across all runnables.
- getResources() - Method in class org.apache.twill.internal.DefaultResourceReport
-
Get all the run resources being used across all runnables.
- getResourceSpecification() - Method in interface org.apache.twill.api.RuntimeSpecification
-
- getResourceSpecification() - Method in class org.apache.twill.internal.DefaultRuntimeSpecification
-
- getRmSchedulerAddr() - Method in class org.apache.twill.internal.TwillRuntimeSpecification
-
- getRunId() - Method in interface org.apache.twill.api.EventHandlerContext
-
- getRunId() - Method in interface org.apache.twill.api.ServiceController
-
Returns the
RunId
of the running application.
- getRunId() - Method in interface org.apache.twill.api.TwillContext
-
- getRunId() - Method in class org.apache.twill.internal.AbstractExecutionServiceController
-
- getRunId() - Method in class org.apache.twill.internal.BasicTwillContext
-
- getRunnableArguments() - Method in class org.apache.twill.internal.Arguments
-
- getRunnableConfigs() - Method in class org.apache.twill.internal.TwillRuntimeSpecification
-
Returns the configurations for each runnable.
- getRunnableExtraOptions(String) - Method in class org.apache.twill.internal.JvmOptions
-
Returns the extra options for the given runnable.
- getRunnableName() - Method in class org.apache.twill.api.EventHandler.TimeoutEvent
-
- getRunnableName() - Method in interface org.apache.twill.api.logging.LogEntry
-
Returns the runnable name.
- getRunnableName() - Method in class org.apache.twill.internal.ServiceMain
-
Returns the name of the runnable that this running inside this process.
- getRunnableResources(String) - Method in interface org.apache.twill.api.ResourceReport
-
Get all the run resources being used by all instances of the specified runnable.
- getRunnableResources(String) - Method in class org.apache.twill.internal.DefaultResourceReport
-
Get all the run resources being used by all instances of the specified runnable.
- getRunnables() - Method in interface org.apache.twill.api.TwillSpecification
-
- getRunnables() - Method in class org.apache.twill.internal.DefaultTwillSpecification
-
- getRunnables() - Method in class org.apache.twill.internal.JvmOptions.DebugOptions
-
- getRunnableSpecification() - Method in interface org.apache.twill.api.RuntimeSpecification
-
- getRunnableSpecification() - Method in class org.apache.twill.internal.DefaultRuntimeSpecification
-
- getServices() - Method in interface org.apache.twill.api.ResourceReport
-
Get the list of services of the application master.
- getServices() - Method in class org.apache.twill.internal.DefaultResourceReport
-
Get the list of services of the application master.
- getSessionId() - Method in class org.apache.twill.zookeeper.ForwardingZKClient
-
- getSessionId() - Method in interface org.apache.twill.zookeeper.ZKClient
-
Returns the current Zookeeper session ID of this client.
- getSize() - Method in interface org.apache.twill.api.LocalFile
-
Returns the size of the file or -1
if unknown.
- getSize() - Method in class org.apache.twill.internal.DefaultLocalFile
-
- getSocketAddress() - Method in class org.apache.twill.discovery.Discoverable
-
- getSourceClassName() - Method in interface org.apache.twill.api.logging.LogEntry
-
Returns the class name where the log emitted.
- getSourceMethodName() - Method in interface org.apache.twill.api.logging.LogEntry
-
Returns the method name where the log emitted.
- getSpecification() - Method in interface org.apache.twill.api.EventHandlerContext
-
- getSpecification() - Method in interface org.apache.twill.api.TwillContext
-
- getSpecification() - Method in class org.apache.twill.internal.BasicTwillContext
-
- getStackTraces() - Method in interface org.apache.twill.api.logging.LogEntry
-
- getStackTraces() - Method in interface org.apache.twill.api.logging.LogThrowable
-
Returns the stack trace of the Throwable.
- getStat() - Method in interface org.apache.twill.zookeeper.ACLData
-
- getStat() - Method in interface org.apache.twill.zookeeper.NodeChildren
-
- getStat() - Method in interface org.apache.twill.zookeeper.NodeData
-
- getStopMessageFuture() - Method in class org.apache.twill.internal.AbstractZKServiceController
-
- getStore() - Method in interface org.apache.twill.api.SecureStore
-
- getStore() - Method in class org.apache.twill.yarn.YarnSecureStore
-
- getTempFile(String) - Method in interface org.apache.twill.filesystem.Location
-
Returns unique location for temporary file to be placed near this location.
- getTerminationStatus() - Method in interface org.apache.twill.api.ServiceController
-
Gets the termination status of the application represented by this controller.
- getTerminationStatus() - Method in class org.apache.twill.internal.AbstractExecutionServiceController
-
- getThreadName() - Method in interface org.apache.twill.api.logging.LogEntry
-
Returns the name of the thread where the log emitted.
- getThrowable() - Method in interface org.apache.twill.api.logging.LogEntry
-
Returns the
Throwable
information emitted with the log.
- getTimeout() - Method in class org.apache.twill.api.EventHandler.TimeoutAction
-
Returns timeout in milliseconds or -1
if to abort the application.
- getTimestamp() - Method in interface org.apache.twill.api.logging.LogEntry
-
Returns timestamp of the log.
- getTopic() - Method in class org.apache.twill.kafka.client.TopicPartition
-
- getTopicPartition() - Method in interface org.apache.twill.kafka.client.FetchedMessage
-
- getTwillAppDir() - Method in class org.apache.twill.internal.TwillRuntimeSpecification
-
- getTwillAppName() - Method in class org.apache.twill.internal.TwillRuntimeSpecification
-
- getTwillAppRunId() - Method in class org.apache.twill.internal.TwillRuntimeSpecification
-
- getTwillRuntimeSpecification() - Method in class org.apache.twill.internal.ServiceMain
-
- getTwillSpecification() - Method in class org.apache.twill.internal.TwillRuntimeSpecification
-
- getType() - Method in interface org.apache.twill.api.TwillSpecification.Order
-
- getType() - Method in interface org.apache.twill.api.TwillSpecification.PlacementPolicy
-
- getType() - Method in class org.apache.twill.internal.DefaultTwillSpecification.DefaultOrder
-
- getType() - Method in class org.apache.twill.internal.DefaultTwillSpecification.DefaultPlacementPolicy
-
- getUplink() - Method in interface org.apache.twill.api.ResourceSpecification
-
Returns the uplink bandwidth in Mbps.
- getUplink() - Method in class org.apache.twill.internal.DefaultResourceSpecification
-
- getURI() - Method in interface org.apache.twill.api.LocalFile
-
- getURI() - Method in class org.apache.twill.internal.DefaultLocalFile
-
- getVirtualCores() - Method in interface org.apache.twill.api.ResourceSpecification
-
Returns the number of virtual CPU cores.
- getVirtualCores() - Method in interface org.apache.twill.api.TwillContext
-
Returns the number of virtual cores the runnable is allowed to use.
- getVirtualCores() - Method in interface org.apache.twill.api.TwillRunResources
-
- getVirtualCores() - Method in class org.apache.twill.internal.BasicTwillContext
-
- getVirtualCores() - Method in class org.apache.twill.internal.DefaultResourceSpecification
-
- getVirtualCores() - Method in class org.apache.twill.internal.DefaultTwillRunResources
-
- getVirtualCores() - Method in class org.apache.twill.internal.EnvContainerInfo
-
- getVirtualCores() - Method in interface org.apache.twill.internal.ResourceCapability
-
Returns the number of virtual cpu cores.
- getZkConnectStr() - Method in class org.apache.twill.internal.TwillRuntimeSpecification
-
- getZooKeeperSupplier() - Method in class org.apache.twill.zookeeper.ForwardingZKClientService
-
- getZooKeeperSupplier() - Method in interface org.apache.twill.zookeeper.ZKClientService
-
Returns a Supplier
of ZooKeeper
that gives the current ZooKeeper
in use at the moment
when Supplier.get()
get called.
- SAME_THREAD_EXECUTOR - Static variable in class org.apache.twill.common.Threads
-
A executor that execute task from the submitter thread.
- scheduleSecureStoreUpdate(SecureStoreUpdater, long, long, TimeUnit) - Method in interface org.apache.twill.api.TwillRunner
-
- scheduleSecureStoreUpdate(SecureStoreUpdater, long, long, TimeUnit) - Method in class org.apache.twill.yarn.YarnTwillRunnerService
-
- SECURE_STORE_UPDATE_LOCATION_ENABLED - Static variable in class org.apache.twill.api.Configs.Keys
-
Set this to false to disable the secure store updates done by default.
- SecureStore - Interface in org.apache.twill.api
-
Represents storage of secure tokens.
- SecureStoreRenewer - Class in org.apache.twill.api.security
-
This class is responsible for renewing the secure store used by application.
- SecureStoreRenewer() - Constructor for class org.apache.twill.api.security.SecureStoreRenewer
-
- SecureStoreUpdater - Interface in org.apache.twill.api
-
- SecureStoreWriter - Interface in org.apache.twill.api.security
-
- send() - Method in interface org.apache.twill.kafka.client.KafkaPublisher.Preparer
-
- sendCommand(Command) - Method in interface org.apache.twill.api.ServiceController
-
Sends a user command to the running application.
- sendCommand(String, Command) - Method in interface org.apache.twill.api.ServiceController
-
Sends a user command to the given runnable of the running application.
- sendCommand(Command) - Method in class org.apache.twill.internal.AbstractZKServiceController
-
- sendCommand(String, Command) - Method in class org.apache.twill.internal.AbstractZKServiceController
-
- sendMessage(Message, V) - Method in class org.apache.twill.internal.AbstractZKServiceController
-
Sends a Message
to the remote service.
- sendMessage(Message) - Method in interface org.apache.twill.internal.TwillContainerController
-
- sendMessage(ZKClient, String, Message, V) - Static method in class org.apache.twill.internal.ZKMessages
-
Creates a message node in zookeeper.
- sendMessage(ZKClient, String, Message, SettableFuture<V>, V) - Static method in class org.apache.twill.internal.ZKMessages
-
Creates a message node in zookeeper.
- ServiceAnnouncer - Interface in org.apache.twill.api
-
This interface provides a way to announce the availability of a service.
- ServiceController - Interface in org.apache.twill.api
-
This interface is for controlling a remote running service.
- ServiceController.TerminationStatus - Enum in org.apache.twill.api
-
Enum to represent termination status of the application when it completed.
- ServiceDiscovered - Interface in org.apache.twill.discovery
-
Represents the result of service discovery.
- ServiceDiscovered.ChangeListener - Interface in org.apache.twill.discovery
-
Represents a callback for watching changes in the discovery list.
- ServiceListenerAdapter - Class in org.apache.twill.internal
-
An adapter for implementing Service.Listener
with all method default to no-op.
- ServiceListenerAdapter() - Constructor for class org.apache.twill.internal.ServiceListenerAdapter
-
- ServiceMain - Class in org.apache.twill.internal
-
Class for main method that starts a service.
- ServiceMain() - Constructor for class org.apache.twill.internal.ServiceMain
-
- ServiceMain.TwillZKPathService - Class in org.apache.twill.internal
-
- Services - Class in org.apache.twill.internal
-
Utility methods for help dealing with Service
.
- setACL(String, Iterable<ACL>) - Method in class org.apache.twill.zookeeper.AbstractZKClient
-
- setACL(String, Iterable<ACL>, int) - Method in class org.apache.twill.zookeeper.ForwardingZKClient
-
- setACL(String, Iterable<ACL>) - Method in interface org.apache.twill.zookeeper.ZKClient
-
Sets the ACL of the given path if the path exists.
- setACL(String, Iterable<ACL>, int) - Method in interface org.apache.twill.zookeeper.ZKClient
-
Sets the ACL of the given path if the path exists and version matched.
- setClassesDir(String) - Method in class org.apache.twill.internal.ApplicationBundler
-
Sets the name of the directory inside the bundle jar that all ".class" files stored in.
- setClassLoader(String) - Method in interface org.apache.twill.api.TwillPreparer
-
Sets the class name of the
ClassLoader
to be used for loading twill and application classes for
all containers.
- setConnectionWatcher(Watcher) - Method in class org.apache.twill.zookeeper.ZKClientService.Builder
-
Sets a Watcher
that will be called whenever connection state change.
- setCores(int) - Method in class org.apache.twill.api.ResourceSpecification.Builder.CoreSetter
-
Deprecated.
- setData(String, byte[]) - Method in class org.apache.twill.zookeeper.AbstractZKClient
-
- setData(String, byte[], int) - Method in class org.apache.twill.zookeeper.ForwardingZKClient
-
- setData(String, byte[]) - Method in interface org.apache.twill.zookeeper.ZKClient
-
Sets the data for the given path without matching version.
- setData(String, byte[], int) - Method in interface org.apache.twill.zookeeper.ZKClient
-
Sets the data for the given path that match the given version.
- setDownlink(int, ResourceSpecification.SizeUnit) - Method in class org.apache.twill.api.ResourceSpecification.Builder.AfterUplink
-
- setGroup(String) - Method in interface org.apache.twill.filesystem.Location
-
Sets the group of the location.
- setInstanceCount(int) - Method in class org.apache.twill.internal.BasicTwillContext
-
- setInstances(int) - Method in class org.apache.twill.api.ResourceSpecification.Builder.AfterMemory
-
- setJarFileName(String) - Method in class org.apache.twill.ext.BundledJarRunner.Arguments.Builder
-
- setJVMOptions(String) - Method in interface org.apache.twill.api.TwillPreparer
-
This methods sets the extra JVM options that will be passed to the java command line for every runnable
of the application started through this
TwillPreparer
instance.
- setJVMOptions(String, String) - Method in interface org.apache.twill.api.TwillPreparer
-
This methods sets the extra JVM options that will be passed to the java command line for the given runnable
of the application started through this
TwillPreparer
instance.
- setJVMOptions(String) - Method in class org.apache.twill.yarn.YarnTwillRunnerService
-
This methods sets the extra JVM options that will be passed to the java command line for every application
started through this
YarnTwillRunnerService
instance.
- setLibDir(String) - Method in class org.apache.twill.internal.ApplicationBundler
-
Sets the name of the directory inside the bundle jar that all ".jar" files stored in.
- setLibFolder(String) - Method in class org.apache.twill.ext.BundledJarRunner.Arguments.Builder
-
- setLogLevel(LogEntry.Level) - Method in interface org.apache.twill.api.TwillPreparer
-
- setLogLevel(String, String) - Method in class org.apache.twill.internal.ContainerLiveNodeData
-
- setLogLevels(Map<String, LogEntry.Level>) - Method in interface org.apache.twill.api.TwillPreparer
-
Set the log levels for requested logger names for Twill applications running in a container.
- setLogLevels(String, Map<String, LogEntry.Level>) - Method in interface org.apache.twill.api.TwillPreparer
-
Set the log levels for requested logger names for a
TwillRunnable
.
- setMainArgs(String[]) - Method in class org.apache.twill.ext.BundledJarRunnable
-
- setMainArgs(String) - Method in class org.apache.twill.ext.BundledJarRunnable
-
- setMainArgs(String[]) - Method in class org.apache.twill.ext.BundledJarRunner.Arguments.Builder
-
- setMainClassName(String) - Method in class org.apache.twill.ext.BundledJarRunner.Arguments.Builder
-
- setMemory(int, ResourceSpecification.SizeUnit) - Method in class org.apache.twill.api.ResourceSpecification.Builder.MemorySetter
-
- setName(String) - Method in class org.apache.twill.api.TwillRunnableSpecification.Builder.NameSetter
-
- setName(String) - Method in class org.apache.twill.api.TwillSpecification.Builder.NameSetter
-
- setPermissions(String) - Method in interface org.apache.twill.filesystem.Location
-
Sets the permissions on this location.
- setResourcesDir(String) - Method in class org.apache.twill.internal.ApplicationBundler
-
Sets the name of the directory inside the bundle jar that all resource files stored in.
- setSchedulerQueue(String) - Method in interface org.apache.twill.api.TwillPreparer
-
Sets the name of the scheduler queue to use.
- setSecureStoreRenewer(SecureStoreRenewer, long, long, long, TimeUnit) - Method in interface org.apache.twill.api.TwillRunner
-
- setSecureStoreRenewer(SecureStoreRenewer, long, long, long, TimeUnit) - Method in class org.apache.twill.yarn.YarnTwillRunnerService
-
- setServices(List<String>) - Method in class org.apache.twill.internal.DefaultResourceReport
-
Set the list of services of the application master.
- setSessionTimeout(int) - Method in class org.apache.twill.zookeeper.ZKClientService.Builder
-
Sets the client timeout to the give milliseconds.
- setTempDir(File) - Method in class org.apache.twill.internal.ApplicationBundler
-
Sets the temporary directory used by this class when generating new jars.
- setTerminationStatus(ServiceController.TerminationStatus) - Method in class org.apache.twill.internal.AbstractExecutionServiceController
-
- setUplink(int, ResourceSpecification.SizeUnit) - Method in class org.apache.twill.api.ResourceSpecification.Builder.AfterInstances
-
- setUser(String) - Method in interface org.apache.twill.api.TwillPreparer
-
- setVirtualCores(int) - Method in class org.apache.twill.api.ResourceSpecification.Builder.CoreSetter
-
- shutDown() - Method in class org.apache.twill.internal.AbstractExecutionServiceController
-
- shutDown() - Method in class org.apache.twill.internal.AbstractTwillService
-
- shutDown() - Method in class org.apache.twill.internal.AbstractZKServiceController
-
- shutDown() - Method in class org.apache.twill.internal.CompositeService
-
- shutdown() - Method in class org.apache.twill.internal.ElectionRegistry
-
Stops all active LeaderElection
processes.
- shutDown() - Method in class org.apache.twill.internal.ServiceMain.TwillZKPathService
-
- SingleRunnableApplication - Class in org.apache.twill.internal
-
- SingleRunnableApplication(TwillRunnable, ResourceSpecification) - Constructor for class org.apache.twill.internal.SingleRunnableApplication
-
- start() - Method in interface org.apache.twill.api.TwillPreparer
-
Starts the application.
- start(long, TimeUnit) - Method in interface org.apache.twill.api.TwillPreparer
-
Starts the application.
- start() - Method in interface org.apache.twill.api.TwillRunnerService
-
Starts the service.
- start() - Method in class org.apache.twill.internal.AbstractExecutionServiceController
-
- start(RunId, int, Class<?>, String, Location) - Method in class org.apache.twill.internal.TwillContainerLauncher
-
Start execution run for a class in a container.
- start() - Method in class org.apache.twill.yarn.YarnTwillRunnerService
-
- start() - Method in class org.apache.twill.zookeeper.ForwardingZKClientService
-
- startAndWait() - Method in class org.apache.twill.internal.AbstractExecutionServiceController
-
- startAndWait() - Method in class org.apache.twill.zookeeper.ForwardingZKClientService
-
- started() - Method in class org.apache.twill.api.EventHandler
-
Invoked by the application when it starts.
- starting() - Method in class org.apache.twill.internal.ServiceListenerAdapter
-
- startUp() - Method in class org.apache.twill.internal.AbstractExecutionServiceController
-
- startUp() - Method in class org.apache.twill.internal.AbstractTwillService
-
- startUp() - Method in class org.apache.twill.internal.AbstractZKServiceController
-
- startUp() - Method in class org.apache.twill.internal.CompositeService
-
- startUp() - Method in class org.apache.twill.internal.ServiceMain.TwillZKPathService
-
- state() - Method in class org.apache.twill.internal.AbstractExecutionServiceController
-
- state() - Method in class org.apache.twill.zookeeper.ForwardingZKClientService
-
- stop() - Method in class org.apache.twill.api.AbstractTwillRunnable
-
- stop() - Method in interface org.apache.twill.api.TwillRunnable
-
Requests to stop the running service.
- stop() - Method in interface org.apache.twill.api.TwillRunnerService
-
Stops the service.
- stop() - Method in class org.apache.twill.ext.BundledJarRunnable
-
- stop() - Method in class org.apache.twill.internal.AbstractExecutionServiceController
-
- stop() - Method in class org.apache.twill.internal.BasicTwillContext
-
Stops and frees any currently allocated resources.
- stop() - Method in class org.apache.twill.yarn.YarnTwillRunnerService
-
- stop() - Method in class org.apache.twill.zookeeper.ForwardingZKClientService
-
- stopAndWait() - Method in class org.apache.twill.internal.AbstractExecutionServiceController
-
- stopAndWait() - Method in class org.apache.twill.zookeeper.ForwardingZKClientService
-
- stopping(Service.State) - Method in class org.apache.twill.internal.ServiceListenerAdapter
-
- SUCCESS - Static variable in class org.apache.twill.internal.ContainerExitCodes
-
- valueOf(String) - Static method in enum org.apache.twill.api.logging.LogEntry.Level
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.apache.twill.api.ResourceSpecification.SizeUnit
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.apache.twill.api.ServiceController.TerminationStatus
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.apache.twill.api.TwillSpecification.Order.Type
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.apache.twill.api.TwillSpecification.PlacementPolicy.Type
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.apache.twill.kafka.client.Compression
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.apache.twill.kafka.client.KafkaPublisher.Ack
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.apache.twill.zookeeper.RetryStrategy.OperationType
-
Returns the enum constant of this type with the specified name.
- values() - Static method in enum org.apache.twill.api.logging.LogEntry.Level
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum org.apache.twill.api.ResourceSpecification.SizeUnit
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum org.apache.twill.api.ServiceController.TerminationStatus
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum org.apache.twill.api.TwillSpecification.Order.Type
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum org.apache.twill.api.TwillSpecification.PlacementPolicy.Type
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum org.apache.twill.kafka.client.Compression
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum org.apache.twill.kafka.client.KafkaPublisher.Ack
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum org.apache.twill.zookeeper.RetryStrategy.OperationType
-
Returns an array containing the constants of this enum type, in
the order they are declared.