Path	Lines of Code
samza-core/src/main/java/org/apache/samza/application/ApplicationUtil.java	32
samza-core/src/main/java/org/apache/samza/application/LegacyTaskApplication.java	13
samza-core/src/main/java/org/apache/samza/application/descriptors/ApplicationDescriptorImpl.java	223
samza-core/src/main/java/org/apache/samza/application/descriptors/ApplicationDescriptorUtil.java	19
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/checkpoint/kafka/KafkaChangelogSSPOffset.java	52
samza-core/src/main/java/org/apache/samza/checkpoint/kafka/KafkaStateCheckpointMarker.java	88
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/ContainerProcessManager.java	455
samza-core/src/main/java/org/apache/samza/clustermanager/DefaultApplicationMain.java	20
samza-core/src/main/java/org/apache/samza/clustermanager/FaultDomain.java	41
samza-core/src/main/java/org/apache/samza/clustermanager/FaultDomainManager.java	9
samza-core/src/main/java/org/apache/samza/clustermanager/FaultDomainManagerFactory.java	8
samza-core/src/main/java/org/apache/samza/clustermanager/FaultDomainType.java	4
samza-core/src/main/java/org/apache/samza/clustermanager/JobCoordinatorLaunchUtil.java	97
samza-core/src/main/java/org/apache/samza/clustermanager/ProcessorFailure.java	22
samza-core/src/main/java/org/apache/samza/clustermanager/ProcessorLaunchException.java	16
samza-core/src/main/java/org/apache/samza/clustermanager/ResourceManagerFactory.java	4
samza-core/src/main/java/org/apache/samza/clustermanager/ResourceRequestState.java	264
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/clustermanager/SamzaResourceStatus.java	32
samza-core/src/main/java/org/apache/samza/clustermanager/SingleFaultDomainManager.java	18
samza-core/src/main/java/org/apache/samza/clustermanager/SingleFaultDomainManagerFactory.java	9
samza-core/src/main/java/org/apache/samza/clustermanager/StandbyContainerManager.java	399
samza-core/src/main/java/org/apache/samza/clustermanager/StandbyTaskUtil.java	63
samza-core/src/main/java/org/apache/samza/clustermanager/container/placement/ContainerPlacementMessageObjectMapper.java	99
samza-core/src/main/java/org/apache/samza/clustermanager/container/placement/ContainerPlacementMetadata.java	78
samza-core/src/main/java/org/apache/samza/clustermanager/container/placement/ContainerPlacementMetadataStore.java	176
samza-core/src/main/java/org/apache/samza/clustermanager/container/placement/ContainerPlacementRequestAllocator.java	66
samza-core/src/main/java/org/apache/samza/config/ApplicationConfig.java	62
samza-core/src/main/java/org/apache/samza/config/BlobStoreConfig.java	45
samza-core/src/main/java/org/apache/samza/config/ClusterManagerConfig.java	164
samza-core/src/main/java/org/apache/samza/config/DefaultChooserConfig.java	41
samza-core/src/main/java/org/apache/samza/config/EnvironmentConfigRewriter.java	44
samza-core/src/main/java/org/apache/samza/config/FileSystemCheckpointManagerConfig.java	11
samza-core/src/main/java/org/apache/samza/config/InMemorySystemConfig.java	11
samza-core/src/main/java/org/apache/samza/config/JobConfig.java	345
samza-core/src/main/java/org/apache/samza/config/JobCoordinatorConfig.java	55
samza-core/src/main/java/org/apache/samza/config/MetricsConfig.java	46
samza-core/src/main/java/org/apache/samza/config/RunLoopConfig.java	50
samza-core/src/main/java/org/apache/samza/config/SerializerConfig.java	65
samza-core/src/main/java/org/apache/samza/config/ShellCommandConfig.java	60
samza-core/src/main/java/org/apache/samza/config/StorageConfig.java	238
samza-core/src/main/java/org/apache/samza/config/StreamConfig.java	174
samza-core/src/main/java/org/apache/samza/config/SystemConfig.java	116
samza-core/src/main/java/org/apache/samza/config/TaskConfig.java	276
samza-core/src/main/java/org/apache/samza/config/ZkConfig.java	32
samza-core/src/main/java/org/apache/samza/config/loaders/PropertiesConfigLoader.java	36
samza-core/src/main/java/org/apache/samza/config/loaders/PropertiesConfigLoaderFactory.java	16
samza-core/src/main/java/org/apache/samza/container/ContainerHeartbeatClient.java	72
samza-core/src/main/java/org/apache/samza/container/ContainerHeartbeatMonitor.java	212
samza-core/src/main/java/org/apache/samza/container/ContainerHeartbeatResponse.java	11
samza-core/src/main/java/org/apache/samza/container/ExecutionContainerIdManager.java	44
samza-core/src/main/java/org/apache/samza/container/LocalityManager.java	52
samza-core/src/main/java/org/apache/samza/container/RunLoop.java	742
samza-core/src/main/java/org/apache/samza/container/RunLoopFactory.java	27
samza-core/src/main/java/org/apache/samza/container/RunLoopTask.java	23
samza-core/src/main/java/org/apache/samza/container/SamzaContainerListener.java	7
samza-core/src/main/java/org/apache/samza/container/SamzaContainerMonitorListener.java	48
samza-core/src/main/java/org/apache/samza/container/SamzaContainerStatus.java	8
samza-core/src/main/java/org/apache/samza/container/SecurityManager.java	5
samza-core/src/main/java/org/apache/samza/container/SecurityManagerFactory.java	5
samza-core/src/main/java/org/apache/samza/container/disk/DiskQuotaPolicy.java	4
samza-core/src/main/java/org/apache/samza/container/disk/DiskQuotaPolicyFactory.java	5
samza-core/src/main/java/org/apache/samza/container/disk/DiskSpaceMonitor.java	9
samza-core/src/main/java/org/apache/samza/container/disk/NoThrottlingDiskQuotaPolicy.java	13
samza-core/src/main/java/org/apache/samza/container/disk/NoThrottlingDiskQuotaPolicyFactory.java	8
samza-core/src/main/java/org/apache/samza/container/disk/PollingScanDiskSpaceMonitor.java	117
samza-core/src/main/java/org/apache/samza/container/disk/WatermarkDiskQuotaPolicy.java	126
samza-core/src/main/java/org/apache/samza/container/disk/WatermarkDiskQuotaPolicyFactory.java	27
samza-core/src/main/java/org/apache/samza/container/grouper/stream/AllSspToSingleTaskGrouperFactory.java	48
samza-core/src/main/java/org/apache/samza/container/grouper/stream/GroupByPartition.java	44
samza-core/src/main/java/org/apache/samza/container/grouper/stream/GroupByPartitionFactory.java	8
samza-core/src/main/java/org/apache/samza/container/grouper/stream/GroupBySystemStreamPartition.java	41
samza-core/src/main/java/org/apache/samza/container/grouper/stream/GroupBySystemStreamPartitionFactory.java	8
samza-core/src/main/java/org/apache/samza/container/grouper/stream/HashSystemStreamPartitionMapper.java	17
samza-core/src/main/java/org/apache/samza/container/grouper/stream/HashSystemStreamPartitionMapperFactory.java	9
samza-core/src/main/java/org/apache/samza/container/grouper/stream/SSPGrouperProxy.java	152
samza-core/src/main/java/org/apache/samza/container/grouper/task/BalancingTaskNameGrouper.java	11
samza-core/src/main/java/org/apache/samza/container/grouper/task/GroupByContainerCount.java	149
samza-core/src/main/java/org/apache/samza/container/grouper/task/GroupByContainerCountFactory.java	9
samza-core/src/main/java/org/apache/samza/container/grouper/task/GroupByContainerIds.java	130
samza-core/src/main/java/org/apache/samza/container/grouper/task/GroupByContainerIdsFactory.java	9
samza-core/src/main/java/org/apache/samza/container/grouper/task/GrouperMetadata.java	14
samza-core/src/main/java/org/apache/samza/container/grouper/task/GrouperMetadataImpl.java	35
samza-core/src/main/java/org/apache/samza/container/grouper/task/SingleContainerGrouperFactory.java	31
samza-core/src/main/java/org/apache/samza/container/grouper/task/TaskAssignmentManager.java	91
samza-core/src/main/java/org/apache/samza/container/grouper/task/TaskGroup.java	42
samza-core/src/main/java/org/apache/samza/container/grouper/task/TaskNameGrouper.java	18
samza-core/src/main/java/org/apache/samza/container/grouper/task/TaskNameGrouperFactory.java	5
samza-core/src/main/java/org/apache/samza/container/grouper/task/TaskNameGrouperProxy.java	68
samza-core/src/main/java/org/apache/samza/container/grouper/task/TaskPartitionAssignmentManager.java	89
samza-core/src/main/java/org/apache/samza/container/host/DefaultSystemStatisticsGetter.java	23
samza-core/src/main/java/org/apache/samza/container/host/OshiBasedStatisticsGetter.java	63
samza-core/src/main/java/org/apache/samza/container/host/PosixCommandBasedStatisticsGetter.java	53
samza-core/src/main/java/org/apache/samza/container/host/ProcessCPUStatistics.java	30
samza-core/src/main/java/org/apache/samza/container/host/StatisticsMonitorImpl.java	92
samza-core/src/main/java/org/apache/samza/container/host/SystemMemoryStatistics.java	27
samza-core/src/main/java/org/apache/samza/container/host/SystemStatistics.java	35
samza-core/src/main/java/org/apache/samza/container/host/SystemStatisticsGetter.java	5
samza-core/src/main/java/org/apache/samza/container/host/SystemStatisticsMonitor.java	9
samza-core/src/main/java/org/apache/samza/context/ContainerContextImpl.java	27
samza-core/src/main/java/org/apache/samza/context/ContextImpl.java	72
samza-core/src/main/java/org/apache/samza/context/InternalTaskContext.java	32
samza-core/src/main/java/org/apache/samza/context/JobContextImpl.java	39
samza-core/src/main/java/org/apache/samza/context/TaskContextImpl.java	95
samza-core/src/main/java/org/apache/samza/coordinator/ClusterMembership.java	8
samza-core/src/main/java/org/apache/samza/coordinator/CoordinationConstants.java	16
samza-core/src/main/java/org/apache/samza/coordinator/CoordinationUtils.java	10
samza-core/src/main/java/org/apache/samza/coordinator/CoordinationUtilsFactory.java	5
samza-core/src/main/java/org/apache/samza/coordinator/DistributedLock.java	6
samza-core/src/main/java/org/apache/samza/coordinator/InputStreamsDiscoveredException.java	7
samza-core/src/main/java/org/apache/samza/coordinator/JobCoordinator.java	12
samza-core/src/main/java/org/apache/samza/coordinator/JobCoordinatorFactory.java	10
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/JobModelHelper.java	151
samza-core/src/main/java/org/apache/samza/coordinator/JobModelMonitors.java	32
samza-core/src/main/java/org/apache/samza/coordinator/LeaderElector.java	9
samza-core/src/main/java/org/apache/samza/coordinator/LeaderElectorListener.java	4
samza-core/src/main/java/org/apache/samza/coordinator/MetadataResourceUtil.java	33
samza-core/src/main/java/org/apache/samza/coordinator/NoProcessorJobCoordinatorListener.java	27
samza-core/src/main/java/org/apache/samza/coordinator/PartitionChangeException.java	7
samza-core/src/main/java/org/apache/samza/coordinator/RunIdGenerator.java	67
samza-core/src/main/java/org/apache/samza/coordinator/StreamPartitionCountMonitor.java	146
samza-core/src/main/java/org/apache/samza/coordinator/StreamPartitionCountMonitorFactory.java	26
samza-core/src/main/java/org/apache/samza/coordinator/StreamRegexMonitor.java	125
samza-core/src/main/java/org/apache/samza/coordinator/StreamRegexMonitorFactory.java	49
samza-core/src/main/java/org/apache/samza/coordinator/communication/CoordinatorCommunication.java	5
samza-core/src/main/java/org/apache/samza/coordinator/communication/CoordinatorCommunicationContext.java	23
samza-core/src/main/java/org/apache/samza/coordinator/communication/CoordinatorToWorkerCommunicationFactory.java	4
samza-core/src/main/java/org/apache/samza/coordinator/communication/HttpCoordinatorCommunication.java	31
samza-core/src/main/java/org/apache/samza/coordinator/communication/HttpCoordinatorToWorkerCommunicationFactory.java	17
samza-core/src/main/java/org/apache/samza/coordinator/communication/JobInfoProvider.java	5
samza-core/src/main/java/org/apache/samza/coordinator/communication/JobInfoServingContext.java	20
samza-core/src/main/java/org/apache/samza/coordinator/communication/JobModelHttpServlet.java	46
samza-core/src/main/java/org/apache/samza/coordinator/lifecycle/NoOpJobRestartSignal.java	10
samza-core/src/main/java/org/apache/samza/coordinator/lifecycle/NoOpJobRestartSignalFactory.java	7
samza-core/src/main/java/org/apache/samza/coordinator/metadatastore/CoordinatorStreamMetadataStoreFactory.java	11
samza-core/src/main/java/org/apache/samza/coordinator/metadatastore/CoordinatorStreamStore.java	185
samza-core/src/main/java/org/apache/samza/coordinator/metadatastore/NamespaceAwareCoordinatorStreamStore.java	73
samza-core/src/main/java/org/apache/samza/coordinator/server/LocalityServlet.java	33
samza-core/src/main/java/org/apache/samza/coordinator/staticresource/StaticResourceJobCoordinator.java	199
samza-core/src/main/java/org/apache/samza/coordinator/staticresource/StaticResourceJobCoordinatorFactory.java	87
samza-core/src/main/java/org/apache/samza/coordinator/stream/CoordinatorStreamKeySerde.java	25
samza-core/src/main/java/org/apache/samza/coordinator/stream/CoordinatorStreamManager.java	82
samza-core/src/main/java/org/apache/samza/coordinator/stream/CoordinatorStreamSystemConsumer.java	197
samza-core/src/main/java/org/apache/samza/coordinator/stream/CoordinatorStreamSystemProducer.java	96
samza-core/src/main/java/org/apache/samza/coordinator/stream/CoordinatorStreamValueSerde.java	88
samza-core/src/main/java/org/apache/samza/coordinator/stream/CoordinatorStreamWriter.java	51
samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/CoordinatorStreamMessage.java	151
samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/Delete.java	13
samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/SetChangelogMapping.java	22
samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/SetConfig.java	17
samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/SetContainerHostMapping.java	21
samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/SetExecutionEnvContainerIdMapping.java	17
samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/SetJobCoordinatorMetadataMessage.java	17
samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/SetMigrationMetaMessage.java	16
samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/SetTaskContainerMapping.java	17
samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/SetTaskModeMapping.java	17
samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/SetTaskPartitionMapping.java	17
samza-core/src/main/java/org/apache/samza/drain/DrainMonitor.java	158
samza-core/src/main/java/org/apache/samza/drain/DrainNotificationObjectMapper.java	60
samza-core/src/main/java/org/apache/samza/drain/DrainUtils.java	95
samza-core/src/main/java/org/apache/samza/environment/EnvironmentVariables.java	5
samza-core/src/main/java/org/apache/samza/execution/ExecutionPlan.java	13
samza-core/src/main/java/org/apache/samza/execution/ExecutionPlanner.java	183
samza-core/src/main/java/org/apache/samza/execution/IntermediateStreamManager.java	107
samza-core/src/main/java/org/apache/samza/execution/JobGraph.java	265
samza-core/src/main/java/org/apache/samza/execution/JobGraphJsonGenerator.java	202
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/OperatorSpecGraphAnalyzer.java	99
samza-core/src/main/java/org/apache/samza/execution/RemoteJobPlanner.java	58
samza-core/src/main/java/org/apache/samza/execution/StreamEdge.java	94
samza-core/src/main/java/org/apache/samza/execution/StreamManager.java	101
samza-core/src/main/java/org/apache/samza/executors/KeyBasedExecutorService.java	106
samza-core/src/main/java/org/apache/samza/job/ShellCommandBuilder.java	29
samza-core/src/main/java/org/apache/samza/job/metadata/JobCoordinatorMetadataManager.java	243
samza-core/src/main/java/org/apache/samza/job/model/JobModelUtil.java	93
samza-core/src/main/java/org/apache/samza/logging/LoggingContextHolder.java	22
samza-core/src/main/java/org/apache/samza/metrics/BaseServerMetrics.java	11
samza-core/src/main/java/org/apache/samza/metrics/JmxMetricsAccessor.java	59
samza-core/src/main/java/org/apache/samza/metrics/JmxUtil.java	28
samza-core/src/main/java/org/apache/samza/metrics/MetricGroup.java	35
samza-core/src/main/java/org/apache/samza/metrics/MetricsBase.java	23
samza-core/src/main/java/org/apache/samza/metrics/reporter/LoggingMetricsReporter.java	84
samza-core/src/main/java/org/apache/samza/metrics/reporter/LoggingMetricsReporterConfig.java	21
samza-core/src/main/java/org/apache/samza/metrics/reporter/LoggingMetricsReporterFactory.java	19
samza-core/src/main/java/org/apache/samza/metrics/reporter/Metrics.java	47
samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsHeader.java	138
samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsSnapshot.java	50
samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsSnapshotReporter.java	179
samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsSnapshotReporterFactory.java	110
samza-core/src/main/java/org/apache/samza/migration/MigrationPlan.java	5
samza-core/src/main/java/org/apache/samza/operators/MessageStreamImpl.java	166
samza-core/src/main/java/org/apache/samza/operators/OperatorSpecGraph.java	73
samza-core/src/main/java/org/apache/samza/operators/TableImpl.java	16
samza-core/src/main/java/org/apache/samza/operators/functions/PartialJoinFunction.java	8
samza-core/src/main/java/org/apache/samza/operators/impl/AsyncFlatmapOperatorImpl.java	34
samza-core/src/main/java/org/apache/samza/operators/impl/BroadcastOperatorImpl.java	64
samza-core/src/main/java/org/apache/samza/operators/impl/ControlMessageSender.java	52
samza-core/src/main/java/org/apache/samza/operators/impl/DrainStates.java	60
samza-core/src/main/java/org/apache/samza/operators/impl/EndOfStreamStates.java	50
samza-core/src/main/java/org/apache/samza/operators/impl/FlatmapOperatorImpl.java	34
samza-core/src/main/java/org/apache/samza/operators/impl/InputOperatorImpl.java	44
samza-core/src/main/java/org/apache/samza/operators/impl/OperatorImpl.java	412
samza-core/src/main/java/org/apache/samza/operators/impl/OperatorImplGraph.java	276
samza-core/src/main/java/org/apache/samza/operators/impl/OutputOperatorImpl.java	48
samza-core/src/main/java/org/apache/samza/operators/impl/PartialJoinOperatorImpl.java	69
samza-core/src/main/java/org/apache/samza/operators/impl/PartitionByOperatorImpl.java	81
samza-core/src/main/java/org/apache/samza/operators/impl/SendToTableOperatorImpl.java	43
samza-core/src/main/java/org/apache/samza/operators/impl/SendToTableWithUpdateOperatorImpl.java	85
samza-core/src/main/java/org/apache/samza/operators/impl/SinkOperatorImpl.java	36
samza-core/src/main/java/org/apache/samza/operators/impl/StreamTableJoinOperatorImpl.java	51
samza-core/src/main/java/org/apache/samza/operators/impl/TriggerKey.java	48
samza-core/src/main/java/org/apache/samza/operators/impl/TriggerScheduler.java	64
samza-core/src/main/java/org/apache/samza/operators/impl/WatermarkMetrics.java	26
samza-core/src/main/java/org/apache/samza/operators/impl/WatermarkStates.java	144
samza-core/src/main/java/org/apache/samza/operators/impl/WindowOperatorImpl.java	288
samza-core/src/main/java/org/apache/samza/operators/impl/store/TimeSeriesKey.java	41
samza-core/src/main/java/org/apache/samza/operators/impl/store/TimeSeriesKeySerde.java	50
samza-core/src/main/java/org/apache/samza/operators/impl/store/TimeSeriesStore.java	13
samza-core/src/main/java/org/apache/samza/operators/impl/store/TimeSeriesStoreImpl.java	143
samza-core/src/main/java/org/apache/samza/operators/impl/store/TimestampedValueSerde.java	31
samza-core/src/main/java/org/apache/samza/operators/spec/AsyncFlatMapOperatorSpec.java	22
samza-core/src/main/java/org/apache/samza/operators/spec/BroadcastOperatorSpec.java	21
samza-core/src/main/java/org/apache/samza/operators/spec/FilterOperatorSpec.java	42
samza-core/src/main/java/org/apache/samza/operators/spec/FlatMapOperatorSpec.java	17
samza-core/src/main/java/org/apache/samza/operators/spec/InputOperatorSpec.java	45
samza-core/src/main/java/org/apache/samza/operators/spec/JoinOperatorSpec.java	77
samza-core/src/main/java/org/apache/samza/operators/spec/MapOperatorSpec.java	43
samza-core/src/main/java/org/apache/samza/operators/spec/MergeOperatorSpec.java	22
samza-core/src/main/java/org/apache/samza/operators/spec/OperatorSpec.java	66
samza-core/src/main/java/org/apache/samza/operators/spec/OperatorSpecs.java	77
samza-core/src/main/java/org/apache/samza/operators/spec/OutputOperatorSpec.java	21
samza-core/src/main/java/org/apache/samza/operators/spec/OutputStreamImpl.java	28
samza-core/src/main/java/org/apache/samza/operators/spec/PartitionByOperatorSpec.java	40
samza-core/src/main/java/org/apache/samza/operators/spec/SendToTableOperatorSpec.java	24
samza-core/src/main/java/org/apache/samza/operators/spec/SendToTableWithUpdateOperatorSpec.java	31
samza-core/src/main/java/org/apache/samza/operators/spec/SinkOperatorSpec.java	22
samza-core/src/main/java/org/apache/samza/operators/spec/StatefulOperatorSpec.java	5
samza-core/src/main/java/org/apache/samza/operators/spec/StoreDescriptor.java	48
samza-core/src/main/java/org/apache/samza/operators/spec/StreamOperatorSpec.java	12
samza-core/src/main/java/org/apache/samza/operators/spec/StreamTableJoinOperatorSpec.java	34
samza-core/src/main/java/org/apache/samza/operators/spec/WindowOperatorSpec.java	92
samza-core/src/main/java/org/apache/samza/operators/spec/WindowState.java	12
samza-core/src/main/java/org/apache/samza/operators/stream/IntermediateMessageStreamImpl.java	33
samza-core/src/main/java/org/apache/samza/operators/triggers/AnyTriggerImpl.java	50
samza-core/src/main/java/org/apache/samza/operators/triggers/Cancellable.java	4
samza-core/src/main/java/org/apache/samza/operators/triggers/CountTriggerImpl.java	31
samza-core/src/main/java/org/apache/samza/operators/triggers/RepeatingTriggerImpl.java	36
samza-core/src/main/java/org/apache/samza/operators/triggers/TimeSinceFirstMessageTriggerImpl.java	40
samza-core/src/main/java/org/apache/samza/operators/triggers/TimeSinceLastMessageTriggerImpl.java	47
samza-core/src/main/java/org/apache/samza/operators/triggers/TimeTriggerImpl.java	40
samza-core/src/main/java/org/apache/samza/operators/triggers/TriggerImpl.java	7
samza-core/src/main/java/org/apache/samza/operators/triggers/TriggerImpls.java	25
samza-core/src/main/java/org/apache/samza/operators/util/InternalInMemoryStore.java	97
samza-core/src/main/java/org/apache/samza/processor/StreamProcessor.java	372
samza-core/src/main/java/org/apache/samza/runtime/ApplicationRunnerMain.java	46
samza-core/src/main/java/org/apache/samza/runtime/ApplicationRunnerOperation.java	15
samza-core/src/main/java/org/apache/samza/runtime/ApplicationRunnerUtil.java	25
samza-core/src/main/java/org/apache/samza/runtime/ApplicationRunners.java	26
samza-core/src/main/java/org/apache/samza/runtime/ClusterBasedProcessorLifecycleListener.java	101
samza-core/src/main/java/org/apache/samza/runtime/ContainerLaunchUtil.java	195
samza-core/src/main/java/org/apache/samza/runtime/DefaultLocationIdProviderFactory.java	9
samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.java	389
samza-core/src/main/java/org/apache/samza/runtime/LocalContainerRunner.java	49
samza-core/src/main/java/org/apache/samza/runtime/RemoteApplicationRunner.java	122
samza-core/src/main/java/org/apache/samza/runtime/UUIDGenerator.java	9
samza-core/src/main/java/org/apache/samza/scheduler/CallbackSchedulerImpl.java	15
samza-core/src/main/java/org/apache/samza/scheduler/EpochTimeScheduler.java	122
samza-core/src/main/java/org/apache/samza/serializers/CheckpointV2Serde.java	25
samza-core/src/main/java/org/apache/samza/serializers/IntermediateMessageSerde.java	83
samza-core/src/main/java/org/apache/samza/serializers/JsonCheckpoint.java	24
samza-core/src/main/java/org/apache/samza/serializers/model/JsonCheckpointV2Mixin.java	22
samza-core/src/main/java/org/apache/samza/serializers/model/JsonContainerModelMixIn.java	14
samza-core/src/main/java/org/apache/samza/serializers/model/JsonJobCoordinatorMetadataMixIn.java	17
samza-core/src/main/java/org/apache/samza/serializers/model/JsonJobModelMixIn.java	17
samza-core/src/main/java/org/apache/samza/serializers/model/JsonLocalityModelMixIn.java	14
samza-core/src/main/java/org/apache/samza/serializers/model/JsonProcessorLocalityMixIn.java	19
samza-core/src/main/java/org/apache/samza/serializers/model/JsonTaskModelMixIn.java	20
samza-core/src/main/java/org/apache/samza/serializers/model/KafkaStateCheckpointMarkerMixin.java	20
samza-core/src/main/java/org/apache/samza/serializers/model/SamzaObjectMapper.java	237
samza-core/src/main/java/org/apache/samza/standalone/PassthroughCoordinationUtilsFactory.java	10
samza-core/src/main/java/org/apache/samza/standalone/PassthroughJobCoordinator.java	91
samza-core/src/main/java/org/apache/samza/standalone/PassthroughJobCoordinatorFactory.java	13
samza-core/src/main/java/org/apache/samza/startpoint/StartpointFanOutPerTask.java	50
samza-core/src/main/java/org/apache/samza/startpoint/StartpointManager.java	262
samza-core/src/main/java/org/apache/samza/startpoint/StartpointObjectMapper.java	42
samza-core/src/main/java/org/apache/samza/storage/ChangelogStreamManager.java	105
samza-core/src/main/java/org/apache/samza/storage/KafkaChangelogStateBackendFactory.java	170
samza-core/src/main/java/org/apache/samza/storage/NonTransactionalStateTaskRestoreManager.java	268
samza-core/src/main/java/org/apache/samza/storage/SideInputTask.java	106
samza-core/src/main/java/org/apache/samza/storage/StateStorageTool.java	32
samza-core/src/main/java/org/apache/samza/storage/StorageManagerUtil.java	302
samza-core/src/main/java/org/apache/samza/storage/StorageRecovery.java	175
samza-core/src/main/java/org/apache/samza/storage/TaskSideInputHandler.java	187
samza-core/src/main/java/org/apache/samza/storage/TaskSideInputStorageManager.java	131
samza-core/src/main/java/org/apache/samza/storage/TaskStorageCommitManager.java	260
samza-core/src/main/java/org/apache/samza/storage/TransactionalStateTaskRestoreManager.java	517
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/BlobStoreStateBackendFactory.java	79
samza-core/src/main/java/org/apache/samza/storage/blobstore/diff/DirDiff.java	162
samza-core/src/main/java/org/apache/samza/storage/blobstore/index/DirIndex.java	180
samza-core/src/main/java/org/apache/samza/storage/blobstore/index/FileBlob.java	46
samza-core/src/main/java/org/apache/samza/storage/blobstore/index/FileIndex.java	67
samza-core/src/main/java/org/apache/samza/storage/blobstore/index/FileMetadata.java	97
samza-core/src/main/java/org/apache/samza/storage/blobstore/index/SnapshotIndex.java	75
samza-core/src/main/java/org/apache/samza/storage/blobstore/index/SnapshotMetadata.java	78
samza-core/src/main/java/org/apache/samza/storage/blobstore/index/serde/JsonDirIndexMixin.java	27
samza-core/src/main/java/org/apache/samza/storage/blobstore/index/serde/JsonFileBlobMixin.java	14
samza-core/src/main/java/org/apache/samza/storage/blobstore/index/serde/JsonFileIndexMixin.java	23
samza-core/src/main/java/org/apache/samza/storage/blobstore/index/serde/JsonFileMetadataMixin.java	25
samza-core/src/main/java/org/apache/samza/storage/blobstore/index/serde/JsonSnapshotIndexMixin.java	24
samza-core/src/main/java/org/apache/samza/storage/blobstore/index/serde/JsonSnapshotMetadataMixin.java	23
samza-core/src/main/java/org/apache/samza/storage/blobstore/index/serde/SnapshotIndexSerde.java	53
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/system/SystemAdmins.java	46
samza-core/src/main/java/org/apache/samza/system/descriptors/DelegatingSystemDescriptor.java	24
samza-core/src/main/java/org/apache/samza/system/inmemory/InMemoryManager.java	137
samza-core/src/main/java/org/apache/samza/system/inmemory/InMemorySystemAdmin.java	59
samza-core/src/main/java/org/apache/samza/system/inmemory/InMemorySystemConsumer.java	56
samza-core/src/main/java/org/apache/samza/system/inmemory/InMemorySystemFactory.java	28
samza-core/src/main/java/org/apache/samza/system/inmemory/InMemorySystemProducer.java	58
samza-core/src/main/java/org/apache/samza/table/BaseReadWriteUpdateTable.java	38
samza-core/src/main/java/org/apache/samza/table/BaseTableProvider.java	21
samza-core/src/main/java/org/apache/samza/table/ReadWriteTableDelegate.java	76
samza-core/src/main/java/org/apache/samza/table/TableConfigGenerator.java	58
samza-core/src/main/java/org/apache/samza/table/TableManager.java	60
samza-core/src/main/java/org/apache/samza/table/batching/AbstractBatch.java	39
samza-core/src/main/java/org/apache/samza/table/batching/AsyncBatchingTable.java	120
samza-core/src/main/java/org/apache/samza/table/batching/BatchHandler.java	5
samza-core/src/main/java/org/apache/samza/table/batching/BatchMetrics.java	18
samza-core/src/main/java/org/apache/samza/table/batching/BatchProcessor.java	125
samza-core/src/main/java/org/apache/samza/table/batching/BatchingNotSupportedException.java	15
samza-core/src/main/java/org/apache/samza/table/batching/CompactBatch.java	42
samza-core/src/main/java/org/apache/samza/table/batching/CompactBatchProvider.java	7
samza-core/src/main/java/org/apache/samza/table/batching/CompleteBatch.java	30
samza-core/src/main/java/org/apache/samza/table/batching/CompleteBatchProvider.java	7
samza-core/src/main/java/org/apache/samza/table/batching/DeleteOperation.java	27
samza-core/src/main/java/org/apache/samza/table/batching/GetOperation.java	40
samza-core/src/main/java/org/apache/samza/table/batching/PutOperation.java	30
samza-core/src/main/java/org/apache/samza/table/batching/TableBatchHandler.java	111
samza-core/src/main/java/org/apache/samza/table/batching/UpdateOperation.java	28
samza-core/src/main/java/org/apache/samza/table/caching/CachingTable.java	271
samza-core/src/main/java/org/apache/samza/table/caching/CachingTableProvider.java	61
samza-core/src/main/java/org/apache/samza/table/caching/CachingTableProviderFactory.java	9
samza-core/src/main/java/org/apache/samza/table/caching/SupplierGauge.java	16
samza-core/src/main/java/org/apache/samza/table/caching/guava/GuavaCacheTable.java	175
samza-core/src/main/java/org/apache/samza/table/caching/guava/GuavaCacheTableProvider.java	32
samza-core/src/main/java/org/apache/samza/table/caching/guava/GuavaCacheTableProviderFactory.java	9
samza-core/src/main/java/org/apache/samza/table/ratelimit/AsyncRateLimitedTable.java	152
samza-core/src/main/java/org/apache/samza/table/remote/AsyncRemoteTable.java	98
samza-core/src/main/java/org/apache/samza/table/remote/NoOpTableReadFunction.java	13
samza-core/src/main/java/org/apache/samza/table/remote/RemoteTable.java	344
samza-core/src/main/java/org/apache/samza/table/remote/RemoteTableProvider.java	119
samza-core/src/main/java/org/apache/samza/table/remote/RemoteTableProviderFactory.java	9
samza-core/src/main/java/org/apache/samza/table/retry/AsyncRetriableTable.java	123
samza-core/src/main/java/org/apache/samza/table/retry/FailsafeAdapter.java	55
samza-core/src/main/java/org/apache/samza/table/retry/RetryMetrics.java	16
samza-core/src/main/java/org/apache/samza/table/utils/TableMetrics.java	56
samza-core/src/main/java/org/apache/samza/table/utils/TableMetricsUtil.java	52
samza-core/src/main/java/org/apache/samza/task/AsyncStreamTaskAdapter.java	63
samza-core/src/main/java/org/apache/samza/task/CoordinatorRequests.java	45
samza-core/src/main/java/org/apache/samza/task/DefaultTaskExecutorFactory.java	40
samza-core/src/main/java/org/apache/samza/task/StreamOperatorTask.java	130
samza-core/src/main/java/org/apache/samza/task/TaskCallbackFactory.java	4
samza-core/src/main/java/org/apache/samza/task/TaskCallbackImpl.java	92
samza-core/src/main/java/org/apache/samza/task/TaskCallbackListener.java	5
samza-core/src/main/java/org/apache/samza/task/TaskCallbackManager.java	86
samza-core/src/main/java/org/apache/samza/task/TaskFactoryUtil.java	75
samza-core/src/main/java/org/apache/samza/testUtils/TestClock.java	16
samza-core/src/main/java/org/apache/samza/testUtils/TestUtils.java	24
samza-core/src/main/java/org/apache/samza/util/BoundedLinkedHashSet.java	24
samza-core/src/main/java/org/apache/samza/util/ConfigUtil.java	55
samza-core/src/main/java/org/apache/samza/util/DiagnosticsUtil.java	124
samza-core/src/main/java/org/apache/samza/util/EmbeddedTaggedRateLimiter.java	103
samza-core/src/main/java/org/apache/samza/util/FutureUtil.java	116
samza-core/src/main/java/org/apache/samza/util/HighResolutionClock.java	4
samza-core/src/main/java/org/apache/samza/util/MathUtil.java	36
samza-core/src/main/java/org/apache/samza/util/MetricsReporterLoader.java	28
samza-core/src/main/java/org/apache/samza/util/ReflectionUtil.java	58
samza-core/src/main/java/org/apache/samza/util/RetryPolicyConfig.java	42
samza-core/src/main/java/org/apache/samza/util/SamzaUncaughtExceptionHandler.java	23
samza-core/src/main/java/org/apache/samza/util/ShutdownUtil.java	31
samza-core/src/main/java/org/apache/samza/util/StreamUtil.java	45
samza-core/src/main/java/org/apache/samza/util/SystemClock.java	12
samza-core/src/main/java/org/apache/samza/util/SystemHighResolutionClock.java	12
samza-core/src/main/java/org/apache/samza/util/ThreadUtil.java	88
samza-core/src/main/java/org/apache/samza/util/Throttleable.java	7
samza-core/src/main/java/org/apache/samza/util/ThrottlingExecutor.java	63
samza-core/src/main/java/org/apache/samza/util/ThrottlingScheduler.java	76
samza-core/src/main/java/org/apache/samza/util/Util.java	29
samza-core/src/main/java/org/apache/samza/zk/ProcessorData.java	40
samza-core/src/main/java/org/apache/samza/zk/ScheduleAfterDebounceTime.java	103
samza-core/src/main/java/org/apache/samza/zk/ZkBarrierForVersionUpgrade.java	156
samza-core/src/main/java/org/apache/samza/zk/ZkBarrierListener.java	6
samza-core/src/main/java/org/apache/samza/zk/ZkClusterMembership.java	46
samza-core/src/main/java/org/apache/samza/zk/ZkCoordinationUtils.java	48
samza-core/src/main/java/org/apache/samza/zk/ZkCoordinationUtilsFactory.java	46
samza-core/src/main/java/org/apache/samza/zk/ZkDistributedLock.java	81
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/ZkJobCoordinatorMetrics.java	26
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/ZkMetadataStore.java	120
samza-core/src/main/java/org/apache/samza/zk/ZkMetadataStoreFactory.java	15
samza-core/src/main/java/org/apache/samza/zk/ZkProcessorLatch.java	35
samza-core/src/main/java/org/apache/samza/zk/ZkSessionMetrics.java	19
samza-core/src/main/java/org/apache/samza/zk/ZkStringSerializer.java	31
samza-core/src/main/java/org/apache/samza/zk/ZkUtils.java	484
samza-core/src/main/java/org/apache/samza/zk/ZkUtilsMetrics.java	19
samza-core/src/main/scala/org/apache/samza/checkpoint/CheckpointTool.scala	160
samza-core/src/main/scala/org/apache/samza/checkpoint/OffsetManager.scala	406
samza-core/src/main/scala/org/apache/samza/checkpoint/OffsetManagerMetrics.scala	10
samza-core/src/main/scala/org/apache/samza/checkpoint/file/FileSystemCheckpointManager.scala	55
samza-core/src/main/scala/org/apache/samza/config/RegExTopicGenerator.scala	61
samza-core/src/main/scala/org/apache/samza/config/ScalaMapConfig.scala	21
samza-core/src/main/scala/org/apache/samza/config/factories/PropertiesConfigFactory.scala	25
samza-core/src/main/scala/org/apache/samza/container/SameThreadExecutor.scala	5
samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala	892
samza-core/src/main/scala/org/apache/samza/container/SamzaContainerMetrics.scala	38
samza-core/src/main/scala/org/apache/samza/container/TaskInstance.scala	506
samza-core/src/main/scala/org/apache/samza/container/TaskInstanceExceptionHandler.scala	44
samza-core/src/main/scala/org/apache/samza/container/TaskInstanceMetrics.scala	35
samza-core/src/main/scala/org/apache/samza/coordinator/JobModelManager.scala	63
samza-core/src/main/scala/org/apache/samza/coordinator/Latch.java	7
samza-core/src/main/scala/org/apache/samza/coordinator/server/HttpServer.scala	58
samza-core/src/main/scala/org/apache/samza/coordinator/server/JobServlet.scala	14
samza-core/src/main/scala/org/apache/samza/coordinator/stream/CoordinatorStreamWriterCommandLine.scala	42
samza-core/src/main/scala/org/apache/samza/diagnostics/BoundedList.java	67
samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsExceptionEvent.java	53
samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsManager.java	205
samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsStreamMessage.java	200
samza-core/src/main/scala/org/apache/samza/diagnostics/ProcessorStopEvent.java	33
samza-core/src/main/scala/org/apache/samza/job/JobRunner.scala	71
samza-core/src/main/scala/org/apache/samza/job/local/ProcessJob.scala	100
samza-core/src/main/scala/org/apache/samza/job/local/ProcessJobFactory.scala	69
samza-core/src/main/scala/org/apache/samza/job/local/ThreadJob.scala	45
samza-core/src/main/scala/org/apache/samza/job/local/ThreadJobFactory.scala	116
samza-core/src/main/scala/org/apache/samza/metrics/ContainerProcessManagerMetrics.scala	40
samza-core/src/main/scala/org/apache/samza/metrics/JmxServer.scala	65
samza-core/src/main/scala/org/apache/samza/metrics/JvmMetrics.scala	131
samza-core/src/main/scala/org/apache/samza/metrics/MetricsHelper.scala	17
samza-core/src/main/scala/org/apache/samza/metrics/MetricsRegistryMap.scala	55
samza-core/src/main/scala/org/apache/samza/metrics/reporter/JmxReporter.scala	91
samza-core/src/main/scala/org/apache/samza/serializers/CheckpointV1Serde.scala	47
samza-core/src/main/scala/org/apache/samza/serializers/JsonSerde.scala	30
samza-core/src/main/scala/org/apache/samza/serializers/MetricsSnapshotSerde.scala	17
samza-core/src/main/scala/org/apache/samza/serializers/MetricsSnapshotSerdeV2.java	44
samza-core/src/main/scala/org/apache/samza/serializers/MetricsSnapshotSerdeV2Factory.java	9
samza-core/src/main/scala/org/apache/samza/serializers/SerdeManager.scala	105
samza-core/src/main/scala/org/apache/samza/storage/ContainerStorageManager.java	304
samza-core/src/main/scala/org/apache/samza/storage/ContainerStorageManagerRestoreUtil.java	284
samza-core/src/main/scala/org/apache/samza/storage/ContainerStorageManagerUtil.java	318
samza-core/src/main/scala/org/apache/samza/storage/KafkaNonTransactionalStateTaskBackupManager.scala	50
samza-core/src/main/scala/org/apache/samza/storage/KafkaTransactionalStateTaskBackupManager.scala	55
samza-core/src/main/scala/org/apache/samza/storage/SideInputsManager.java	381
samza-core/src/main/scala/org/apache/samza/system/RangeSystemStreamPartitionMatcher.scala	26
samza-core/src/main/scala/org/apache/samza/system/RegexSystemStreamPartitionMatcher.scala	11
samza-core/src/main/scala/org/apache/samza/system/SSPMetadataCache.java	73
samza-core/src/main/scala/org/apache/samza/system/StreamMetadataCache.scala	61
samza-core/src/main/scala/org/apache/samza/system/SystemConsumers.scala	282
samza-core/src/main/scala/org/apache/samza/system/SystemConsumersMetrics.scala	37
samza-core/src/main/scala/org/apache/samza/system/SystemProducers.scala	56
samza-core/src/main/scala/org/apache/samza/system/SystemProducersMetrics.scala	16
samza-core/src/main/scala/org/apache/samza/system/chooser/BatchingChooser.scala	66
samza-core/src/main/scala/org/apache/samza/system/chooser/BootstrappingChooser.scala	143
samza-core/src/main/scala/org/apache/samza/system/chooser/DefaultChooser.scala	94
samza-core/src/main/scala/org/apache/samza/system/chooser/RoundRobinChooser.scala	28
samza-core/src/main/scala/org/apache/samza/system/chooser/TieredPriorityChooser.scala	74
samza-core/src/main/scala/org/apache/samza/system/filereader/FileReaderSystemAdmin.scala	86
samza-core/src/main/scala/org/apache/samza/system/filereader/FileReaderSystemConsumer.scala	84
samza-core/src/main/scala/org/apache/samza/system/filereader/FileReaderSystemFactory.scala	18
samza-core/src/main/scala/org/apache/samza/task/ReadableCoordinator.scala	13
samza-core/src/main/scala/org/apache/samza/task/TaskInstanceCollector.scala	23
samza-core/src/main/scala/org/apache/samza/util/CommandLine.scala	23
samza-core/src/main/scala/org/apache/samza/util/CoordinatorStreamConfigFactory.java	5
samza-core/src/main/scala/org/apache/samza/util/CoordinatorStreamUtil.scala	141
samza-core/src/main/scala/org/apache/samza/util/DefaultCoordinatorStreamConfigFactory.java	24
samza-core/src/main/scala/org/apache/samza/util/ExponentialSleepStrategy.scala	80
samza-core/src/main/scala/org/apache/samza/util/FileUtil.scala	110
samza-core/src/main/scala/org/apache/samza/util/HttpUtil.scala	52
samza-core/src/main/scala/org/apache/samza/util/Logging.scala	65
samza-core/src/main/scala/org/apache/samza/util/ScalaJavaUtil.scala	43
samza-core/src/main/scala/org/apache/samza/util/TimerUtil.scala	18