Path Lines of Code twill-api/src/main/java/org/apache/twill/api/AbstractTwillRunnable.java 44 twill-api/src/main/java/org/apache/twill/api/ClassAcceptor.java 7 twill-api/src/main/java/org/apache/twill/api/Command.java 72 twill-api/src/main/java/org/apache/twill/api/ElectionHandler.java 5 twill-api/src/main/java/org/apache/twill/api/EventHandler.java 67 twill-api/src/main/java/org/apache/twill/api/EventHandlerContext.java 4 twill-api/src/main/java/org/apache/twill/api/EventHandlerSpecification.java 6 twill-api/src/main/java/org/apache/twill/api/Hosts.java 27 twill-api/src/main/java/org/apache/twill/api/LocalFile.java 12 twill-api/src/main/java/org/apache/twill/api/Racks.java 27 twill-api/src/main/java/org/apache/twill/api/ResourceReport.java 11 twill-api/src/main/java/org/apache/twill/api/ResourceSpecification.java 73 twill-api/src/main/java/org/apache/twill/api/RunId.java 4 twill-api/src/main/java/org/apache/twill/api/RuntimeSpecification.java 8 twill-api/src/main/java/org/apache/twill/api/SecureStore.java 4 twill-api/src/main/java/org/apache/twill/api/SecureStoreUpdater.java 4 twill-api/src/main/java/org/apache/twill/api/ServiceAnnouncer.java 5 twill-api/src/main/java/org/apache/twill/api/ServiceController.java 17 twill-api/src/main/java/org/apache/twill/api/TwillApplication.java 4 twill-api/src/main/java/org/apache/twill/api/TwillContext.java 22 twill-api/src/main/java/org/apache/twill/api/TwillController.java 18 twill-api/src/main/java/org/apache/twill/api/TwillPreparer.java 33 twill-api/src/main/java/org/apache/twill/api/TwillRunResources.java 11 twill-api/src/main/java/org/apache/twill/api/TwillRunnable.java 8 twill-api/src/main/java/org/apache/twill/api/TwillRunnableSpecification.java 39 twill-api/src/main/java/org/apache/twill/api/TwillRunner.java 17 twill-api/src/main/java/org/apache/twill/api/TwillRunnerService.java 5 twill-api/src/main/java/org/apache/twill/api/TwillSpecification.java 293 twill-api/src/main/java/org/apache/twill/api/logging/LogEntry.java 25 twill-api/src/main/java/org/apache/twill/api/logging/LogHandler.java 4 twill-api/src/main/java/org/apache/twill/api/logging/LogThrowable.java 7 twill-api/src/main/java/org/apache/twill/api/logging/PrinterLogHandler.java 75 twill-api/src/main/java/org/apache/twill/api/logging/package-info.java 1 twill-api/src/main/java/org/apache/twill/api/package-info.java 1 twill-api/src/main/java/org/apache/twill/internal/DefaultEventHandlerSpecification.java 27 twill-api/src/main/java/org/apache/twill/internal/DefaultLocalFile.java 45 twill-api/src/main/java/org/apache/twill/internal/DefaultResourceSpecification.java 41 twill-api/src/main/java/org/apache/twill/internal/DefaultRuntimeSpecification.java 39 twill-api/src/main/java/org/apache/twill/internal/DefaultTwillRunResources.java 72 twill-api/src/main/java/org/apache/twill/internal/DefaultTwillRunnableSpecification.java 32 twill-api/src/main/java/org/apache/twill/internal/DefaultTwillSpecification.java 117 twill-api/src/main/java/org/apache/twill/internal/RunIds.java 44 twill-api/src/main/java/org/apache/twill/internal/package-info.java 1 twill-common/src/main/java/org/apache/twill/common/Cancellable.java 4 twill-common/src/main/java/org/apache/twill/common/Threads.java 26 twill-common/src/main/java/org/apache/twill/filesystem/ForwardingLocationFactory.java 10 twill-common/src/main/java/org/apache/twill/filesystem/LocalLocation.java 154 twill-common/src/main/java/org/apache/twill/filesystem/LocalLocationFactory.java 27 twill-common/src/main/java/org/apache/twill/filesystem/Location.java 29 twill-common/src/main/java/org/apache/twill/filesystem/LocationFactories.java 36 twill-common/src/main/java/org/apache/twill/filesystem/LocationFactory.java 7 twill-common/src/main/java/org/apache/twill/internal/Constants.java 33 twill-core/src/main/java/org/apache/twill/internal/AbstractExecutionServiceController.java 213 twill-core/src/main/java/org/apache/twill/internal/AbstractTwillController.java 187 twill-core/src/main/java/org/apache/twill/internal/AbstractTwillService.java 222 twill-core/src/main/java/org/apache/twill/internal/AbstractZKServiceController.java 173 twill-core/src/main/java/org/apache/twill/internal/ApplicationBundler.java 265 twill-core/src/main/java/org/apache/twill/internal/Arguments.java 19 twill-core/src/main/java/org/apache/twill/internal/BasicTwillContext.java 123 twill-core/src/main/java/org/apache/twill/internal/CompositeService.java 70 twill-core/src/main/java/org/apache/twill/internal/Configs.java 15 twill-core/src/main/java/org/apache/twill/internal/ContainerInfo.java 7 twill-core/src/main/java/org/apache/twill/internal/ContainerLiveNodeData.java 20 twill-core/src/main/java/org/apache/twill/internal/DefaultResourceReport.java 71 twill-core/src/main/java/org/apache/twill/internal/ElectionRegistry.java 41 twill-core/src/main/java/org/apache/twill/internal/EnvContainerInfo.java 37 twill-core/src/main/java/org/apache/twill/internal/EnvKeys.java 26 twill-core/src/main/java/org/apache/twill/internal/JvmOptions.java 69 twill-core/src/main/java/org/apache/twill/internal/ListenerExecutor.java 100 twill-core/src/main/java/org/apache/twill/internal/LogOnlyEventHandler.java 17 twill-core/src/main/java/org/apache/twill/internal/ProcessController.java 6 twill-core/src/main/java/org/apache/twill/internal/ProcessLauncher.java 15 twill-core/src/main/java/org/apache/twill/internal/ResourceCapability.java 5 twill-core/src/main/java/org/apache/twill/internal/ServiceListenerAdapter.java 19 twill-core/src/main/java/org/apache/twill/internal/Services.java 71 twill-core/src/main/java/org/apache/twill/internal/SingleRunnableApplication.java 24 twill-core/src/main/java/org/apache/twill/internal/TwillContainerController.java 10 twill-core/src/main/java/org/apache/twill/internal/TwillContainerLauncher.java 157 twill-core/src/main/java/org/apache/twill/internal/ZKMessages.java 43 twill-core/src/main/java/org/apache/twill/internal/json/ArgumentsCodec.java 58 twill-core/src/main/java/org/apache/twill/internal/json/DefaultLogThrowable.java 36 twill-core/src/main/java/org/apache/twill/internal/json/ILoggingEventSerializer.java 46 twill-core/src/main/java/org/apache/twill/internal/json/JsonUtils.java 31 twill-core/src/main/java/org/apache/twill/internal/json/JvmOptionsCodec.java 78 twill-core/src/main/java/org/apache/twill/internal/json/LocalFileCodec.java 38 twill-core/src/main/java/org/apache/twill/internal/json/LogEntryDecoder.java 91 twill-core/src/main/java/org/apache/twill/internal/json/LogThrowableCodec.java 29 twill-core/src/main/java/org/apache/twill/internal/json/ResourceReportAdapter.java 32 twill-core/src/main/java/org/apache/twill/internal/json/ResourceReportCodec.java 44 twill-core/src/main/java/org/apache/twill/internal/json/ResourceSpecificationCodec.java 37 twill-core/src/main/java/org/apache/twill/internal/json/RuntimeSpecificationCodec.java 41 twill-core/src/main/java/org/apache/twill/internal/json/StackTraceElementCodec.java 30 twill-core/src/main/java/org/apache/twill/internal/json/TwillRunResourcesCodec.java 51 twill-core/src/main/java/org/apache/twill/internal/json/TwillRunnableSpecificationCodec.java 34 twill-core/src/main/java/org/apache/twill/internal/json/TwillSpecificationAdapter.java 123 twill-core/src/main/java/org/apache/twill/internal/json/TwillSpecificationCodec.java 120 twill-core/src/main/java/org/apache/twill/internal/kafka/EmbeddedKafkaServer.java 73 twill-core/src/main/java/org/apache/twill/internal/kafka/client/BasicFetchedMessage.java 30 twill-core/src/main/java/org/apache/twill/internal/kafka/client/ByteBufferEncoder.java 13 twill-core/src/main/java/org/apache/twill/internal/kafka/client/IntegerEncoder.java 11 twill-core/src/main/java/org/apache/twill/internal/kafka/client/IntegerPartitioner.java 10 twill-core/src/main/java/org/apache/twill/internal/kafka/client/SimpleKafkaConsumer.java 375 twill-core/src/main/java/org/apache/twill/internal/kafka/client/SimpleKafkaPublisher.java 156 twill-core/src/main/java/org/apache/twill/internal/kafka/client/ZKBrokerService.java 339 twill-core/src/main/java/org/apache/twill/internal/kafka/client/ZKKafkaClientService.java 74 twill-core/src/main/java/org/apache/twill/internal/kafka/client/package-info.java 1 twill-core/src/main/java/org/apache/twill/internal/logging/KafkaAppender.java 216 twill-core/src/main/java/org/apache/twill/internal/logging/Loggings.java 21 twill-core/src/main/java/org/apache/twill/internal/package-info.java 1 twill-core/src/main/java/org/apache/twill/internal/state/Message.java 18 twill-core/src/main/java/org/apache/twill/internal/state/MessageCallback.java 5 twill-core/src/main/java/org/apache/twill/internal/state/MessageCodec.java 73 twill-core/src/main/java/org/apache/twill/internal/state/Messages.java 12 twill-core/src/main/java/org/apache/twill/internal/state/SimpleMessage.java 58 twill-core/src/main/java/org/apache/twill/internal/state/SystemMessages.java 30 twill-core/src/main/java/org/apache/twill/internal/utils/Dependencies.java 273 twill-core/src/main/java/org/apache/twill/internal/utils/Instances.java 67 twill-core/src/main/java/org/apache/twill/internal/utils/Networks.java 14 twill-core/src/main/java/org/apache/twill/internal/utils/Paths.java 19 twill-core/src/main/java/org/apache/twill/internal/utils/Resources.java 12 twill-core/src/main/java/org/apache/twill/kafka/client/BrokerInfo.java 36 twill-core/src/main/java/org/apache/twill/kafka/client/BrokerService.java 14 twill-core/src/main/java/org/apache/twill/kafka/client/Compression.java 13 twill-core/src/main/java/org/apache/twill/kafka/client/FetchedMessage.java 7 twill-core/src/main/java/org/apache/twill/kafka/client/KafkaClient.java 5 twill-core/src/main/java/org/apache/twill/kafka/client/KafkaClientService.java 4 twill-core/src/main/java/org/apache/twill/kafka/client/KafkaConsumer.java 16 twill-core/src/main/java/org/apache/twill/kafka/client/KafkaPublisher.java 22 twill-core/src/main/java/org/apache/twill/kafka/client/TopicPartition.java 40 twill-core/src/main/java/org/apache/twill/kafka/client/package-info.java 1 twill-core/src/main/java/org/apache/twill/launcher/FindFreePort.java 9 twill-core/src/main/java/org/apache/twill/launcher/TwillLauncher.java 182 twill-discovery-api/src/main/java/org/apache/twill/discovery/Discoverable.java 6 twill-discovery-api/src/main/java/org/apache/twill/discovery/DiscoveryService.java 5 twill-discovery-api/src/main/java/org/apache/twill/discovery/DiscoveryServiceClient.java 4 twill-discovery-api/src/main/java/org/apache/twill/discovery/ServiceDiscovered.java 11 twill-discovery-core/src/main/java/org/apache/twill/discovery/DefaultServiceDiscovered.java 104 twill-discovery-core/src/main/java/org/apache/twill/discovery/DiscoverableAdapter.java 57 twill-discovery-core/src/main/java/org/apache/twill/discovery/DiscoverableWrapper.java 39 twill-discovery-core/src/main/java/org/apache/twill/discovery/InMemoryDiscoveryService.java 58 twill-discovery-core/src/main/java/org/apache/twill/discovery/ZKDiscoveryService.java 255 twill-discovery-core/src/main/java/org/apache/twill/discovery/package-info.java 1 twill-examples/echo/src/main/java/echo/EchoMain.java 25 twill-examples/yarn/src/main/java/org/apache/twill/example/yarn/BundledJarExample.java 77 twill-examples/yarn/src/main/java/org/apache/twill/example/yarn/HelloWorld.java 72 twill-ext/src/main/java/org/apache/twill/ext/BundledJarRunnable.java 77 twill-ext/src/main/java/org/apache/twill/ext/BundledJarRunner.java 209 twill-yarn/src/main/hadoop20/org/apache/twill/internal/yarn/Hadoop20YarnAMClient.java 126 twill-yarn/src/main/hadoop20/org/apache/twill/internal/yarn/Hadoop20YarnAppClient.java 164 twill-yarn/src/main/hadoop20/org/apache/twill/internal/yarn/Hadoop20YarnApplicationReport.java 69 twill-yarn/src/main/hadoop20/org/apache/twill/internal/yarn/Hadoop20YarnContainerInfo.java 39 twill-yarn/src/main/hadoop20/org/apache/twill/internal/yarn/Hadoop20YarnContainerStatus.java 25 twill-yarn/src/main/hadoop20/org/apache/twill/internal/yarn/Hadoop20YarnLaunchContext.java 62 twill-yarn/src/main/hadoop20/org/apache/twill/internal/yarn/Hadoop20YarnLocalResource.java 64 twill-yarn/src/main/hadoop20/org/apache/twill/internal/yarn/Hadoop20YarnNMClient.java 80 twill-yarn/src/main/hadoop20/org/apache/twill/internal/yarn/ports/AMRMClient.java 49 twill-yarn/src/main/hadoop20/org/apache/twill/internal/yarn/ports/AMRMClientImpl.java 306 twill-yarn/src/main/hadoop20/org/apache/twill/internal/yarn/ports/AllocationResponse.java 11 twill-yarn/src/main/hadoop20/org/apache/twill/internal/yarn/ports/AllocationResponses.java 68 twill-yarn/src/main/hadoop21/org/apache/twill/internal/yarn/Hadoop21YarnAMClient.java 119 twill-yarn/src/main/hadoop21/org/apache/twill/internal/yarn/Hadoop21YarnAppClient.java 145 twill-yarn/src/main/hadoop21/org/apache/twill/internal/yarn/Hadoop21YarnApplicationReport.java 69 twill-yarn/src/main/hadoop21/org/apache/twill/internal/yarn/Hadoop21YarnContainerInfo.java 39 twill-yarn/src/main/hadoop21/org/apache/twill/internal/yarn/Hadoop21YarnContainerStatus.java 25 twill-yarn/src/main/hadoop21/org/apache/twill/internal/yarn/Hadoop21YarnLaunchContext.java 62 twill-yarn/src/main/hadoop21/org/apache/twill/internal/yarn/Hadoop21YarnLocalResource.java 64 twill-yarn/src/main/hadoop21/org/apache/twill/internal/yarn/Hadoop21YarnNMClient.java 64 twill-yarn/src/main/hadoop22/org/apache/twill/internal/yarn/Hadoop22YarnAMClient.java 16 twill-yarn/src/main/java/org/apache/twill/filesystem/FileContextLocation.java 170 twill-yarn/src/main/java/org/apache/twill/filesystem/FileContextLocationFactory.java 72 twill-yarn/src/main/java/org/apache/twill/filesystem/HDFSLocation.java 146 twill-yarn/src/main/java/org/apache/twill/filesystem/HDFSLocationFactory.java 64 twill-yarn/src/main/java/org/apache/twill/filesystem/package-info.java 1 twill-yarn/src/main/java/org/apache/twill/internal/ContainerExitCodes.java 9 twill-yarn/src/main/java/org/apache/twill/internal/ServiceMain.java 224 twill-yarn/src/main/java/org/apache/twill/internal/appmaster/AllocationSpecification.java 55 twill-yarn/src/main/java/org/apache/twill/internal/appmaster/ApplicationMasterInfo.java 32 twill-yarn/src/main/java/org/apache/twill/internal/appmaster/ApplicationMasterLiveNodeData.java 20 twill-yarn/src/main/java/org/apache/twill/internal/appmaster/ApplicationMasterMain.java 212 twill-yarn/src/main/java/org/apache/twill/internal/appmaster/ApplicationMasterProcessLauncher.java 31 twill-yarn/src/main/java/org/apache/twill/internal/appmaster/ApplicationMasterService.java 709 twill-yarn/src/main/java/org/apache/twill/internal/appmaster/ApplicationSubmitter.java 7 twill-yarn/src/main/java/org/apache/twill/internal/appmaster/BasicEventHandlerContext.java 13 twill-yarn/src/main/java/org/apache/twill/internal/appmaster/ExpectedContainers.java 43 twill-yarn/src/main/java/org/apache/twill/internal/appmaster/LoggerContextListenerAdapter.java 27 twill-yarn/src/main/java/org/apache/twill/internal/appmaster/PlacementPolicyManager.java 50 twill-yarn/src/main/java/org/apache/twill/internal/appmaster/ProvisionRequest.java 31 twill-yarn/src/main/java/org/apache/twill/internal/appmaster/RunnableContainerRequest.java 39 twill-yarn/src/main/java/org/apache/twill/internal/appmaster/RunnableProcessLauncher.java 58 twill-yarn/src/main/java/org/apache/twill/internal/appmaster/RunningContainers.java 413 twill-yarn/src/main/java/org/apache/twill/internal/appmaster/TrackerService.java 156 twill-yarn/src/main/java/org/apache/twill/internal/appmaster/package-info.java 1 twill-yarn/src/main/java/org/apache/twill/internal/container/TwillContainerMain.java 136 twill-yarn/src/main/java/org/apache/twill/internal/container/TwillContainerService.java 112 twill-yarn/src/main/java/org/apache/twill/internal/yarn/AbstractYarnAMClient.java 173 twill-yarn/src/main/java/org/apache/twill/internal/yarn/AbstractYarnProcessLauncher.java 102 twill-yarn/src/main/java/org/apache/twill/internal/yarn/AbstractYarnTwillService.java 56 twill-yarn/src/main/java/org/apache/twill/internal/yarn/VersionDetectYarnAMClientFactory.java 34 twill-yarn/src/main/java/org/apache/twill/internal/yarn/VersionDetectYarnAppClientFactory.java 22 twill-yarn/src/main/java/org/apache/twill/internal/yarn/YarnAMClient.java 64 twill-yarn/src/main/java/org/apache/twill/internal/yarn/YarnAMClientFactory.java 4 twill-yarn/src/main/java/org/apache/twill/internal/yarn/YarnAppClient.java 20 twill-yarn/src/main/java/org/apache/twill/internal/yarn/YarnAppClientFactory.java 5 twill-yarn/src/main/java/org/apache/twill/internal/yarn/YarnApplicationReport.java 22 twill-yarn/src/main/java/org/apache/twill/internal/yarn/YarnContainerInfo.java 5 twill-yarn/src/main/java/org/apache/twill/internal/yarn/YarnContainerStatus.java 8 twill-yarn/src/main/java/org/apache/twill/internal/yarn/YarnLaunchContext.java 17 twill-yarn/src/main/java/org/apache/twill/internal/yarn/YarnLocalResource.java 19 twill-yarn/src/main/java/org/apache/twill/internal/yarn/YarnNMClient.java 5 twill-yarn/src/main/java/org/apache/twill/internal/yarn/YarnUtils.java 199 twill-yarn/src/main/java/org/apache/twill/internal/yarn/package-info.java 1 twill-yarn/src/main/java/org/apache/twill/yarn/LocationSecureStoreUpdater.java 28 twill-yarn/src/main/java/org/apache/twill/yarn/ResourceReportClient.java 33 twill-yarn/src/main/java/org/apache/twill/yarn/YarnSecureStore.java 16 twill-yarn/src/main/java/org/apache/twill/yarn/YarnTwillController.java 228 twill-yarn/src/main/java/org/apache/twill/yarn/YarnTwillControllerFactory.java 10 twill-yarn/src/main/java/org/apache/twill/yarn/YarnTwillPreparer.java 556 twill-yarn/src/main/java/org/apache/twill/yarn/YarnTwillRunnerService.java 477 twill-yarn/src/main/java/org/apache/twill/yarn/package-info.java 1 twill-yarn/src/main/resources/logback-template.xml 6 twill-zookeeper/src/main/java/org/apache/twill/internal/zookeeper/BasicACLData.java 21 twill-zookeeper/src/main/java/org/apache/twill/internal/zookeeper/BasicNodeChildren.java 36 twill-zookeeper/src/main/java/org/apache/twill/internal/zookeeper/BasicNodeData.java 36 twill-zookeeper/src/main/java/org/apache/twill/internal/zookeeper/DefaultZKClientService.java 497 twill-zookeeper/src/main/java/org/apache/twill/internal/zookeeper/FailureRetryZKClient.java 186 twill-zookeeper/src/main/java/org/apache/twill/internal/zookeeper/InMemoryZKServer.java 149 twill-zookeeper/src/main/java/org/apache/twill/internal/zookeeper/KillZKSession.java 28 twill-zookeeper/src/main/java/org/apache/twill/internal/zookeeper/LeaderElection.java 312 twill-zookeeper/src/main/java/org/apache/twill/internal/zookeeper/NamespaceZKClient.java 110 twill-zookeeper/src/main/java/org/apache/twill/internal/zookeeper/ReentrantDistributedLock.java 280 twill-zookeeper/src/main/java/org/apache/twill/internal/zookeeper/RetryUtils.java 15 twill-zookeeper/src/main/java/org/apache/twill/internal/zookeeper/RewatchOnExpireWatcher.java 153 twill-zookeeper/src/main/java/org/apache/twill/internal/zookeeper/RewatchOnExpireZKClient.java 70 twill-zookeeper/src/main/java/org/apache/twill/internal/zookeeper/SettableOperationFuture.java 37 twill-zookeeper/src/main/java/org/apache/twill/internal/zookeeper/package-info.java 1 twill-zookeeper/src/main/java/org/apache/twill/zookeeper/ACLData.java 8 twill-zookeeper/src/main/java/org/apache/twill/zookeeper/AbstractZKClient.java 46 twill-zookeeper/src/main/java/org/apache/twill/zookeeper/ForwardingZKClient.java 61 twill-zookeeper/src/main/java/org/apache/twill/zookeeper/ForwardingZKClientService.java 45 twill-zookeeper/src/main/java/org/apache/twill/zookeeper/NodeChildren.java 7 twill-zookeeper/src/main/java/org/apache/twill/zookeeper/NodeData.java 8 twill-zookeeper/src/main/java/org/apache/twill/zookeeper/OperationFuture.java 5 twill-zookeeper/src/main/java/org/apache/twill/zookeeper/RetryStrategies.java 57 twill-zookeeper/src/main/java/org/apache/twill/zookeeper/RetryStrategy.java 14 twill-zookeeper/src/main/java/org/apache/twill/zookeeper/ZKClient.java 30 twill-zookeeper/src/main/java/org/apache/twill/zookeeper/ZKClientService.java 39 twill-zookeeper/src/main/java/org/apache/twill/zookeeper/ZKClientServices.java 67 twill-zookeeper/src/main/java/org/apache/twill/zookeeper/ZKClients.java 17 twill-zookeeper/src/main/java/org/apache/twill/zookeeper/ZKOperations.java 235 twill-zookeeper/src/main/java/org/apache/twill/zookeeper/package-info.java 1