Path	Lines of Code
samza-api/src/main/java/org/apache/samza/runtime/ProcessorContext.java	5
samza-api/src/main/java/org/apache/samza/startpoint/Startpoint.java	40
samza-azure/src/main/java/org/apache/samza/coordinator/AzureJobCoordinator.java	352
samza-core/src/main/java/org/apache/samza/application/descriptors/StreamApplicationDescriptorImpl.java	145
samza-core/src/main/java/org/apache/samza/application/descriptors/TaskApplicationDescriptorImpl.java	45
samza-core/src/main/java/org/apache/samza/clustermanager/ClusterBasedJobCoordinator.java	308
samza-core/src/main/java/org/apache/samza/clustermanager/ClusterBasedJobCoordinatorRunner.java	93
samza-core/src/main/java/org/apache/samza/clustermanager/ClusterResourceManager.java	27
samza-core/src/main/java/org/apache/samza/clustermanager/ContainerAllocator.java	223
samza-core/src/main/java/org/apache/samza/clustermanager/ContainerManager.java	368
samza-core/src/main/java/org/apache/samza/clustermanager/ResourceManagerFactory.java	4
samza-core/src/main/java/org/apache/samza/clustermanager/SamzaApplicationState.java	42
samza-core/src/main/java/org/apache/samza/clustermanager/SamzaResource.java	62
samza-core/src/main/java/org/apache/samza/clustermanager/SamzaResourceRequest.java	97
samza-core/src/main/java/org/apache/samza/config/ApplicationConfig.java	62
samza-core/src/main/java/org/apache/samza/config/JobConfig.java	345
samza-core/src/main/java/org/apache/samza/config/StorageConfig.java	238
samza-core/src/main/java/org/apache/samza/config/TaskConfig.java	276
samza-core/src/main/java/org/apache/samza/container/RunLoopTask.java	23
samza-core/src/main/java/org/apache/samza/container/grouper/task/GroupByContainerCount.java	149
samza-core/src/main/java/org/apache/samza/context/InternalTaskContext.java	32
samza-core/src/main/java/org/apache/samza/coordinator/JobCoordinatorListener.java	8
samza-core/src/main/java/org/apache/samza/coordinator/JobModelCalculator.java	160
samza-core/src/main/java/org/apache/samza/coordinator/MetadataResourceUtil.java	33
samza-core/src/main/java/org/apache/samza/coordinator/StreamPartitionCountMonitor.java	146
samza-core/src/main/java/org/apache/samza/coordinator/staticresource/StaticResourceJobCoordinator.java	199
samza-core/src/main/java/org/apache/samza/coordinator/stream/CoordinatorStreamWriter.java	51
samza-core/src/main/java/org/apache/samza/execution/ExecutionPlanner.java	183
samza-core/src/main/java/org/apache/samza/execution/JobNode.java	125
samza-core/src/main/java/org/apache/samza/execution/JobNodeConfigurationGenerator.java	250
samza-core/src/main/java/org/apache/samza/execution/JobPlanner.java	145
samza-core/src/main/java/org/apache/samza/execution/LocalJobPlanner.java	146
samza-core/src/main/java/org/apache/samza/execution/RemoteJobPlanner.java	58
samza-core/src/main/java/org/apache/samza/operators/util/InternalInMemoryStore.java	97
samza-core/src/main/java/org/apache/samza/runtime/ContainerLaunchUtil.java	195
samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.java	389
samza-core/src/main/java/org/apache/samza/runtime/RemoteApplicationRunner.java	122
samza-core/src/main/java/org/apache/samza/standalone/PassthroughJobCoordinator.java	91
samza-core/src/main/java/org/apache/samza/startpoint/StartpointFanOutPerTask.java	50
samza-core/src/main/java/org/apache/samza/storage/KafkaChangelogStateBackendFactory.java	170
samza-core/src/main/java/org/apache/samza/storage/StorageManagerUtil.java	302
samza-core/src/main/java/org/apache/samza/storage/TaskSideInputHandler.java	187
samza-core/src/main/java/org/apache/samza/storage/blobstore/BlobStoreBackupManager.java	247
samza-core/src/main/java/org/apache/samza/storage/blobstore/BlobStoreRestoreManager.java	264
samza-core/src/main/java/org/apache/samza/storage/blobstore/metrics/BlobStoreBackupManagerMetrics.java	92
samza-core/src/main/java/org/apache/samza/storage/blobstore/metrics/BlobStoreRestoreManagerMetrics.java	54
samza-core/src/main/java/org/apache/samza/storage/blobstore/util/BlobStoreUtil.java	473
samza-core/src/main/java/org/apache/samza/storage/blobstore/util/DirDiffUtil.java	278
samza-core/src/main/java/org/apache/samza/task/StreamOperatorTask.java	130
samza-core/src/main/java/org/apache/samza/zk/ZkBarrierForVersionUpgrade.java	156
samza-core/src/main/java/org/apache/samza/zk/ZkCoordinationUtils.java	48
samza-core/src/main/java/org/apache/samza/zk/ZkJobCoordinator.java	553
samza-core/src/main/java/org/apache/samza/zk/ZkJobCoordinatorFactory.java	41
samza-core/src/main/java/org/apache/samza/zk/ZkKeyBuilder.java	45
samza-core/src/main/java/org/apache/samza/zk/ZkLeaderElector.java	127
samza-core/src/main/java/org/apache/samza/zk/ZkProcessorLatch.java	35
samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala	892
samza-core/src/main/scala/org/apache/samza/container/TaskInstance.scala	506
samza-core/src/main/scala/org/apache/samza/coordinator/server/HttpServer.scala	58
samza-core/src/main/scala/org/apache/samza/util/CoordinatorStreamUtil.scala	141
samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaSystemAdmin.java	670
samza-kafka/src/main/scala/org/apache/samza/checkpoint/kafka/KafkaCheckpointManager.scala	291
samza-kv-couchbase/src/main/java/org/apache/samza/table/remote/couchbase/CouchbaseTableWriteFunction.java	75
samza-kv-inmemory/src/main/java/org/apache/samza/storage/kv/inmemory/InMemoryKeyValueStore.java	122
samza-kv-rocksdb/src/main/java/org/apache/samza/storage/kv/RocksDbOptionsHelper.java	175
samza-kv/src/main/scala/org/apache/samza/storage/kv/KeyValueStorageEngine.scala	192
samza-log4j/src/main/java/org/apache/samza/logging/log4j/StreamAppender.java	252
samza-sql-shell/src/main/java/org/apache/samza/sql/client/impl/SamzaExecutor.java	389
samza-sql-shell/src/main/java/org/apache/samza/sql/client/interfaces/QueryResult.java	16
samza-sql/src/main/java/org/apache/samza/sql/avro/AvroRelConverter.java	249
samza-sql/src/main/java/org/apache/samza/sql/data/SamzaSqlRelMsgMetadata.java	80
samza-sql/src/main/java/org/apache/samza/sql/dsl/SamzaSqlDslConverter.java	71
samza-sql/src/main/java/org/apache/samza/sql/planner/QueryPlanner.java	189
samza-sql/src/main/java/org/apache/samza/sql/planner/RelSchemaConverter.java	74
samza-sql/src/main/java/org/apache/samza/sql/planner/SamzaSqlFilterRemoteJoinRule.java	159
samza-sql/src/main/java/org/apache/samza/sql/planner/SamzaSqlValidator.java	273
samza-sql/src/main/java/org/apache/samza/sql/runner/SamzaSqlApplication.java	59
samza-sql/src/main/java/org/apache/samza/sql/runner/SamzaSqlApplicationConfig.java	247
samza-sql/src/main/java/org/apache/samza/sql/runner/SamzaSqlApplicationRunner.java	95
samza-sql/src/main/java/org/apache/samza/sql/translator/JoinTranslator.java	299
samza-sql/src/main/java/org/apache/samza/sql/translator/QueryTranslator.java	229
samza-sql/src/main/java/org/apache/samza/sql/translator/ScanTranslator.java	158
samza-test/src/main/python/samza_job_yarn_deployer.py	154
samza-tools/src/main/java/org/apache/samza/tools/json/JsonRelConverterFactory.java	64
samza-yarn/src/main/java/org/apache/samza/job/yarn/YarnAppState.java	51
samza-yarn/src/main/java/org/apache/samza/job/yarn/YarnClusterResourceManager.java	509
samza-yarn/src/main/scala/org/apache/samza/job/yarn/ClientHelper.scala	330
samza-yarn/src/main/scala/org/apache/samza/job/yarn/YarnJob.scala	137
samza-yarn/src/main/scala/org/apache/samza/job/yarn/YarnJobFactory.scala	28
samza-yarn3/src/main/java/org/apache/samza/job/yarn/YarnAppState.java	51
samza-yarn3/src/main/java/org/apache/samza/job/yarn/YarnClusterResourceManager.java	507
samza-yarn3/src/main/scala/org/apache/samza/job/yarn/ClientHelper.scala	330
samza-yarn3/src/main/scala/org/apache/samza/job/yarn/YarnJob.scala	137
samza-yarn3/src/main/scala/org/apache/samza/job/yarn/YarnJobFactory.scala	28