path	# lines of code
samza-log4j2/src/main/java/org/apache/samza/logging/log4j2/SimpleDiagnosticsAppender.java	47
samza-log4j2/src/main/java/org/apache/samza/logging/log4j2/serializers/LoggingEventJsonSerdeFactory.java	13
samza-log4j2/src/main/java/org/apache/samza/logging/log4j2/serializers/LoggingEventStringSerde.java	38
samza-log4j2/src/main/java/org/apache/samza/logging/log4j2/serializers/LoggingEventStringSerdeFactory.java	11
samza-log4j2/src/main/java/org/apache/samza/logging/log4j2/serializers/LoggingEventJsonSerde.java	102
samza-log4j2/src/main/java/org/apache/samza/logging/log4j2/StreamAppender.java	341
samza-log4j2/src/main/java/org/apache/samza/logging/log4j2/StreamAppenderMetrics.java	20
samza-log4j2/src/main/java/org/apache/samza/config/Log4jSystemConfig.java	34
gradle/resources/rat-output-to-html.xsl	153
samza-api/src/main/java/org/apache/samza/metrics/MetricsValidationFailureException.java	9
samza-api/src/main/java/org/apache/samza/metrics/MetricsRegistry.java	9
samza-api/src/main/java/org/apache/samza/metrics/ReadableMetricsRegistryListener.java	6
samza-api/src/main/java/org/apache/samza/metrics/MetricsReporterFactory.java	6
samza-api/src/main/java/org/apache/samza/metrics/MetricsReporter.java	6
samza-api/src/main/java/org/apache/samza/metrics/MetricsVisitor.java	15
samza-api/src/main/java/org/apache/samza/metrics/Counter.java	42
samza-api/src/main/java/org/apache/samza/metrics/MetricsRegistryWithSource.java	15
samza-api/src/main/java/org/apache/samza/metrics/Gauge.java	31
samza-api/src/main/java/org/apache/samza/metrics/ReadableMetricsRegistry.java	9
samza-api/src/main/java/org/apache/samza/metrics/Metric.java	4
samza-api/src/main/java/org/apache/samza/metrics/Reservoir.java	6
samza-api/src/main/java/org/apache/samza/metrics/MetricsAccessor.java	7
samza-api/src/main/java/org/apache/samza/metrics/MetricsValidator.java	7
samza-api/src/main/java/org/apache/samza/metrics/Snapshot.java	54
samza-api/src/main/java/org/apache/samza/metrics/SlidingTimeWindowReservoir.java	75
samza-api/src/main/java/org/apache/samza/metrics/Timer.java	34
samza-api/src/main/java/org/apache/samza/metrics/SamzaHistogram.java	52
samza-api/src/main/java/org/apache/samza/system/SystemConsumer.java	11
samza-api/src/main/java/org/apache/samza/system/StreamValidationException.java	8
samza-api/src/main/java/org/apache/samza/system/SystemStream.java	51
samza-api/src/main/java/org/apache/samza/system/SystemStreamPartitionIterator.java	58
samza-api/src/main/java/org/apache/samza/system/ChangelogSSPIterator.java	34
samza-api/src/main/java/org/apache/samza/system/SystemFactory.java	20
samza-api/src/main/java/org/apache/samza/system/SystemAdmin.java	53
samza-api/src/main/java/org/apache/samza/system/SystemStreamPartitionMatcher.java	6
samza-api/src/main/java/org/apache/samza/system/OutgoingMessageEnvelope.java	101
samza-api/src/main/java/org/apache/samza/system/EndOfStreamMessage.java	12
samza-api/src/main/java/org/apache/samza/system/DrainMessage.java	38
samza-api/src/main/java/org/apache/samza/system/WatermarkMessage.java	41
samza-api/src/main/java/org/apache/samza/system/SystemProducerException.java	14
samza-api/src/main/java/org/apache/samza/system/SystemStreamMetadata.java	130
samza-api/src/main/java/org/apache/samza/system/ControlMessage.java	43
samza-api/src/main/java/org/apache/samza/system/IncomingMessageEnvelope.java	129
samza-api/src/main/java/org/apache/samza/system/descriptors/GenericOutputDescriptor.java	8
samza-api/src/main/java/org/apache/samza/system/descriptors/TransformingInputDescriptorProvider.java	5
samza-api/src/main/java/org/apache/samza/system/descriptors/GenericSystemDescriptor.java	18
samza-api/src/main/java/org/apache/samza/system/descriptors/OutputDescriptorProvider.java	5
samza-api/src/main/java/org/apache/samza/system/descriptors/StreamExpander.java	7
samza-api/src/main/java/org/apache/samza/system/descriptors/SystemDescriptor.java	72
samza-api/src/main/java/org/apache/samza/system/descriptors/StreamDescriptor.java	68
samza-api/src/main/java/org/apache/samza/system/descriptors/InputTransformer.java	8
samza-api/src/main/java/org/apache/samza/system/descriptors/OutputDescriptor.java	8
samza-api/src/main/java/org/apache/samza/system/descriptors/InputDescriptor.java	77
samza-api/src/main/java/org/apache/samza/system/descriptors/GenericInputDescriptor.java	8
samza-api/src/main/java/org/apache/samza/system/descriptors/SimpleInputDescriptorProvider.java	5
samza-api/src/main/java/org/apache/samza/system/descriptors/ExpandingInputDescriptorProvider.java	5
samza-api/src/main/java/org/apache/samza/system/StreamSpec.java	114
samza-api/src/main/java/org/apache/samza/system/SystemStreamPartition.java	101
samza-api/src/main/java/org/apache/samza/system/chooser/MessageChooserFactory.java	6
samza-api/src/main/java/org/apache/samza/system/chooser/BaseMessageChooser.java	13
samza-api/src/main/java/org/apache/samza/system/chooser/MessageChooser.java	10
samza-api/src/main/java/org/apache/samza/system/SystemProducer.java	8
samza-api/src/main/java/org/apache/samza/system/BoundedSSPIterator.java	51
samza-api/src/main/java/org/apache/samza/system/MessageType.java	18
samza-api/src/main/java/org/apache/samza/Partition.java	40
samza-api/src/main/java/org/apache/samza/job/model/ContainerModel.java	48
samza-api/src/main/java/org/apache/samza/job/model/TaskMode.java	12
samza-api/src/main/java/org/apache/samza/job/model/LocalityModel.java	31
samza-api/src/main/java/org/apache/samza/job/model/JobModel.java	62
samza-api/src/main/java/org/apache/samza/job/model/TaskModel.java	73
samza-api/src/main/java/org/apache/samza/job/model/ProcessorLocality.java	47
samza-api/src/main/java/org/apache/samza/job/StreamJob.java	8
samza-api/src/main/java/org/apache/samza/job/CommandBuilder.java	28
samza-api/src/main/java/org/apache/samza/job/JobMetadataChange.java	6
samza-api/src/main/java/org/apache/samza/job/StreamJobFactory.java	5
samza-api/src/main/java/org/apache/samza/job/ApplicationStatus.java	50
samza-api/src/main/java/org/apache/samza/job/JobCoordinatorMetadata.java	49
samza-api/src/main/java/org/apache/samza/metadatastore/MetadataStore.java	18
samza-api/src/main/java/org/apache/samza/metadatastore/MetadataStoreFactory.java	6
samza-api/src/main/java/org/apache/samza/metadatastore/InMemoryMetadataStoreFactory.java	12
samza-api/src/main/java/org/apache/samza/metadatastore/InMemoryMetadataStore.java	29
samza-api/src/main/java/org/apache/samza/sql/udfs/SamzaSqlUdfMethod.java	13
samza-api/src/main/java/org/apache/samza/sql/udfs/ScalarUdf.java	6
samza-api/src/main/java/org/apache/samza/sql/udfs/SamzaSqlUdf.java	12
samza-api/src/main/java/org/apache/samza/sql/schema/SqlSchema.java	52
samza-api/src/main/java/org/apache/samza/sql/schema/SqlFieldSchema.java	54
samza-api/src/main/java/org/apache/samza/sql/schema/SqlSchemaBuilder.java	22
samza-api/src/main/java/org/apache/samza/sql/schema/SamzaSqlFieldType.java	19
samza-api/src/main/java/org/apache/samza/sql/SamzaSqlRelRecord.java	67
samza-api/src/main/java/org/apache/samza/runtime/ProcessorContext.java	5
samza-api/src/main/java/org/apache/samza/runtime/LocationIdProviderFactory.java	5
samza-api/src/main/java/org/apache/samza/runtime/LocationId.java	29
samza-api/src/main/java/org/apache/samza/runtime/ApplicationRunner.java	16
samza-api/src/main/java/org/apache/samza/runtime/ProcessorLifecycleListener.java	9
samza-api/src/main/java/org/apache/samza/runtime/LocationIdProvider.java	4
samza-api/src/main/java/org/apache/samza/runtime/ProcessorLifecycleListenerFactory.java	8
samza-api/src/main/java/org/apache/samza/runtime/ProcessorIdGenerator.java	7
samza-api/src/main/java/org/apache/samza/serializers/LongSerde.java	20
samza-api/src/main/java/org/apache/samza/serializers/DoubleSerde.java	20
samza-api/src/main/java/org/apache/samza/serializers/StringSerde.java	36
samza-api/src/main/java/org/apache/samza/serializers/Serializer.java	4
samza-api/src/main/java/org/apache/samza/serializers/KVSerde.java	53
samza-api/src/main/java/org/apache/samza/serializers/Serde.java	4
samza-api/src/main/java/org/apache/samza/serializers/DoubleSerdeFactory.java	8
samza-api/src/main/java/org/apache/samza/serializers/JsonSerdeV2Factory.java	8
samza-api/src/main/java/org/apache/samza/serializers/UUIDSerde.java	25
samza-api/src/main/java/org/apache/samza/serializers/IntegerSerdeFactory.java	8
samza-api/src/main/java/org/apache/samza/serializers/Deserializer.java	4
samza-api/src/main/java/org/apache/samza/serializers/SerdeFactory.java	5
samza-api/src/main/java/org/apache/samza/serializers/ByteSerde.java	11
samza-api/src/main/java/org/apache/samza/serializers/UUIDSerdeFactory.java	9
samza-api/src/main/java/org/apache/samza/serializers/StringSerdeFactory.java	8
samza-api/src/main/java/org/apache/samza/serializers/JsonSerdeV2.java	63
samza-api/src/main/java/org/apache/samza/serializers/SerializableSerde.java	57
samza-api/src/main/java/org/apache/samza/serializers/LongSerdeFactory.java	8
samza-api/src/main/java/org/apache/samza/serializers/ByteBufferSerdeFactory.java	9
samza-api/src/main/java/org/apache/samza/serializers/SerializableSerdeFactory.java	9
samza-api/src/main/java/org/apache/samza/serializers/ByteSerdeFactory.java	8
samza-api/src/main/java/org/apache/samza/serializers/NoOpSerde.java	12
samza-api/src/main/java/org/apache/samza/serializers/ByteBufferSerde.java	22
samza-api/src/main/java/org/apache/samza/serializers/IntegerSerde.java	20
samza-api/src/main/java/org/apache/samza/context/ApplicationTaskContext.java	8
samza-api/src/main/java/org/apache/samza/context/TaskContext.java	23
samza-api/src/main/java/org/apache/samza/context/ApplicationContainerContext.java	7
samza-api/src/main/java/org/apache/samza/context/JobContext.java	9
samza-api/src/main/java/org/apache/samza/context/ExternalContext.java	3
samza-api/src/main/java/org/apache/samza/context/ApplicationContainerContextFactory.java	15
samza-api/src/main/java/org/apache/samza/context/ApplicationTaskContextFactory.java	17
samza-api/src/main/java/org/apache/samza/context/Context.java	11
samza-api/src/main/java/org/apache/samza/context/ContainerContext.java	10
samza-api/src/main/java/org/apache/samza/table/batching/Batch.java	18
samza-api/src/main/java/org/apache/samza/table/batching/Operation.java	7
samza-api/src/main/java/org/apache/samza/table/batching/BatchProvider.java	23
samza-api/src/main/java/org/apache/samza/table/retry/TableRetryPolicy.java	109
samza-api/src/main/java/org/apache/samza/table/TableProvider.java	9
samza-api/src/main/java/org/apache/samza/table/utils/SerdeUtils.java	57
samza-api/src/main/java/org/apache/samza/table/TableProviderFactory.java	6
samza-api/src/main/java/org/apache/samza/table/RecordNotFoundException.java	16
samza-api/src/main/java/org/apache/samza/table/ReadWriteTable.java	27
samza-api/src/main/java/org/apache/samza/table/AsyncReadWriteUpdateTable.java	27
samza-api/src/main/java/org/apache/samza/table/Table.java	14
samza-api/src/main/java/org/apache/samza/table/ReadWriteUpdateTable.java	23
samza-api/src/main/java/org/apache/samza/table/descriptors/TableDescriptor.java	17
samza-api/src/main/java/org/apache/samza/table/descriptors/GuavaCacheTableDescriptor.java	34
samza-api/src/main/java/org/apache/samza/table/descriptors/CachingTableDescriptor.java	89
samza-api/src/main/java/org/apache/samza/table/descriptors/RemoteTableDescriptor.java	200
samza-api/src/main/java/org/apache/samza/table/descriptors/LocalTableDescriptor.java	108
samza-api/src/main/java/org/apache/samza/table/descriptors/BaseTableDescriptor.java	39
samza-api/src/main/java/org/apache/samza/table/descriptors/HybridTableDescriptor.java	9
samza-api/src/main/java/org/apache/samza/table/remote/TablePart.java	11
samza-api/src/main/java/org/apache/samza/table/remote/TableFunction.java	11
samza-api/src/main/java/org/apache/samza/table/remote/TableWriteFunction.java	79
samza-api/src/main/java/org/apache/samza/table/remote/TableReadFunction.java	46
samza-api/src/main/java/org/apache/samza/table/remote/TableRateLimiter.java	78
samza-api/src/main/java/org/apache/samza/table/remote/BaseTableFunction.java	13
samza-api/src/main/java/org/apache/samza/operators/KV.java	44
samza-api/src/main/java/org/apache/samza/operators/OutputStream.java	5
samza-api/src/main/java/org/apache/samza/operators/functions/FoldLeftFunction.java	8
samza-api/src/main/java/org/apache/samza/operators/functions/SinkFunction.java	10
samza-api/src/main/java/org/apache/samza/operators/functions/SupplierFunction.java	8
samza-api/src/main/java/org/apache/samza/operators/functions/StreamTableJoinFunction.java	9
samza-api/src/main/java/org/apache/samza/operators/functions/FlatMapFunction.java	9
samza-api/src/main/java/org/apache/samza/operators/functions/JoinFunction.java	9
samza-api/src/main/java/org/apache/samza/operators/functions/ScheduledFunction.java	7
samza-api/src/main/java/org/apache/samza/operators/functions/FilterFunction.java	8
samza-api/src/main/java/org/apache/samza/operators/functions/WatermarkFunction.java	6
samza-api/src/main/java/org/apache/samza/operators/functions/MapFunction.java	8
samza-api/src/main/java/org/apache/samza/operators/functions/AsyncFlatMapFunction.java	11
samza-api/src/main/java/org/apache/samza/operators/functions/InitableFunction.java	7
samza-api/src/main/java/org/apache/samza/operators/functions/ClosableFunction.java	6
samza-api/src/main/java/org/apache/samza/operators/Scheduler.java	5
samza-api/src/main/java/org/apache/samza/operators/MessageStream.java	48
samza-api/src/main/java/org/apache/samza/operators/UpdateOptions.java	5
samza-api/src/main/java/org/apache/samza/operators/windows/Window.java	10
samza-api/src/main/java/org/apache/samza/operators/windows/WindowKey.java	37
samza-api/src/main/java/org/apache/samza/operators/windows/AccumulationMode.java	4
samza-api/src/main/java/org/apache/samza/operators/windows/WindowPane.java	23
samza-api/src/main/java/org/apache/samza/operators/windows/internal/WindowType.java	4
samza-api/src/main/java/org/apache/samza/operators/windows/internal/WindowInternal.java	106
samza-api/src/main/java/org/apache/samza/operators/windows/Windows.java	54
samza-api/src/main/java/org/apache/samza/operators/triggers/CountTrigger.java	10
samza-api/src/main/java/org/apache/samza/operators/triggers/RepeatingTrigger.java	10
samza-api/src/main/java/org/apache/samza/operators/triggers/DurationCharacteristic.java	4
samza-api/src/main/java/org/apache/samza/operators/triggers/Trigger.java	6
samza-api/src/main/java/org/apache/samza/operators/triggers/FiringType.java	6
samza-api/src/main/java/org/apache/samza/operators/triggers/Triggers.java	29
samza-api/src/main/java/org/apache/samza/operators/triggers/TimeSinceFirstMessageTrigger.java	16
samza-api/src/main/java/org/apache/samza/operators/triggers/TimeTrigger.java	16
samza-api/src/main/java/org/apache/samza/operators/triggers/TimeBasedTrigger.java	7
samza-api/src/main/java/org/apache/samza/operators/triggers/TimeSinceLastMessageTrigger.java	16
samza-api/src/main/java/org/apache/samza/operators/triggers/AnyTrigger.java	14
samza-api/src/main/java/org/apache/samza/operators/UpdateMessage.java	50
samza-api/src/main/java/org/apache/samza/drain/DrainMode.java	4
samza-api/src/main/java/org/apache/samza/drain/DrainNotification.java	55
samza-api/src/main/java/org/apache/samza/annotation/InterfaceStability.java	16
samza-api/src/main/java/org/apache/samza/config/ConfigFactory.java	5
samza-api/src/main/java/org/apache/samza/config/ConfigException.java	14
samza-api/src/main/java/org/apache/samza/config/ConfigLoaderFactory.java	5
samza-api/src/main/java/org/apache/samza/config/MapConfig.java	101
samza-api/src/main/java/org/apache/samza/config/JavaTableConfig.java	43
samza-api/src/main/java/org/apache/samza/config/ConfigRewriter.java	4
samza-api/src/main/java/org/apache/samza/config/ConfigLoader.java	4
samza-api/src/main/java/org/apache/samza/config/Config.java	196
samza-api/src/main/java/org/apache/samza/scheduler/ScheduledCallback.java	6
samza-api/src/main/java/org/apache/samza/scheduler/CallbackScheduler.java	5
samza-api/src/main/java/org/apache/samza/startpoint/StartpointTimestamp.java	48
samza-api/src/main/java/org/apache/samza/startpoint/StartpointUpcoming.java	15
samza-api/src/main/java/org/apache/samza/startpoint/StartpointSpecific.java	42
samza-api/src/main/java/org/apache/samza/startpoint/StartpointVisitor.java	18
samza-api/src/main/java/org/apache/samza/startpoint/StartpointOldest.java	15
samza-api/src/main/java/org/apache/samza/startpoint/Startpoint.java	40
samza-api/src/main/java/org/apache/samza/util/Clock.java	4
samza-api/src/main/java/org/apache/samza/util/BlockingEnvelopeMap.java	208
samza-api/src/main/java/org/apache/samza/util/NoOpMetricsRegistry.java	31
samza-api/src/main/java/org/apache/samza/util/RateLimiter.java	16
samza-api/src/main/java/org/apache/samza/util/SinglePartitionWithoutOffsetsSystemAdmin.java	35
samza-api/src/main/java/org/apache/samza/util/TimestampedValue.java	29
samza-api/src/main/java/org/apache/samza/task/TaskCallback.java	5
samza-api/src/main/java/org/apache/samza/task/StreamTask.java	5
samza-api/src/main/java/org/apache/samza/task/DrainListenerTask.java	4
samza-api/src/main/java/org/apache/samza/task/InitableTask.java	5
samza-api/src/main/java/org/apache/samza/task/WindowableTask.java	4
samza-api/src/main/java/org/apache/samza/task/EndOfStreamListenerTask.java	4
samza-api/src/main/java/org/apache/samza/task/TaskFactory.java	7
samza-api/src/main/java/org/apache/samza/task/TaskCoordinator.java	9
samza-api/src/main/java/org/apache/samza/task/AsyncStreamTaskFactory.java	5
samza-api/src/main/java/org/apache/samza/task/StreamOperatorTaskFactory.java	4
samza-api/src/main/java/org/apache/samza/task/TaskExecutorFactory.java	12
samza-api/src/main/java/org/apache/samza/task/MessageCollector.java	5
samza-api/src/main/java/org/apache/samza/task/AsyncStreamTask.java	5
samza-api/src/main/java/org/apache/samza/task/StreamTaskFactory.java	5
samza-api/src/main/java/org/apache/samza/task/ClosableTask.java	7
samza-api/src/main/java/org/apache/samza/container/grouper/stream/SystemStreamPartitionGrouper.java	8
samza-api/src/main/java/org/apache/samza/container/grouper/stream/SystemStreamPartitionMapper.java	6
samza-api/src/main/java/org/apache/samza/container/grouper/stream/SystemStreamPartitionMapperFactory.java	6
samza-api/src/main/java/org/apache/samza/container/grouper/stream/SystemStreamPartitionGrouperFactory.java	5
samza-api/src/main/java/org/apache/samza/container/TaskName.java	30
samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementMessage.java	76
samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementResponseMessage.java	58
samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementRequestMessage.java	26
samza-api/src/main/java/org/apache/samza/SamzaException.java	16
samza-api/src/main/java/org/apache/samza/coordinator/lifecycle/JobRestartSignal.java	4
samza-api/src/main/java/org/apache/samza/coordinator/lifecycle/JobRestartSignalFactoryContext.java	11
samza-api/src/main/java/org/apache/samza/coordinator/lifecycle/JobRestartSignalFactory.java	4
samza-api/src/main/java/org/apache/samza/application/SamzaApplication.java	10
samza-api/src/main/java/org/apache/samza/application/ApplicationApiType.java	6
samza-api/src/main/java/org/apache/samza/application/StreamApplication.java	19
samza-api/src/main/java/org/apache/samza/application/TaskApplication.java	14
samza-api/src/main/java/org/apache/samza/application/descriptors/StreamApplicationDescriptor.java	16
samza-api/src/main/java/org/apache/samza/application/descriptors/ApplicationDescriptor.java	27
samza-api/src/main/java/org/apache/samza/application/descriptors/TaskApplicationDescriptor.java	19
samza-api/src/main/java/org/apache/samza/storage/SideInputsProcessorFactory.java	10
samza-api/src/main/java/org/apache/samza/storage/BlobStoreAdminFactory.java	6
samza-api/src/main/java/org/apache/samza/storage/blobstore/BlobStoreManager.java	14
samza-api/src/main/java/org/apache/samza/storage/blobstore/exceptions/RetriableException.java	15
samza-api/src/main/java/org/apache/samza/storage/blobstore/exceptions/DeletedException.java	15
samza-api/src/main/java/org/apache/samza/storage/blobstore/Metadata.java	73
samza-api/src/main/java/org/apache/samza/storage/blobstore/BlobStoreManagerFactory.java	9
samza-api/src/main/java/org/apache/samza/storage/StorageEngine.java	16
samza-api/src/main/java/org/apache/samza/storage/SideInputsProcessor.java	12
samza-api/src/main/java/org/apache/samza/storage/TaskRestoreManager.java	8
samza-api/src/main/java/org/apache/samza/storage/StoreProperties.java	43
samza-api/src/main/java/org/apache/samza/storage/StorageEngineFactory.java	27
samza-api/src/main/java/org/apache/samza/storage/StateBackendFactory.java	38
samza-api/src/main/java/org/apache/samza/storage/KafkaChangelogRestoreParams.java	46
samza-api/src/main/java/org/apache/samza/storage/StateBackendAdmin.java	5
samza-api/src/main/java/org/apache/samza/storage/kv/ClosableIterator.java	5
samza-api/src/main/java/org/apache/samza/storage/kv/Entry.java	15
samza-api/src/main/java/org/apache/samza/storage/kv/KeyValueStore.java	44
samza-api/src/main/java/org/apache/samza/storage/kv/KeyValueIterator.java	5
samza-api/src/main/java/org/apache/samza/storage/kv/KeyValueSnapshot.java	5
samza-api/src/main/java/org/apache/samza/storage/TaskBackupManager.java	13
samza-api/src/main/java/org/apache/samza/checkpoint/Checkpoint.java	7
samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointId.java	59
samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointManager.java	11
samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointManagerFactory.java	6
samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV2.java	59
samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointListener.java	13
samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV1.java	39
samza-test/src/main/java/org/apache/samza/system/mock/MockSystemAdmin.java	38
samza-test/src/main/java/org/apache/samza/system/mock/MockSystemFactory.java	47
samza-test/src/main/java/org/apache/samza/system/mock/MockSystemConsumer.java	90
samza-test/src/main/java/org/apache/samza/example/AppWithGlobalConfigExample.java	54
samza-test/src/main/java/org/apache/samza/example/WindowExample.java	48
samza-test/src/main/java/org/apache/samza/example/KeyValueStoreExample.java	96
samza-test/src/main/java/org/apache/samza/example/AsyncApplicationExample.java	86
samza-test/src/main/java/org/apache/samza/example/models/PageViewEvent.java	20
samza-test/src/main/java/org/apache/samza/example/models/PageViewCount.java	20
samza-test/src/main/java/org/apache/samza/example/models/EnrichedAdClickEvent.java	20
samza-test/src/main/java/org/apache/samza/example/models/Member.java	20
samza-test/src/main/java/org/apache/samza/example/models/AdClickEvent.java	15
samza-test/src/main/java/org/apache/samza/example/OrderShipmentJoinExample.java	82
samza-test/src/main/java/org/apache/samza/example/RepartitionExample.java	58
samza-test/src/main/java/org/apache/samza/example/TaskApplicationExample.java	48
samza-test/src/main/java/org/apache/samza/example/PageViewCounterExample.java	60
samza-test/src/main/java/org/apache/samza/example/BroadcastExample.java	42
samza-test/src/main/java/org/apache/samza/example/MergeExample.java	42
samza-test/src/main/python/samza_job_yarn_deployer.py	154
samza-test/src/main/python/standalone_deployment.py	65
samza-test/src/main/python/deployment.py	64
samza-test/src/main/python/templates/yarn-site.xml	9
samza-test/src/main/python/templates.py	7
samza-test/src/main/python/perf.py	26
samza-test/src/main/python/samza_failure_testing.py	120
samza-test/src/main/python/stream_processor.py	62
samza-test/src/main/resources/log4j2.xml	17
samza-kv-couchbase/src/main/java/org/apache/samza/table/remote/couchbase/CouchbaseTableWriteFunction.java	75
samza-kv-couchbase/src/main/java/org/apache/samza/table/remote/couchbase/CouchbaseBucketRegistry.java	114
samza-kv-couchbase/src/main/java/org/apache/samza/table/remote/couchbase/BaseCouchbaseTableFunction.java	117
samza-kv-couchbase/src/main/java/org/apache/samza/table/remote/couchbase/CouchbaseEnvironmentConfigs.java	16
samza-kv-couchbase/src/main/java/org/apache/samza/table/remote/couchbase/CouchbaseTableReadFunction.java	82
samza-hdfs/src/main/scala/org/apache/samza/system/hdfs/HdfsSystemFactory.scala	30
samza-hdfs/src/main/scala/org/apache/samza/system/hdfs/HdfsSystemProducer.scala	73
samza-hdfs/src/main/scala/org/apache/samza/system/hdfs/writer/TextSequenceFileHdfsWriter.scala	18
samza-hdfs/src/main/scala/org/apache/samza/system/hdfs/writer/Bucketer.scala	16
samza-hdfs/src/main/scala/org/apache/samza/system/hdfs/writer/HdfsWriter.scala	20
samza-hdfs/src/main/scala/org/apache/samza/system/hdfs/writer/SequenceFileHdfsWriter.scala	61
samza-hdfs/src/main/scala/org/apache/samza/system/hdfs/writer/AvroDataFileHdfsWriter.scala	49
samza-hdfs/src/main/scala/org/apache/samza/system/hdfs/writer/BinarySequenceFileHdfsWriter.scala	18
samza-hdfs/src/main/scala/org/apache/samza/system/hdfs/writer/JobNameDateTimeBucketer.scala	30
samza-hdfs/src/main/scala/org/apache/samza/system/hdfs/HdfsSystemProducerMetrics.scala	13
samza-hdfs/src/main/scala/org/apache/samza/system/hdfs/HdfsConfig.scala	83
samza-hdfs/src/main/java/org/apache/samza/system/hdfs/HdfsSystemConsumer.java	180
samza-hdfs/src/main/java/org/apache/samza/system/hdfs/partitioner/DirectoryPartitioner.java	135
samza-hdfs/src/main/java/org/apache/samza/system/hdfs/partitioner/HdfsFileSystemAdapter.java	33
samza-hdfs/src/main/java/org/apache/samza/system/hdfs/partitioner/FileSystemAdapter.java	23
samza-hdfs/src/main/java/org/apache/samza/system/hdfs/PartitionDescriptorUtil.java	57
samza-hdfs/src/main/java/org/apache/samza/system/hdfs/reader/AvroFileHdfsReader.java	143
samza-hdfs/src/main/java/org/apache/samza/system/hdfs/reader/HdfsReaderFactory.java	29
samza-hdfs/src/main/java/org/apache/samza/system/hdfs/reader/SingleFileHdfsReader.java	10
samza-hdfs/src/main/java/org/apache/samza/system/hdfs/reader/MultiFileHdfsReader.java	120
samza-hdfs/src/main/java/org/apache/samza/system/hdfs/HdfsSystemAdmin.java	133
samza-hdfs/src/main/java/org/apache/samza/system/hdfs/descriptors/HdfsInputDescriptor.java	10
samza-hdfs/src/main/java/org/apache/samza/system/hdfs/descriptors/HdfsSystemDescriptor.java	112
samza-hdfs/src/main/java/org/apache/samza/system/hdfs/descriptors/HdfsOutputDescriptor.java	10
samza-elasticsearch/src/main/java/org/apache/samza/system/elasticsearch/indexrequest/DefaultIndexRequestFactory.java	51
samza-elasticsearch/src/main/java/org/apache/samza/system/elasticsearch/indexrequest/IndexRequestFactory.java	6
samza-elasticsearch/src/main/java/org/apache/samza/system/elasticsearch/ElasticsearchSystemProducerMetrics.java	17
samza-elasticsearch/src/main/java/org/apache/samza/system/elasticsearch/ElasticsearchSystemFactory.java	54
samza-elasticsearch/src/main/java/org/apache/samza/system/elasticsearch/ElasticsearchSystemAdmin.java	27
samza-elasticsearch/src/main/java/org/apache/samza/system/elasticsearch/client/ClientFactory.java	5
samza-elasticsearch/src/main/java/org/apache/samza/system/elasticsearch/client/TransportClientFactory.java	30
samza-elasticsearch/src/main/java/org/apache/samza/system/elasticsearch/client/NodeClientFactory.java	24
samza-elasticsearch/src/main/java/org/apache/samza/system/elasticsearch/BulkProcessorFactory.java	25
samza-elasticsearch/src/main/java/org/apache/samza/system/elasticsearch/ElasticsearchSystemProducer.java	134
samza-elasticsearch/src/main/java/org/apache/samza/config/ElasticsearchConfig.java	79
samza-rest/src/main/java/org/apache/samza/monitor/MonitorFactory.java	6
samza-rest/src/main/java/org/apache/samza/monitor/JobsClient.java	70
samza-rest/src/main/java/org/apache/samza/monitor/LocalStoreMonitor.java	103
samza-rest/src/main/java/org/apache/samza/monitor/Monitor.java	4
samza-rest/src/main/java/org/apache/samza/monitor/MonitorConfig.java	49
samza-rest/src/main/java/org/apache/samza/monitor/MonitorLoader.java	16
samza-rest/src/main/java/org/apache/samza/monitor/SamzaMonitorService.java	86
samza-rest/src/main/java/org/apache/samza/monitor/LocalStoreMonitorFactory.java	11
samza-rest/src/main/java/org/apache/samza/monitor/LocalStoreMonitorConfig.java	29
samza-rest/src/main/java/org/apache/samza/monitor/LocalStoreMonitorMetrics.java	15
samza-rest/src/main/java/org/apache/samza/rest/model/Partition.java	64
samza-rest/src/main/java/org/apache/samza/rest/model/Task.java	89
samza-rest/src/main/java/org/apache/samza/rest/model/JobStatus.java	18
samza-rest/src/main/java/org/apache/samza/rest/model/yarn/YarnApplicationInfo.java	41
samza-rest/src/main/java/org/apache/samza/rest/model/Job.java	44
samza-rest/src/main/java/org/apache/samza/rest/resources/Responses.java	13
samza-rest/src/main/java/org/apache/samza/rest/resources/ResourceFactory.java	6
samza-rest/src/main/java/org/apache/samza/rest/resources/DefaultResourceFactory.java	12
samza-rest/src/main/java/org/apache/samza/rest/resources/BaseResourceConfig.java	31
samza-rest/src/main/java/org/apache/samza/rest/resources/TasksResource.java	53
samza-rest/src/main/java/org/apache/samza/rest/resources/ResourceConstants.java	5
samza-rest/src/main/java/org/apache/samza/rest/resources/JobsResource.java	95
samza-rest/src/main/java/org/apache/samza/rest/resources/YarnJobResourceConfig.java	15
samza-rest/src/main/java/org/apache/samza/rest/resources/JobsResourceConfig.java	11
samza-rest/src/main/java/org/apache/samza/rest/script/ScriptRunner.java	78
samza-rest/src/main/java/org/apache/samza/rest/script/ScriptPathProvider.java	7
samza-rest/src/main/java/org/apache/samza/rest/script/ScriptOutputHandler.java	7
samza-rest/src/main/java/org/apache/samza/rest/proxy/job/JobProxyFactory.java	5
samza-rest/src/main/java/org/apache/samza/rest/proxy/job/SimpleYarnJobProxyFactory.java	17
samza-rest/src/main/java/org/apache/samza/rest/proxy/job/AbstractJobProxy.java	59
samza-rest/src/main/java/org/apache/samza/rest/proxy/job/JobInstance.java	34
samza-rest/src/main/java/org/apache/samza/rest/proxy/job/JobProxy.java	15
samza-rest/src/main/java/org/apache/samza/rest/proxy/job/JobStatusProvider.java	10
samza-rest/src/main/java/org/apache/samza/rest/proxy/job/ScriptJobProxy.java	28
samza-rest/src/main/java/org/apache/samza/rest/proxy/job/SimpleYarnJobProxy.java	71
samza-rest/src/main/java/org/apache/samza/rest/proxy/job/YarnRestJobStatusProvider.java	99
samza-rest/src/main/java/org/apache/samza/rest/proxy/task/TaskResourceConfig.java	12
samza-rest/src/main/java/org/apache/samza/rest/proxy/task/SamzaTaskProxy.java	101
samza-rest/src/main/java/org/apache/samza/rest/proxy/task/SamzaTaskProxyFactory.java	29
samza-rest/src/main/java/org/apache/samza/rest/proxy/task/TaskProxyFactory.java	4
samza-rest/src/main/java/org/apache/samza/rest/proxy/task/TaskProxy.java	9
samza-rest/src/main/java/org/apache/samza/rest/proxy/installation/InstallationFinder.java	7
samza-rest/src/main/java/org/apache/samza/rest/proxy/installation/InstallationRecord.java	26
samza-rest/src/main/java/org/apache/samza/rest/proxy/installation/SimpleInstallationFinder.java	72
samza-rest/src/main/java/org/apache/samza/rest/SamzaRestConfig.java	29
samza-rest/src/main/java/org/apache/samza/rest/SamzaRestService.java	112
samza-rest/src/main/java/org/apache/samza/rest/SamzaRestApplication.java	47
samza-rest/src/main/resources/log4j.xml	19
samza-rest/src/main/resources/log4j2.xml	19
doap_Samza.rdf	41
samza-kv-inmemory/src/main/java/org/apache/samza/storage/kv/inmemory/InMemoryKeyValueStore.java	122
samza-kv-inmemory/src/main/java/org/apache/samza/storage/kv/inmemory/InMemoryKeyValueStorageEngineFactory.java	20
samza-kv-inmemory/src/main/java/org/apache/samza/storage/kv/inmemory/descriptors/InMemoryTableDescriptor.java	26
samza-kv/src/main/scala/org/apache/samza/storage/kv/KeyValueStorageEngineMetrics.scala	35
samza-kv/src/main/scala/org/apache/samza/storage/kv/LoggedStoreMetrics.scala	15
samza-kv/src/main/scala/org/apache/samza/storage/kv/AccessLoggedStore.scala	128
samza-kv/src/main/scala/org/apache/samza/storage/kv/KeyValueStoreMetrics.scala	18
samza-kv/src/main/scala/org/apache/samza/storage/kv/LargeMessageSafeStoreMetrics.scala	8
samza-kv/src/main/scala/org/apache/samza/storage/kv/SerializedKeyValueStore.scala	159
samza-kv/src/main/scala/org/apache/samza/storage/kv/LoggedStore.scala	79
samza-kv/src/main/scala/org/apache/samza/storage/kv/CachedStore.scala	200
samza-kv/src/main/scala/org/apache/samza/storage/kv/SerializedKeyValueStoreMetrics.scala	21
samza-kv/src/main/scala/org/apache/samza/storage/kv/AccessLogMessage.scala	20
samza-kv/src/main/scala/org/apache/samza/storage/kv/NullSafeKeyValueStore.scala	75
samza-kv/src/main/scala/org/apache/samza/storage/kv/CachedStoreMetrics.scala	23
samza-kv/src/main/scala/org/apache/samza/storage/kv/KeyValueStorageEngine.scala	192
samza-kv/src/main/java/org/apache/samza/storage/kv/LocalTable.java	179
samza-kv/src/main/java/org/apache/samza/storage/kv/BaseKeyValueStorageEngineFactory.java	166
samza-kv/src/main/java/org/apache/samza/storage/kv/RecordTooLargeException.java	7
samza-kv/src/main/java/org/apache/samza/storage/kv/LargeMessageSafeStore.java	106
samza-kv/src/main/java/org/apache/samza/storage/kv/LocalTableProviderFactory.java	9
samza-kv/src/main/java/org/apache/samza/storage/kv/LocalTableProvider.java	29
samza-core/src/main/scala/org/apache/samza/metrics/MetricsHelper.scala	17
samza-core/src/main/scala/org/apache/samza/metrics/ContainerProcessManagerMetrics.scala	40
samza-core/src/main/scala/org/apache/samza/metrics/reporter/JmxReporter.scala	91
samza-core/src/main/scala/org/apache/samza/metrics/JmxServer.scala	65
samza-core/src/main/scala/org/apache/samza/metrics/MetricsRegistryMap.scala	55
samza-core/src/main/scala/org/apache/samza/metrics/JvmMetrics.scala	131
samza-core/src/main/scala/org/apache/samza/system/SystemConsumers.scala	282
samza-core/src/main/scala/org/apache/samza/system/SSPMetadataCache.java	73
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/RangeSystemStreamPartitionMatcher.scala	26
samza-core/src/main/scala/org/apache/samza/system/filereader/FileReaderSystemConsumer.scala	84
samza-core/src/main/scala/org/apache/samza/system/filereader/FileReaderSystemAdmin.scala	86
samza-core/src/main/scala/org/apache/samza/system/filereader/FileReaderSystemFactory.scala	18
samza-core/src/main/scala/org/apache/samza/system/RegexSystemStreamPartitionMatcher.scala	11
samza-core/src/main/scala/org/apache/samza/system/StreamMetadataCache.scala	61
samza-core/src/main/scala/org/apache/samza/system/chooser/DefaultChooser.scala	94
samza-core/src/main/scala/org/apache/samza/system/chooser/TieredPriorityChooser.scala	74
samza-core/src/main/scala/org/apache/samza/system/chooser/BootstrappingChooser.scala	143
samza-core/src/main/scala/org/apache/samza/system/chooser/RoundRobinChooser.scala	28
samza-core/src/main/scala/org/apache/samza/system/chooser/BatchingChooser.scala	66
samza-core/src/main/scala/org/apache/samza/job/local/ProcessJobFactory.scala	69
samza-core/src/main/scala/org/apache/samza/job/local/ProcessJob.scala	100
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/job/JobRunner.scala	71
samza-core/src/main/scala/org/apache/samza/serializers/MetricsSnapshotSerdeV2.java	44
samza-core/src/main/scala/org/apache/samza/serializers/SerdeManager.scala	105
samza-core/src/main/scala/org/apache/samza/serializers/MetricsSnapshotSerdeV2Factory.java	9
samza-core/src/main/scala/org/apache/samza/serializers/JsonSerde.scala	30
samza-core/src/main/scala/org/apache/samza/serializers/CheckpointV1Serde.scala	47
samza-core/src/main/scala/org/apache/samza/serializers/MetricsSnapshotSerde.scala	17
samza-core/src/main/scala/org/apache/samza/config/RegExTopicGenerator.scala	61
samza-core/src/main/scala/org/apache/samza/config/factories/PropertiesConfigFactory.scala	25
samza-core/src/main/scala/org/apache/samza/config/ScalaMapConfig.scala	21
samza-core/src/main/scala/org/apache/samza/util/HttpUtil.scala	52
samza-core/src/main/scala/org/apache/samza/util/FileUtil.scala	110
samza-core/src/main/scala/org/apache/samza/util/ScalaJavaUtil.scala	43
samza-core/src/main/scala/org/apache/samza/util/TimerUtil.scala	18
samza-core/src/main/scala/org/apache/samza/util/CoordinatorStreamUtil.scala	141
samza-core/src/main/scala/org/apache/samza/util/CommandLine.scala	23
samza-core/src/main/scala/org/apache/samza/util/Logging.scala	65
samza-core/src/main/scala/org/apache/samza/util/ExponentialSleepStrategy.scala	80
samza-core/src/main/scala/org/apache/samza/util/DefaultCoordinatorStreamConfigFactory.java	24
samza-core/src/main/scala/org/apache/samza/util/CoordinatorStreamConfigFactory.java	5
samza-core/src/main/scala/org/apache/samza/diagnostics/ProcessorStopEvent.java	33
samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsManager.java	205
samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsExceptionEvent.java	53
samza-core/src/main/scala/org/apache/samza/diagnostics/BoundedList.java	67
samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsStreamMessage.java	200
samza-core/src/main/scala/org/apache/samza/task/TaskInstanceCollector.scala	23
samza-core/src/main/scala/org/apache/samza/task/ReadableCoordinator.scala	13
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/TaskInstanceExceptionHandler.scala	44
samza-core/src/main/scala/org/apache/samza/container/TaskInstanceMetrics.scala	35
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/coordinator/Latch.java	7
samza-core/src/main/scala/org/apache/samza/coordinator/stream/CoordinatorStreamWriterCommandLine.scala	42
samza-core/src/main/scala/org/apache/samza/coordinator/server/JobServlet.scala	14
samza-core/src/main/scala/org/apache/samza/coordinator/server/HttpServer.scala	58
samza-core/src/main/scala/org/apache/samza/coordinator/JobModelManager.scala	63
samza-core/src/main/scala/org/apache/samza/storage/KafkaNonTransactionalStateTaskBackupManager.scala	50
samza-core/src/main/scala/org/apache/samza/storage/SideInputsManager.java	381
samza-core/src/main/scala/org/apache/samza/storage/ContainerStorageManagerUtil.java	318
samza-core/src/main/scala/org/apache/samza/storage/ContainerStorageManagerRestoreUtil.java	284
samza-core/src/main/scala/org/apache/samza/storage/ContainerStorageManager.java	304
samza-core/src/main/scala/org/apache/samza/storage/KafkaTransactionalStateTaskBackupManager.scala	55
samza-core/src/main/scala/org/apache/samza/checkpoint/file/FileSystemCheckpointManager.scala	55
samza-core/src/main/scala/org/apache/samza/checkpoint/OffsetManager.scala	406
samza-core/src/main/scala/org/apache/samza/checkpoint/CheckpointTool.scala	160
samza-core/src/main/scala/org/apache/samza/checkpoint/OffsetManagerMetrics.scala	10
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/BaseServerMetrics.java	11
samza-core/src/main/java/org/apache/samza/metrics/MetricGroup.java	35
samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsHeader.java	138
samza-core/src/main/java/org/apache/samza/metrics/reporter/LoggingMetricsReporter.java	84
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/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/MetricsSnapshot.java	50
samza-core/src/main/java/org/apache/samza/metrics/reporter/Metrics.java	47
samza-core/src/main/java/org/apache/samza/metrics/MetricsBase.java	23
samza-core/src/main/java/org/apache/samza/system/SystemAdmins.java	46
samza-core/src/main/java/org/apache/samza/system/inmemory/InMemorySystemAdmin.java	59
samza-core/src/main/java/org/apache/samza/system/inmemory/InMemorySystemProducer.java	58
samza-core/src/main/java/org/apache/samza/system/inmemory/InMemorySystemFactory.java	28
samza-core/src/main/java/org/apache/samza/system/inmemory/InMemoryManager.java	137
samza-core/src/main/java/org/apache/samza/system/inmemory/InMemorySystemConsumer.java	56
samza-core/src/main/java/org/apache/samza/system/descriptors/DelegatingSystemDescriptor.java	24
samza-core/src/main/java/org/apache/samza/job/model/JobModelUtil.java	93
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/standalone/PassthroughJobCoordinator.java	91
samza-core/src/main/java/org/apache/samza/standalone/PassthroughJobCoordinatorFactory.java	13
samza-core/src/main/java/org/apache/samza/standalone/PassthroughCoordinationUtilsFactory.java	10
samza-core/src/main/java/org/apache/samza/runtime/ApplicationRunners.java	26
samza-core/src/main/java/org/apache/samza/runtime/UUIDGenerator.java	9
samza-core/src/main/java/org/apache/samza/runtime/ApplicationRunnerUtil.java	25
samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.java	389
samza-core/src/main/java/org/apache/samza/runtime/DefaultLocationIdProviderFactory.java	9
samza-core/src/main/java/org/apache/samza/runtime/ApplicationRunnerMain.java	46
samza-core/src/main/java/org/apache/samza/runtime/ContainerLaunchUtil.java	195
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/ClusterBasedProcessorLifecycleListener.java	101
samza-core/src/main/java/org/apache/samza/runtime/ApplicationRunnerOperation.java	15
samza-core/src/main/java/org/apache/samza/serializers/IntermediateMessageSerde.java	83
samza-core/src/main/java/org/apache/samza/serializers/model/JsonJobModelMixIn.java	17
samza-core/src/main/java/org/apache/samza/serializers/model/SamzaObjectMapper.java	237
samza-core/src/main/java/org/apache/samza/serializers/model/KafkaStateCheckpointMarkerMixin.java	20
samza-core/src/main/java/org/apache/samza/serializers/model/JsonProcessorLocalityMixIn.java	19
samza-core/src/main/java/org/apache/samza/serializers/model/JsonCheckpointV2Mixin.java	22
samza-core/src/main/java/org/apache/samza/serializers/model/JsonLocalityModelMixIn.java	14
samza-core/src/main/java/org/apache/samza/serializers/model/JsonContainerModelMixIn.java	14
samza-core/src/main/java/org/apache/samza/serializers/model/JsonTaskModelMixIn.java	20
samza-core/src/main/java/org/apache/samza/serializers/model/JsonJobCoordinatorMetadataMixIn.java	17
samza-core/src/main/java/org/apache/samza/serializers/CheckpointV2Serde.java	25
samza-core/src/main/java/org/apache/samza/serializers/JsonCheckpoint.java	24
samza-core/src/main/java/org/apache/samza/logging/LoggingContextHolder.java	22
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/ProcessorData.java	40
samza-core/src/main/java/org/apache/samza/zk/ZkLeaderElector.java	127
samza-core/src/main/java/org/apache/samza/zk/ZkBarrierListener.java	6
samza-core/src/main/java/org/apache/samza/zk/ZkUtilsMetrics.java	19
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/ZkCoordinationUtils.java	48
samza-core/src/main/java/org/apache/samza/zk/ZkStringSerializer.java	31
samza-core/src/main/java/org/apache/samza/zk/ZkBarrierForVersionUpgrade.java	156
samza-core/src/main/java/org/apache/samza/zk/ZkUtils.java	484
samza-core/src/main/java/org/apache/samza/zk/ZkMetadataStore.java	120
samza-core/src/main/java/org/apache/samza/zk/ZkJobCoordinatorMetrics.java	26
samza-core/src/main/java/org/apache/samza/zk/ZkSessionMetrics.java	19
samza-core/src/main/java/org/apache/samza/zk/ZkCoordinationUtilsFactory.java	46
samza-core/src/main/java/org/apache/samza/zk/ZkClusterMembership.java	46
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/ScheduleAfterDebounceTime.java	103
samza-core/src/main/java/org/apache/samza/context/TaskContextImpl.java	95
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/ContainerContextImpl.java	27
samza-core/src/main/java/org/apache/samza/context/ContextImpl.java	72
samza-core/src/main/java/org/apache/samza/table/batching/CompactBatchProvider.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/TableBatchHandler.java	111
samza-core/src/main/java/org/apache/samza/table/batching/BatchProcessor.java	125
samza-core/src/main/java/org/apache/samza/table/batching/AbstractBatch.java	39
samza-core/src/main/java/org/apache/samza/table/batching/CompleteBatchProvider.java	7
samza-core/src/main/java/org/apache/samza/table/batching/BatchingNotSupportedException.java	15
samza-core/src/main/java/org/apache/samza/table/batching/UpdateOperation.java	28
samza-core/src/main/java/org/apache/samza/table/batching/CompactBatch.java	42
samza-core/src/main/java/org/apache/samza/table/batching/BatchMetrics.java	18
samza-core/src/main/java/org/apache/samza/table/batching/PutOperation.java	30
samza-core/src/main/java/org/apache/samza/table/batching/CompleteBatch.java	30
samza-core/src/main/java/org/apache/samza/table/batching/GetOperation.java	40
samza-core/src/main/java/org/apache/samza/table/batching/BatchHandler.java	5
samza-core/src/main/java/org/apache/samza/table/batching/AsyncBatchingTable.java	120
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/TableManager.java	60
samza-core/src/main/java/org/apache/samza/table/utils/TableMetricsUtil.java	52
samza-core/src/main/java/org/apache/samza/table/utils/TableMetrics.java	56
samza-core/src/main/java/org/apache/samza/table/ratelimit/AsyncRateLimitedTable.java	152
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/BaseReadWriteUpdateTable.java	38
samza-core/src/main/java/org/apache/samza/table/TableConfigGenerator.java	58
samza-core/src/main/java/org/apache/samza/table/caching/SupplierGauge.java	16
samza-core/src/main/java/org/apache/samza/table/caching/CachingTableProviderFactory.java	9
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/GuavaCacheTable.java	175
samza-core/src/main/java/org/apache/samza/table/caching/guava/GuavaCacheTableProviderFactory.java	9
samza-core/src/main/java/org/apache/samza/table/caching/CachingTableProvider.java	61
samza-core/src/main/java/org/apache/samza/table/caching/CachingTable.java	271
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/remote/RemoteTable.java	344
samza-core/src/main/java/org/apache/samza/table/remote/NoOpTableReadFunction.java	13
samza-core/src/main/java/org/apache/samza/table/remote/AsyncRemoteTable.java	98
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/spec/OperatorSpecs.java	77
samza-core/src/main/java/org/apache/samza/operators/spec/WindowOperatorSpec.java	92
samza-core/src/main/java/org/apache/samza/operators/spec/BroadcastOperatorSpec.java	21
samza-core/src/main/java/org/apache/samza/operators/spec/SinkOperatorSpec.java	22
samza-core/src/main/java/org/apache/samza/operators/spec/PartitionByOperatorSpec.java	40
samza-core/src/main/java/org/apache/samza/operators/spec/StatefulOperatorSpec.java	5
samza-core/src/main/java/org/apache/samza/operators/spec/OutputStreamImpl.java	28
samza-core/src/main/java/org/apache/samza/operators/spec/WindowState.java	12
samza-core/src/main/java/org/apache/samza/operators/spec/SendToTableWithUpdateOperatorSpec.java	31
samza-core/src/main/java/org/apache/samza/operators/spec/InputOperatorSpec.java	45
samza-core/src/main/java/org/apache/samza/operators/spec/SendToTableOperatorSpec.java	24
samza-core/src/main/java/org/apache/samza/operators/spec/JoinOperatorSpec.java	77
samza-core/src/main/java/org/apache/samza/operators/spec/OperatorSpec.java	66
samza-core/src/main/java/org/apache/samza/operators/spec/OutputOperatorSpec.java	21
samza-core/src/main/java/org/apache/samza/operators/spec/StreamTableJoinOperatorSpec.java	34
samza-core/src/main/java/org/apache/samza/operators/spec/MapOperatorSpec.java	43
samza-core/src/main/java/org/apache/samza/operators/spec/StreamOperatorSpec.java	12
samza-core/src/main/java/org/apache/samza/operators/spec/FilterOperatorSpec.java	42
samza-core/src/main/java/org/apache/samza/operators/spec/StoreDescriptor.java	48
samza-core/src/main/java/org/apache/samza/operators/spec/FlatMapOperatorSpec.java	17
samza-core/src/main/java/org/apache/samza/operators/spec/AsyncFlatMapOperatorSpec.java	22
samza-core/src/main/java/org/apache/samza/operators/spec/MergeOperatorSpec.java	22
samza-core/src/main/java/org/apache/samza/operators/functions/PartialJoinFunction.java	8
samza-core/src/main/java/org/apache/samza/operators/util/InternalInMemoryStore.java	97
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/TimeSinceLastMessageTriggerImpl.java	47
samza-core/src/main/java/org/apache/samza/operators/triggers/TimeSinceFirstMessageTriggerImpl.java	40
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/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/triggers/TimeTriggerImpl.java	40
samza-core/src/main/java/org/apache/samza/operators/impl/SendToTableWithUpdateOperatorImpl.java	85
samza-core/src/main/java/org/apache/samza/operators/impl/PartitionByOperatorImpl.java	81
samza-core/src/main/java/org/apache/samza/operators/impl/TriggerKey.java	48
samza-core/src/main/java/org/apache/samza/operators/impl/ControlMessageSender.java	52
samza-core/src/main/java/org/apache/samza/operators/impl/WatermarkStates.java	144
samza-core/src/main/java/org/apache/samza/operators/impl/BroadcastOperatorImpl.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/SendToTableOperatorImpl.java	43
samza-core/src/main/java/org/apache/samza/operators/impl/FlatmapOperatorImpl.java	34
samza-core/src/main/java/org/apache/samza/operators/impl/OutputOperatorImpl.java	48
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/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/impl/store/TimeSeriesStore.java	13
samza-core/src/main/java/org/apache/samza/operators/impl/InputOperatorImpl.java	44
samza-core/src/main/java/org/apache/samza/operators/impl/StreamTableJoinOperatorImpl.java	51
samza-core/src/main/java/org/apache/samza/operators/impl/EndOfStreamStates.java	50
samza-core/src/main/java/org/apache/samza/operators/impl/WindowOperatorImpl.java	288
samza-core/src/main/java/org/apache/samza/operators/impl/TriggerScheduler.java	64
samza-core/src/main/java/org/apache/samza/operators/impl/DrainStates.java	60
samza-core/src/main/java/org/apache/samza/operators/impl/SinkOperatorImpl.java	36
samza-core/src/main/java/org/apache/samza/operators/impl/AsyncFlatmapOperatorImpl.java	34
samza-core/src/main/java/org/apache/samza/operators/impl/OperatorImplGraph.java	276
samza-core/src/main/java/org/apache/samza/operators/impl/PartialJoinOperatorImpl.java	69
samza-core/src/main/java/org/apache/samza/operators/impl/OperatorImpl.java	412
samza-core/src/main/java/org/apache/samza/operators/TableImpl.java	16
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/config/ShellCommandConfig.java	60
samza-core/src/main/java/org/apache/samza/config/InMemorySystemConfig.java	11
samza-core/src/main/java/org/apache/samza/config/TaskConfig.java	276
samza-core/src/main/java/org/apache/samza/config/MetricsConfig.java	46
samza-core/src/main/java/org/apache/samza/config/StreamConfig.java	174
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/loaders/PropertiesConfigLoaderFactory.java	16
samza-core/src/main/java/org/apache/samza/config/loaders/PropertiesConfigLoader.java	36
samza-core/src/main/java/org/apache/samza/config/ZkConfig.java	32
samza-core/src/main/java/org/apache/samza/config/SerializerConfig.java	65
samza-core/src/main/java/org/apache/samza/config/RunLoopConfig.java	50
samza-core/src/main/java/org/apache/samza/config/ClusterManagerConfig.java	164
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/FileSystemCheckpointManagerConfig.java	11
samza-core/src/main/java/org/apache/samza/config/JobCoordinatorConfig.java	55
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/SystemConfig.java	116
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/clustermanager/ContainerAllocator.java	223
samza-core/src/main/java/org/apache/samza/clustermanager/FaultDomainManager.java	9
samza-core/src/main/java/org/apache/samza/clustermanager/SamzaResourceRequest.java	97
samza-core/src/main/java/org/apache/samza/clustermanager/StandbyContainerManager.java	399
samza-core/src/main/java/org/apache/samza/clustermanager/SamzaApplicationState.java	42
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/ContainerManager.java	368
samza-core/src/main/java/org/apache/samza/clustermanager/StandbyTaskUtil.java	63
samza-core/src/main/java/org/apache/samza/clustermanager/ClusterBasedJobCoordinator.java	308
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/ClusterBasedJobCoordinatorRunner.java	93
samza-core/src/main/java/org/apache/samza/clustermanager/FaultDomainManagerFactory.java	8
samza-core/src/main/java/org/apache/samza/clustermanager/ContainerProcessManager.java	455
samza-core/src/main/java/org/apache/samza/clustermanager/ProcessorLaunchException.java	16
samza-core/src/main/java/org/apache/samza/clustermanager/SingleFaultDomainManagerFactory.java	9
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/ContainerPlacementRequestAllocator.java	66
samza-core/src/main/java/org/apache/samza/clustermanager/container/placement/ContainerPlacementMetadataStore.java	176
samza-core/src/main/java/org/apache/samza/clustermanager/DefaultApplicationMain.java	20
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/ClusterResourceManager.java	27
samza-core/src/main/java/org/apache/samza/clustermanager/FaultDomain.java	41
samza-core/src/main/java/org/apache/samza/clustermanager/FaultDomainType.java	4
samza-core/src/main/java/org/apache/samza/clustermanager/SamzaResource.java	62
samza-core/src/main/java/org/apache/samza/startpoint/StartpointFanOutPerTask.java	50
samza-core/src/main/java/org/apache/samza/startpoint/StartpointObjectMapper.java	42
samza-core/src/main/java/org/apache/samza/startpoint/StartpointManager.java	262
samza-core/src/main/java/org/apache/samza/util/MetricsReporterLoader.java	28
samza-core/src/main/java/org/apache/samza/util/FutureUtil.java	116
samza-core/src/main/java/org/apache/samza/util/ShutdownUtil.java	31
samza-core/src/main/java/org/apache/samza/util/Util.java	29
samza-core/src/main/java/org/apache/samza/util/BoundedLinkedHashSet.java	24
samza-core/src/main/java/org/apache/samza/util/HighResolutionClock.java	4
samza-core/src/main/java/org/apache/samza/util/DiagnosticsUtil.java	124
samza-core/src/main/java/org/apache/samza/util/ThrottlingExecutor.java	63
samza-core/src/main/java/org/apache/samza/util/SystemHighResolutionClock.java	12
samza-core/src/main/java/org/apache/samza/util/StreamUtil.java	45
samza-core/src/main/java/org/apache/samza/util/RetryPolicyConfig.java	42
samza-core/src/main/java/org/apache/samza/util/ReflectionUtil.java	58
samza-core/src/main/java/org/apache/samza/util/SystemClock.java	12
samza-core/src/main/java/org/apache/samza/util/MathUtil.java	36
samza-core/src/main/java/org/apache/samza/util/ThreadUtil.java	88
samza-core/src/main/java/org/apache/samza/util/ThrottlingScheduler.java	76
samza-core/src/main/java/org/apache/samza/util/SamzaUncaughtExceptionHandler.java	23
samza-core/src/main/java/org/apache/samza/util/Throttleable.java	7
samza-core/src/main/java/org/apache/samza/util/EmbeddedTaggedRateLimiter.java	103
samza-core/src/main/java/org/apache/samza/util/ConfigUtil.java	55
samza-core/src/main/java/org/apache/samza/executors/KeyBasedExecutorService.java	106
samza-core/src/main/java/org/apache/samza/processor/StreamProcessor.java	372
samza-core/src/main/java/org/apache/samza/task/TaskFactoryUtil.java	75
samza-core/src/main/java/org/apache/samza/task/TaskCallbackListener.java	5
samza-core/src/main/java/org/apache/samza/task/StreamOperatorTask.java	130
samza-core/src/main/java/org/apache/samza/task/AsyncStreamTaskAdapter.java	63
samza-core/src/main/java/org/apache/samza/task/TaskCallbackImpl.java	92
samza-core/src/main/java/org/apache/samza/task/TaskCallbackFactory.java	4
samza-core/src/main/java/org/apache/samza/task/CoordinatorRequests.java	45
samza-core/src/main/java/org/apache/samza/task/TaskCallbackManager.java	86
samza-core/src/main/java/org/apache/samza/task/DefaultTaskExecutorFactory.java	40
samza-core/src/main/java/org/apache/samza/container/ExecutionContainerIdManager.java	44
samza-core/src/main/java/org/apache/samza/container/SamzaContainerStatus.java	8
samza-core/src/main/java/org/apache/samza/container/ContainerHeartbeatClient.java	72
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/GroupBySystemStreamPartition.java	41
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/HashSystemStreamPartitionMapper.java	17
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/SSPGrouperProxy.java	152
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/AllSspToSingleTaskGrouperFactory.java	48
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/TaskNameGrouperProxy.java	68
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/BalancingTaskNameGrouper.java	11
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/SingleContainerGrouperFactory.java	31
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/TaskNameGrouperFactory.java	5
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/TaskPartitionAssignmentManager.java	89
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/GroupByContainerIds.java	130
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/TaskGroup.java	42
samza-core/src/main/java/org/apache/samza/container/ContainerHeartbeatResponse.java	11
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/SecurityManager.java	5
samza-core/src/main/java/org/apache/samza/container/SamzaContainerListener.java	7
samza-core/src/main/java/org/apache/samza/container/RunLoop.java	742
samza-core/src/main/java/org/apache/samza/container/host/PosixCommandBasedStatisticsGetter.java	53
samza-core/src/main/java/org/apache/samza/container/host/SystemStatisticsMonitor.java	9
samza-core/src/main/java/org/apache/samza/container/host/SystemStatistics.java	35
samza-core/src/main/java/org/apache/samza/container/host/StatisticsMonitorImpl.java	92
samza-core/src/main/java/org/apache/samza/container/host/SystemStatisticsGetter.java	5
samza-core/src/main/java/org/apache/samza/container/host/ProcessCPUStatistics.java	30
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/SystemMemoryStatistics.java	27
samza-core/src/main/java/org/apache/samza/container/SamzaContainerMonitorListener.java	48
samza-core/src/main/java/org/apache/samza/container/SecurityManagerFactory.java	5
samza-core/src/main/java/org/apache/samza/container/disk/WatermarkDiskQuotaPolicy.java	126
samza-core/src/main/java/org/apache/samza/container/disk/NoThrottlingDiskQuotaPolicy.java	13
samza-core/src/main/java/org/apache/samza/container/disk/DiskQuotaPolicy.java	4
samza-core/src/main/java/org/apache/samza/container/disk/PollingScanDiskSpaceMonitor.java	117
samza-core/src/main/java/org/apache/samza/container/disk/WatermarkDiskQuotaPolicyFactory.java	27
samza-core/src/main/java/org/apache/samza/container/disk/NoThrottlingDiskQuotaPolicyFactory.java	8
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/ContainerHeartbeatMonitor.java	212
samza-core/src/main/java/org/apache/samza/container/LocalityManager.java	52
samza-core/src/main/java/org/apache/samza/migration/MigrationPlan.java	5
samza-core/src/main/java/org/apache/samza/coordinator/NoProcessorJobCoordinatorListener.java	27
samza-core/src/main/java/org/apache/samza/coordinator/StreamRegexMonitorFactory.java	49
samza-core/src/main/java/org/apache/samza/coordinator/JobModelHelper.java	151
samza-core/src/main/java/org/apache/samza/coordinator/staticresource/StaticResourceJobCoordinatorFactory.java	87
samza-core/src/main/java/org/apache/samza/coordinator/staticresource/StaticResourceJobCoordinator.java	199
samza-core/src/main/java/org/apache/samza/coordinator/metadatastore/NamespaceAwareCoordinatorStreamStore.java	73
samza-core/src/main/java/org/apache/samza/coordinator/metadatastore/CoordinatorStreamStore.java	185
samza-core/src/main/java/org/apache/samza/coordinator/metadatastore/CoordinatorStreamMetadataStoreFactory.java	11
samza-core/src/main/java/org/apache/samza/coordinator/InputStreamsDiscoveredException.java	7
samza-core/src/main/java/org/apache/samza/coordinator/StreamPartitionCountMonitor.java	146
samza-core/src/main/java/org/apache/samza/coordinator/CoordinationUtils.java	10
samza-core/src/main/java/org/apache/samza/coordinator/CoordinationConstants.java	16
samza-core/src/main/java/org/apache/samza/coordinator/MetadataResourceUtil.java	33
samza-core/src/main/java/org/apache/samza/coordinator/LeaderElectorListener.java	4
samza-core/src/main/java/org/apache/samza/coordinator/JobModelMonitors.java	32
samza-core/src/main/java/org/apache/samza/coordinator/RunIdGenerator.java	67
samza-core/src/main/java/org/apache/samza/coordinator/DistributedLock.java	6
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/SetTaskPartitionMapping.java	17
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/SetJobCoordinatorMetadataMessage.java	17
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/SetTaskModeMapping.java	17
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/SetChangelogMapping.java	22
samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/SetTaskContainerMapping.java	17
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/CoordinatorStreamKeySerde.java	25
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/CoordinatorStreamManager.java	82
samza-core/src/main/java/org/apache/samza/coordinator/communication/HttpCoordinatorCommunication.java	31
samza-core/src/main/java/org/apache/samza/coordinator/communication/JobModelHttpServlet.java	46
samza-core/src/main/java/org/apache/samza/coordinator/communication/HttpCoordinatorToWorkerCommunicationFactory.java	17
samza-core/src/main/java/org/apache/samza/coordinator/communication/CoordinatorCommunication.java	5
samza-core/src/main/java/org/apache/samza/coordinator/communication/JobInfoProvider.java	5
samza-core/src/main/java/org/apache/samza/coordinator/communication/CoordinatorToWorkerCommunicationFactory.java	4
samza-core/src/main/java/org/apache/samza/coordinator/communication/JobInfoServingContext.java	20
samza-core/src/main/java/org/apache/samza/coordinator/communication/CoordinatorCommunicationContext.java	23
samza-core/src/main/java/org/apache/samza/coordinator/StreamRegexMonitor.java	125
samza-core/src/main/java/org/apache/samza/coordinator/StreamPartitionCountMonitorFactory.java	26
samza-core/src/main/java/org/apache/samza/coordinator/server/LocalityServlet.java	33
samza-core/src/main/java/org/apache/samza/coordinator/CoordinationUtilsFactory.java	5
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/PartitionChangeException.java	7
samza-core/src/main/java/org/apache/samza/coordinator/JobCoordinatorListener.java	8
samza-core/src/main/java/org/apache/samza/coordinator/JobCoordinatorFactory.java	10
samza-core/src/main/java/org/apache/samza/coordinator/JobModelCalculator.java	160
samza-core/src/main/java/org/apache/samza/coordinator/ClusterMembership.java	8
samza-core/src/main/java/org/apache/samza/coordinator/JobCoordinator.java	12
samza-core/src/main/java/org/apache/samza/coordinator/LeaderElector.java	9
samza-core/src/main/java/org/apache/samza/execution/StreamEdge.java	94
samza-core/src/main/java/org/apache/samza/execution/JobNode.java	125
samza-core/src/main/java/org/apache/samza/execution/ExecutionPlan.java	13
samza-core/src/main/java/org/apache/samza/execution/OperatorSpecGraphAnalyzer.java	99
samza-core/src/main/java/org/apache/samza/execution/ExecutionPlanner.java	183
samza-core/src/main/java/org/apache/samza/execution/JobGraph.java	265
samza-core/src/main/java/org/apache/samza/execution/RemoteJobPlanner.java	58
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/JobGraphJsonGenerator.java	202
samza-core/src/main/java/org/apache/samza/execution/StreamManager.java	101
samza-core/src/main/java/org/apache/samza/execution/LocalJobPlanner.java	146
samza-core/src/main/java/org/apache/samza/execution/IntermediateStreamManager.java	107
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/application/LegacyTaskApplication.java	13
samza-core/src/main/java/org/apache/samza/application/ApplicationUtil.java	32
samza-core/src/main/java/org/apache/samza/application/descriptors/ApplicationDescriptorImpl.java	223
samza-core/src/main/java/org/apache/samza/application/descriptors/StreamApplicationDescriptorImpl.java	145
samza-core/src/main/java/org/apache/samza/application/descriptors/ApplicationDescriptorUtil.java	19
samza-core/src/main/java/org/apache/samza/application/descriptors/TaskApplicationDescriptorImpl.java	45
samza-core/src/main/java/org/apache/samza/environment/EnvironmentVariables.java	5
samza-core/src/main/java/org/apache/samza/storage/TaskStorageCommitManager.java	260
samza-core/src/main/java/org/apache/samza/storage/TaskSideInputStorageManager.java	131
samza-core/src/main/java/org/apache/samza/storage/StorageManagerUtil.java	302
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/diff/DirDiff.java	162
samza-core/src/main/java/org/apache/samza/storage/blobstore/BlobStoreRestoreManager.java	264
samza-core/src/main/java/org/apache/samza/storage/blobstore/util/DirDiffUtil.java	278
samza-core/src/main/java/org/apache/samza/storage/blobstore/util/BlobStoreUtil.java	473
samza-core/src/main/java/org/apache/samza/storage/blobstore/BlobStoreStateBackendFactory.java	79
samza-core/src/main/java/org/apache/samza/storage/blobstore/BlobStoreBackupManager.java	247
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/JsonDirIndexMixin.java	27
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/index/serde/JsonFileBlobMixin.java	14
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/JsonFileIndexMixin.java	23
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/FileMetadata.java	97
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/FileIndex.java	67
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/SnapshotMetadata.java	78
samza-core/src/main/java/org/apache/samza/storage/blobstore/index/SnapshotIndex.java	75
samza-core/src/main/java/org/apache/samza/storage/TransactionalStateTaskRestoreManager.java	517
samza-core/src/main/java/org/apache/samza/storage/NonTransactionalStateTaskRestoreManager.java	268
samza-core/src/main/java/org/apache/samza/storage/TaskSideInputHandler.java	187
samza-core/src/main/java/org/apache/samza/storage/KafkaChangelogStateBackendFactory.java	170
samza-core/src/main/java/org/apache/samza/storage/SideInputTask.java	106
samza-core/src/main/java/org/apache/samza/storage/ChangelogStreamManager.java	105
samza-core/src/main/java/org/apache/samza/storage/StateStorageTool.java	32
samza-core/src/main/java/org/apache/samza/storage/StorageRecovery.java	175
samza-core/src/main/java/org/apache/samza/checkpoint/kafka/KafkaStateCheckpointMarker.java	88
samza-core/src/main/java/org/apache/samza/checkpoint/kafka/KafkaChangelogSSPOffset.java	52
samza-azure/src/main/java/org/apache/samza/system/azureblob/AzureBlobBasicMetrics.java	43
samza-azure/src/main/java/org/apache/samza/system/azureblob/BlobClientBuilderFactory.java	4
samza-azure/src/main/java/org/apache/samza/system/azureblob/compression/CompressionFactory.java	15
samza-azure/src/main/java/org/apache/samza/system/azureblob/compression/GzipCompression.java	38
samza-azure/src/main/java/org/apache/samza/system/azureblob/compression/CompressionType.java	4
samza-azure/src/main/java/org/apache/samza/system/azureblob/compression/Compression.java	5
samza-azure/src/main/java/org/apache/samza/system/azureblob/compression/NoneCompression.java	11
samza-azure/src/main/java/org/apache/samza/system/azureblob/utils/BlobMetadataGenerator.java	5
samza-azure/src/main/java/org/apache/samza/system/azureblob/utils/NullBlobMetadataGeneratorFactory.java	8
samza-azure/src/main/java/org/apache/samza/system/azureblob/utils/BlobMetadataGeneratorFactory.java	5
samza-azure/src/main/java/org/apache/samza/system/azureblob/utils/NullBlobMetadataGenerator.java	8
samza-azure/src/main/java/org/apache/samza/system/azureblob/utils/BlobMetadataContext.java	20
samza-azure/src/main/java/org/apache/samza/system/azureblob/AzureBlobConfig.java	181
samza-azure/src/main/java/org/apache/samza/system/azureblob/AzureBlobClientBuilder.java	74
samza-azure/src/main/java/org/apache/samza/system/azureblob/BlobClientBuilder.java	5
samza-azure/src/main/java/org/apache/samza/system/azureblob/AzureBlobSystemAdmin.java	18
samza-azure/src/main/java/org/apache/samza/system/azureblob/AzureBlobSystemFactory.java	26
samza-azure/src/main/java/org/apache/samza/system/azureblob/AzureBlobClientBuilderFactory.java	8
samza-azure/src/main/java/org/apache/samza/system/azureblob/producer/AzureBlobSystemProducerMetrics.java	74
samza-azure/src/main/java/org/apache/samza/system/azureblob/producer/AzureBlobSystemProducer.java	343
samza-azure/src/main/java/org/apache/samza/system/azureblob/producer/AzureBlobWriterMetrics.java	33
samza-azure/src/main/java/org/apache/samza/system/azureblob/producer/AzureBlobWriter.java	8
samza-azure/src/main/java/org/apache/samza/system/azureblob/producer/AzureBlobWriterFactory.java	14
samza-azure/src/main/java/org/apache/samza/system/azureblob/avro/AzureBlobAvroWriterFactory.java	22
samza-azure/src/main/java/org/apache/samza/system/azureblob/avro/AzureBlobAvroWriter.java	284
samza-azure/src/main/java/org/apache/samza/system/azureblob/avro/AzureBlobOutputStream.java	225
samza-azure/src/main/java/org/apache/samza/system/eventhub/SamzaEventHubClientManager.java	86
samza-azure/src/main/java/org/apache/samza/system/eventhub/EventHubSystemFactory.java	39
samza-azure/src/main/java/org/apache/samza/system/eventhub/admin/PassThroughInterceptor.java	8
samza-azure/src/main/java/org/apache/samza/system/eventhub/admin/EventHubSystemAdmin.java	236
samza-azure/src/main/java/org/apache/samza/system/eventhub/EventHubClientManager.java	8
samza-azure/src/main/java/org/apache/samza/system/eventhub/consumer/EventHubSystemConsumer.java	392
samza-azure/src/main/java/org/apache/samza/system/eventhub/consumer/EventHubIncomingMessageEnvelope.java	15
samza-azure/src/main/java/org/apache/samza/system/eventhub/Interceptor.java	4
samza-azure/src/main/java/org/apache/samza/system/eventhub/descriptors/EventHubsOutputDescriptor.java	49
samza-azure/src/main/java/org/apache/samza/system/eventhub/descriptors/EventHubsSystemDescriptor.java	87
samza-azure/src/main/java/org/apache/samza/system/eventhub/descriptors/EventHubsInputDescriptor.java	56
samza-azure/src/main/java/org/apache/samza/system/eventhub/EventHubClientManagerFactory.java	11
samza-azure/src/main/java/org/apache/samza/system/eventhub/producer/AsyncSystemProducer.java	115
samza-azure/src/main/java/org/apache/samza/system/eventhub/producer/EventHubSystemProducer.java	290
samza-azure/src/main/java/org/apache/samza/system/eventhub/EventHubConfig.java	159
samza-azure/src/main/java/org/apache/samza/config/AzureConfig.java	35
samza-azure/src/main/java/org/apache/samza/util/TableUtils.java	131
samza-azure/src/main/java/org/apache/samza/util/LeaseBlobManager.java	52
samza-azure/src/main/java/org/apache/samza/util/BlobUtils.java	175
samza-azure/src/main/java/org/apache/samza/AzureClient.java	46
samza-azure/src/main/java/org/apache/samza/AzureException.java	15
samza-azure/src/main/java/org/apache/samza/coordinator/data/JobModelBundle.java	27
samza-azure/src/main/java/org/apache/samza/coordinator/data/ProcessorEntity.java	30
samza-azure/src/main/java/org/apache/samza/coordinator/data/BarrierState.java	4
samza-azure/src/main/java/org/apache/samza/coordinator/AzureLock.java	59
samza-azure/src/main/java/org/apache/samza/coordinator/scheduler/RenewLeaseScheduler.java	48
samza-azure/src/main/java/org/apache/samza/coordinator/scheduler/TaskScheduler.java	7
samza-azure/src/main/java/org/apache/samza/coordinator/scheduler/LeaderBarrierCompleteScheduler.java	83
samza-azure/src/main/java/org/apache/samza/coordinator/scheduler/SchedulerStateChangeListener.java	4
samza-azure/src/main/java/org/apache/samza/coordinator/scheduler/HeartbeatScheduler.java	48
samza-azure/src/main/java/org/apache/samza/coordinator/scheduler/LeaderLivenessCheckScheduler.java	72
samza-azure/src/main/java/org/apache/samza/coordinator/scheduler/JMVersionUpgradeScheduler.java	65
samza-azure/src/main/java/org/apache/samza/coordinator/scheduler/LivenessCheckScheduler.java	71
samza-azure/src/main/java/org/apache/samza/coordinator/AzureCoordinationUtilsFactory.java	8
samza-azure/src/main/java/org/apache/samza/coordinator/AzureJobCoordinatorFactory.java	11
samza-azure/src/main/java/org/apache/samza/coordinator/AzureCoordinationUtils.java	31
samza-azure/src/main/java/org/apache/samza/coordinator/AzureLeaderElector.java	58
samza-azure/src/main/java/org/apache/samza/coordinator/AzureJobCoordinator.java	352
samza-azure/src/main/java/org/apache/samza/checkpoint/azure/AzureCheckpointManagerFactory.java	14
samza-azure/src/main/java/org/apache/samza/checkpoint/azure/AzureCheckpointManager.java	176
samza-azure/src/main/java/org/apache/samza/checkpoint/azure/TaskCheckpointEntity.java	17
samza-yarn/src/main/scala/org/apache/samza/job/yarn/ClientHelper.scala	330
samza-yarn/src/main/scala/org/apache/samza/job/yarn/YarnAppMasterListener.scala	11
samza-yarn/src/main/scala/org/apache/samza/job/yarn/YarnJobFactory.scala	28
samza-yarn/src/main/scala/org/apache/samza/job/yarn/YarnJobUtil.scala	60
samza-yarn/src/main/scala/org/apache/samza/job/yarn/SamzaYarnAppMasterLifecycle.scala	78
samza-yarn/src/main/scala/org/apache/samza/job/yarn/SamzaYarnSecurityManagerFactory.scala	10
samza-yarn/src/main/scala/org/apache/samza/job/yarn/SamzaContainerSecurityManager.scala	71
samza-yarn/src/main/scala/org/apache/samza/job/yarn/SamzaYarnAppMasterService.scala	58
samza-yarn/src/main/scala/org/apache/samza/job/yarn/YarnJob.scala	137
samza-yarn/src/main/scala/org/apache/samza/job/yarn/SamzaAppMasterSecurityManager.scala	74
samza-yarn/src/main/scala/org/apache/samza/job/yarn/YarnContainer.scala	22
samza-yarn/src/main/scala/org/apache/samza/job/yarn/SamzaAppMasterMetrics.scala	41
samza-yarn/src/main/scala/org/apache/samza/util/hadoop/HttpFileSystem.scala	66
samza-yarn/src/main/scala/org/apache/samza/util/hadoop/HttpInputStream.scala	20
samza-yarn/src/main/scala/org/apache/samza/webapp/ApplicationMasterWebServlet.scala	23
samza-yarn/src/main/scala/org/apache/samza/webapp/ApplicationMasterRestServlet.scala	84
samza-yarn/src/main/java/org/apache/samza/job/yarn/YarnAppState.java	51
samza-yarn/src/main/java/org/apache/samza/job/yarn/LocalizerResourceException.java	15
samza-yarn/src/main/java/org/apache/samza/job/yarn/LocalizerResourceMapper.java	64
samza-yarn/src/main/java/org/apache/samza/job/yarn/YarnClusterResourceManager.java	509
samza-yarn/src/main/java/org/apache/samza/job/yarn/YarnFaultDomainManager.java	79
samza-yarn/src/main/java/org/apache/samza/job/yarn/YarnFaultDomainManagerFactory.java	11
samza-yarn/src/main/java/org/apache/samza/job/yarn/YarnResourceManagerFactory.java	19
samza-yarn/src/main/java/org/apache/samza/job/yarn/FileSystemImplConfig.java	31
samza-yarn/src/main/java/org/apache/samza/job/yarn/LocalizerResourceConfig.java	54
samza-yarn/src/main/java/org/apache/samza/config/YarnConfig.java	113
samza-yarn/src/main/java/org/apache/samza/validation/YarnJobValidationTool.java	152
samza-yarn/src/main/java/org/apache/samza/webapp/YarnContainerHeartbeatServlet.java	58
samza-yarn/src/main/java/org/apache/samza/webapp/ApplicationMasterRestClient.java	61
samza-yarn/src/main/resources/scalate/css/ropa-sans.css	6
samza-yarn/src/main/resources/scalate/WEB-INF/views/index.scaml	224
samza-yarn/src/main/resources/scalate/WEB-INF/layouts/default.scaml	41
samza-yarn/src/main/less/main.less	118
samza-yarn/src/main/less/variables.less	3
samza-log4j/src/main/java/org/apache/samza/logging/log4j/SimpleDiagnosticsAppender.java	42
samza-log4j/src/main/java/org/apache/samza/logging/log4j/serializers/LoggingEventJsonSerdeFactory.java	13
samza-log4j/src/main/java/org/apache/samza/logging/log4j/serializers/LoggingEventStringSerde.java	35
samza-log4j/src/main/java/org/apache/samza/logging/log4j/serializers/LoggingEventStringSerdeFactory.java	11
samza-log4j/src/main/java/org/apache/samza/logging/log4j/serializers/LoggingEventJsonSerde.java	106
samza-log4j/src/main/java/org/apache/samza/logging/log4j/StreamAppender.java	252
samza-log4j/src/main/java/org/apache/samza/logging/log4j/JmxAppender.java	53
samza-log4j/src/main/java/org/apache/samza/logging/log4j/StreamAppenderMetrics.java	16
samza-log4j/src/main/java/org/apache/samza/config/Log4jSystemConfig.java	34
samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaSystemConsumerMetrics.scala	58
samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaSystemFactory.scala	73
samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaSystemProducer.scala	148
samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaSystemProducerMetrics.scala	13
samza-kafka/src/main/scala/org/apache/samza/config/KafkaConfig.scala	247
samza-kafka/src/main/scala/org/apache/samza/checkpoint/kafka/KafkaCheckpointManagerFactory.scala	32
samza-kafka/src/main/scala/org/apache/samza/checkpoint/kafka/KafkaCheckpointManager.scala	291
samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaStreamSpec.java	84
samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaConsumerProxy.java	320
samza-kafka/src/main/java/org/apache/samza/system/kafka/descriptors/KafkaOutputDescriptor.java	10
samza-kafka/src/main/java/org/apache/samza/system/kafka/descriptors/KafkaInputDescriptor.java	38
samza-kafka/src/main/java/org/apache/samza/system/kafka/descriptors/KafkaSystemDescriptor.java	99
samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaConsumerProxyFactory.java	4
samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaSystemConsumer.java	224
samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaSystemAdmin.java	670
samza-kafka/src/main/java/org/apache/samza/config/KafkaConsumerConfig.java	130
samza-kafka/src/main/java/org/apache/samza/util/KafkaUtil.java	29
samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKey.java	63
samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKeySerde.java	36
samza-yarn3/src/main/scala/org/apache/samza/job/yarn/ClientHelper.scala	330
samza-yarn3/src/main/scala/org/apache/samza/job/yarn/YarnAppMasterListener.scala	11
samza-yarn3/src/main/scala/org/apache/samza/job/yarn/YarnJobFactory.scala	28
samza-yarn3/src/main/scala/org/apache/samza/job/yarn/YarnJobUtil.scala	60
samza-yarn3/src/main/scala/org/apache/samza/job/yarn/SamzaYarnAppMasterLifecycle.scala	78
samza-yarn3/src/main/scala/org/apache/samza/job/yarn/SamzaYarnSecurityManagerFactory.scala	10
samza-yarn3/src/main/scala/org/apache/samza/job/yarn/SamzaContainerSecurityManager.scala	71
samza-yarn3/src/main/scala/org/apache/samza/job/yarn/SamzaYarnAppMasterService.scala	58
samza-yarn3/src/main/scala/org/apache/samza/job/yarn/YarnJob.scala	137
samza-yarn3/src/main/scala/org/apache/samza/job/yarn/SamzaAppMasterSecurityManager.scala	74
samza-yarn3/src/main/scala/org/apache/samza/job/yarn/YarnContainer.scala	22
samza-yarn3/src/main/scala/org/apache/samza/job/yarn/SamzaAppMasterMetrics.scala	34
samza-yarn3/src/main/scala/org/apache/samza/util/hadoop/HttpFileSystem.scala	66
samza-yarn3/src/main/scala/org/apache/samza/util/hadoop/HttpInputStream.scala	20
samza-yarn3/src/main/scala/org/apache/samza/webapp/ApplicationMasterWebServlet.scala	23
samza-yarn3/src/main/scala/org/apache/samza/webapp/ApplicationMasterRestServlet.scala	84
samza-yarn3/src/main/java/org/apache/samza/job/yarn/YarnAppState.java	51
samza-yarn3/src/main/java/org/apache/samza/job/yarn/LocalizerResourceException.java	15
samza-yarn3/src/main/java/org/apache/samza/job/yarn/LocalizerResourceMapper.java	64
samza-yarn3/src/main/java/org/apache/samza/job/yarn/YarnClusterResourceManager.java	507
samza-yarn3/src/main/java/org/apache/samza/job/yarn/YarnFaultDomainManager.java	79
samza-yarn3/src/main/java/org/apache/samza/job/yarn/YarnFaultDomainManagerFactory.java	11
samza-yarn3/src/main/java/org/apache/samza/job/yarn/YarnResourceManagerFactory.java	19
samza-yarn3/src/main/java/org/apache/samza/job/yarn/FileSystemImplConfig.java	31
samza-yarn3/src/main/java/org/apache/samza/job/yarn/LocalizerResourceConfig.java	54
samza-yarn3/src/main/java/org/apache/samza/config/YarnConfig.java	113
samza-yarn3/src/main/java/org/apache/samza/validation/YarnJobValidationTool.java	152
samza-yarn3/src/main/java/org/apache/samza/webapp/YarnContainerHeartbeatServlet.java	58
samza-yarn3/src/main/java/org/apache/samza/webapp/ApplicationMasterRestClient.java	61
samza-yarn3/src/main/resources/scalate/css/ropa-sans.css	6
samza-yarn3/src/main/resources/scalate/WEB-INF/views/index.scaml	224
samza-yarn3/src/main/resources/scalate/WEB-INF/layouts/default.scaml	41
samza-yarn3/src/main/less/main.less	118
samza-yarn3/src/main/less/variables.less	3
samza-aws/src/main/java/org/apache/samza/system/kinesis/metrics/KinesisSystemConsumerMetrics.java	63
samza-aws/src/main/java/org/apache/samza/system/kinesis/metrics/SamzaHistogram.java	35
samza-aws/src/main/java/org/apache/samza/system/kinesis/consumer/KinesisRecordProcessorListener.java	8
samza-aws/src/main/java/org/apache/samza/system/kinesis/consumer/KinesisSystemConsumerOffset.java	60
samza-aws/src/main/java/org/apache/samza/system/kinesis/consumer/NoAvailablePartitionException.java	10
samza-aws/src/main/java/org/apache/samza/system/kinesis/consumer/KinesisRecordProcessor.java	111
samza-aws/src/main/java/org/apache/samza/system/kinesis/consumer/KinesisIncomingMessageEnvelope.java	30
samza-aws/src/main/java/org/apache/samza/system/kinesis/consumer/KinesisSystemConsumer.java	157
samza-aws/src/main/java/org/apache/samza/system/kinesis/consumer/SSPAllocator.java	32
samza-aws/src/main/java/org/apache/samza/system/kinesis/KinesisSystemAdmin.java	73
samza-aws/src/main/java/org/apache/samza/system/kinesis/KinesisConfig.java	171
samza-aws/src/main/java/org/apache/samza/system/kinesis/KinesisAWSCredentialsProvider.java	36
samza-aws/src/main/java/org/apache/samza/system/kinesis/descriptors/KinesisSystemDescriptor.java	60
samza-aws/src/main/java/org/apache/samza/system/kinesis/descriptors/KinesisInputDescriptor.java	53
samza-aws/src/main/java/org/apache/samza/system/kinesis/KinesisSystemFactory.java	53
samza-sql-shell/conf/samza-sql-shell-log4j.xml	24
samza-sql-shell/src/main/java/org/apache/samza/sql/client/interfaces/CommandHandler.java	12
samza-sql-shell/src/main/java/org/apache/samza/sql/client/interfaces/SqlFunction.java	8
samza-sql-shell/src/main/java/org/apache/samza/sql/client/interfaces/CommandType.java	12
samza-sql-shell/src/main/java/org/apache/samza/sql/client/interfaces/SqlExecutor.java	23
samza-sql-shell/src/main/java/org/apache/samza/sql/client/interfaces/EnvironmentVariableHandler.java	9
samza-sql-shell/src/main/java/org/apache/samza/sql/client/interfaces/ExecutionContext.java	3
samza-sql-shell/src/main/java/org/apache/samza/sql/client/interfaces/EnvironmentVariableHandlerImpl.java	67
samza-sql-shell/src/main/java/org/apache/samza/sql/client/interfaces/EnvironmentVariableSpecs.java	35
samza-sql-shell/src/main/java/org/apache/samza/sql/client/interfaces/NonQueryResult.java	24
samza-sql-shell/src/main/java/org/apache/samza/sql/client/interfaces/ExecutionStatus.java	7
samza-sql-shell/src/main/java/org/apache/samza/sql/client/interfaces/QueryResult.java	16
samza-sql-shell/src/main/java/org/apache/samza/sql/client/exceptions/ExecutorException.java	14
samza-sql-shell/src/main/java/org/apache/samza/sql/client/exceptions/CliException.java	14
samza-sql-shell/src/main/java/org/apache/samza/sql/client/exceptions/CommandHandlerException.java	14
samza-sql-shell/src/main/java/org/apache/samza/sql/client/util/CliUtil.java	37
samza-sql-shell/src/main/java/org/apache/samza/sql/client/util/Pair.java	21
samza-sql-shell/src/main/java/org/apache/samza/sql/client/util/RandomAccessQueue.java	60
samza-sql-shell/src/main/java/org/apache/samza/sql/client/cli/CliConstants.java	28
samza-sql-shell/src/main/java/org/apache/samza/sql/client/cli/CliShell.java	193
samza-sql-shell/src/main/java/org/apache/samza/sql/client/cli/QueryResultLogView.java	209
samza-sql-shell/src/main/java/org/apache/samza/sql/client/cli/CliCommand.java	25
samza-sql-shell/src/main/java/org/apache/samza/sql/client/cli/Main.java	77
samza-sql-shell/src/main/java/org/apache/samza/sql/client/cli/CliEnvironment.java	169
samza-sql-shell/src/main/java/org/apache/samza/sql/client/cli/CliView.java	6
samza-sql-shell/src/main/java/org/apache/samza/sql/client/cli/CliHighlighter.java	57
samza-sql-shell/src/main/java/org/apache/samza/sql/client/cli/CliShellEnvironmentVariableHandler.java	53
samza-sql-shell/src/main/java/org/apache/samza/sql/client/impl/CliCommandHandler.java	578
samza-sql-shell/src/main/java/org/apache/samza/sql/client/impl/CliLoggingSystemFactory.java	76
samza-sql-shell/src/main/java/org/apache/samza/sql/client/impl/SamzaSqlUdfDisplayInfo.java	37
samza-sql-shell/src/main/java/org/apache/samza/sql/client/impl/CliCommandType.java	52
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/impl/FileSystemAvroRelSchemaProviderFactory.java	44
samza-tools/src/main/java/org/apache/samza/tools/CommandLineHelper.java	14
samza-tools/src/main/java/org/apache/samza/tools/EventHubConsoleConsumer.java	85
samza-tools/src/main/java/org/apache/samza/tools/json/JsonRelConverterFactory.java	64
samza-tools/src/main/java/org/apache/samza/tools/GenerateKafkaEvents.java	152
samza-tools/src/main/java/org/apache/samza/tools/benchmark/SystemConsumerBench.java	58
samza-tools/src/main/java/org/apache/samza/tools/benchmark/AbstractSamzaBench.java	103
samza-tools/src/main/java/org/apache/samza/tools/benchmark/ConfigBasedSspGrouperFactory.java	51
samza-tools/src/main/java/org/apache/samza/tools/benchmark/SystemConsumerWithSamzaBench.java	88
samza-tools/src/main/java/org/apache/samza/tools/benchmark/SystemProducerBench.java	72
samza-tools/src/main/java/org/apache/samza/tools/RandomValueGenerator.java	45
samza-tools/src/main/java/org/apache/samza/tools/ConsoleLoggingSystemFactory.java	102
samza-tools/src/main/java/org/apache/samza/tools/schemas/ProfileChangeEvent.java	29
samza-tools/src/main/java/org/apache/samza/tools/schemas/PageViewEvent.java	29
samza-tools/src/main/java/org/apache/samza/tools/schemas/PageViewEvent.avsc	50
samza-tools/src/main/java/org/apache/samza/tools/schemas/ProfileChangeEvent.avsc	50
samza-tools/src/main/java/org/apache/samza/tools/SamzaSqlConsole.java	130
samza-tools/src/main/java/org/apache/samza/tools/avro/AvroSchemaGenRelConverterFactory.java	16
samza-tools/src/main/java/org/apache/samza/tools/avro/AvroSerDeFactory.java	62
samza-tools/src/main/java/org/apache/samza/tools/avro/AvroSchemaGenRelConverter.java	58
samza-tools/src/main/resources/log4j.xml	18
samza-tools/src/main/resources/log4j2.xml	16
samza-tools/config/eh-consumer-log4j.xml	15
samza-tools/config/generate-kafka-events-log4j.xml	15
samza-tools/config/samza-sql-console-log4j.xml	15
samza-tools/config/bench-log4j.xml	15
samza-kv-rocksdb/src/main/scala/org/apache/samza/storage/kv/RocksDbKeyValueStorageEngineFactory.scala	46
samza-kv-rocksdb/src/main/scala/org/apache/samza/storage/kv/RocksDbKeyValueStore.scala	296
samza-kv-rocksdb/src/main/java/org/apache/samza/storage/kv/RocksDbKeyValueReader.java	66
samza-kv-rocksdb/src/main/java/org/apache/samza/storage/kv/RocksDbReadingTool.java	108
samza-kv-rocksdb/src/main/java/org/apache/samza/storage/kv/RocksDbOptionsHelper.java	175
samza-kv-rocksdb/src/main/java/org/apache/samza/storage/kv/descriptors/RocksDbTableDescriptor.java	143
samza-shell/src/main/resources/log4j-console.xml	14
samza-shell/src/main/resources/log4j2-console.xml	13
samza-shell/src/main/visualizer/js/planToDagre.js	60
samza-shell/src/main/visualizer/plan.html	79
samza-sql/src/main/java/org/apache/samza/sql/planner/RelSchemaConverter.java	74
samza-sql/src/main/java/org/apache/samza/sql/planner/Checker.java	139
samza-sql/src/main/java/org/apache/samza/sql/planner/QueryPlanner.java	189
samza-sql/src/main/java/org/apache/samza/sql/planner/SamzaSqlValidator.java	273
samza-sql/src/main/java/org/apache/samza/sql/planner/SamzaSqlFilterRemoteJoinRule.java	159
samza-sql/src/main/java/org/apache/samza/sql/planner/SamzaSqlValidatorException.java	14
samza-sql/src/main/java/org/apache/samza/sql/planner/SamzaSqlUdfOperatorTable.java	48
samza-sql/src/main/java/org/apache/samza/sql/planner/SamzaSqlOperatorTable.java	109
samza-sql/src/main/java/org/apache/samza/sql/planner/SamzaSqlScalarFunctionImpl.java	74
samza-sql/src/main/java/org/apache/samza/sql/SamzaSqlInputMessage.java	20
samza-sql/src/main/java/org/apache/samza/sql/interfaces/SamzaSqlDriver.java	29
samza-sql/src/main/java/org/apache/samza/sql/interfaces/SamzaSqlJavaTypeFactoryImpl.java	41
samza-sql/src/main/java/org/apache/samza/sql/interfaces/RelSchemaProvider.java	5
samza-sql/src/main/java/org/apache/samza/sql/interfaces/SamzaRelConverter.java	10
samza-sql/src/main/java/org/apache/samza/sql/interfaces/SqlIOConfig.java	101
samza-sql/src/main/java/org/apache/samza/sql/interfaces/DslConverterFactory.java	5
samza-sql/src/main/java/org/apache/samza/sql/interfaces/UdfResolver.java	5
samza-sql/src/main/java/org/apache/samza/sql/interfaces/SqlIOResolver.java	5
samza-sql/src/main/java/org/apache/samza/sql/interfaces/SamzaRelConverterFactory.java	6
samza-sql/src/main/java/org/apache/samza/sql/interfaces/DslConverter.java	6
samza-sql/src/main/java/org/apache/samza/sql/interfaces/SamzaRelTableKeyConverterFactory.java	6
samza-sql/src/main/java/org/apache/samza/sql/interfaces/SqlIOResolverFactory.java	5
samza-sql/src/main/java/org/apache/samza/sql/interfaces/SamzaRelTableKeyConverter.java	5
samza-sql/src/main/java/org/apache/samza/sql/interfaces/RelSchemaProviderFactory.java	6
samza-sql/src/main/java/org/apache/samza/sql/interfaces/UdfMetadata.java	63
samza-sql/src/main/java/org/apache/samza/sql/data/SamzaSqlRelMsgMetadata.java	80
samza-sql/src/main/java/org/apache/samza/sql/data/Expression.java	6
samza-sql/src/main/java/org/apache/samza/sql/data/RexToJavaCompiler.java	116
samza-sql/src/main/java/org/apache/samza/sql/data/SamzaSqlExecutionContext.java	44
samza-sql/src/main/java/org/apache/samza/sql/data/SamzaSqlRelMessage.java	107
samza-sql/src/main/java/org/apache/samza/sql/SamzaSqlInputTransformer.java	16
samza-sql/src/main/java/org/apache/samza/sql/translator/FilterTranslator.java	102
samza-sql/src/main/java/org/apache/samza/sql/translator/SamzaSqlTableJoinFunction.java	72
samza-sql/src/main/java/org/apache/samza/sql/translator/JoinInputNode.java	65
samza-sql/src/main/java/org/apache/samza/sql/translator/QueryTranslator.java	229
samza-sql/src/main/java/org/apache/samza/sql/translator/TranslatorOutputMetricsMapFunction.java	35
samza-sql/src/main/java/org/apache/samza/sql/translator/JoinTranslator.java	299
samza-sql/src/main/java/org/apache/samza/sql/translator/TranslatorContext.java	131
samza-sql/src/main/java/org/apache/samza/sql/translator/TranslatorConstants.java	12
samza-sql/src/main/java/org/apache/samza/sql/translator/ScanTranslator.java	158
samza-sql/src/main/java/org/apache/samza/sql/translator/LogicalAggregateTranslator.java	71
samza-sql/src/main/java/org/apache/samza/sql/translator/TranslatorInputMetricsMapFunction.java	29
samza-sql/src/main/java/org/apache/samza/sql/translator/SamzaSqlRemoteTableJoinFunction.java	50
samza-sql/src/main/java/org/apache/samza/sql/translator/SamzaSqlLocalTableJoinFunction.java	24
samza-sql/src/main/java/org/apache/samza/sql/translator/ProjectTranslator.java	143
samza-sql/src/main/java/org/apache/samza/sql/serializers/SamzaSqlRelMessageSerdeFactory.java	35
samza-sql/src/main/java/org/apache/samza/sql/serializers/SamzaSqlRelRecordSerdeFactory.java	35
samza-sql/src/main/java/org/apache/samza/sql/fn/ConvertToStringUdf.java	17
samza-sql/src/main/java/org/apache/samza/sql/fn/FlattenUdf.java	18
samza-sql/src/main/java/org/apache/samza/sql/fn/GetSqlFieldUdf.java	60
samza-sql/src/main/java/org/apache/samza/sql/fn/RegexMatchUdf.java	18
samza-sql/src/main/java/org/apache/samza/sql/fn/GetNestedFieldUdf.java	19
samza-sql/src/main/java/org/apache/samza/sql/fn/BuildOutputRecordUdf.java	28
samza-sql/src/main/java/org/apache/samza/sql/util/JsonUtil.java	44
samza-sql/src/main/java/org/apache/samza/sql/util/SamzaSqlQueryParser.java	158
samza-sql/src/main/java/org/apache/samza/sql/util/SqlFileParser.java	47
samza-sql/src/main/java/org/apache/samza/sql/udf/ReflectionBasedUdfResolver.java	79
samza-sql/src/main/java/org/apache/samza/sql/runner/SamzaSqlApplicationContext.java	19
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/impl/ConfigBasedIOResolverFactory.java	84
samza-sql/src/main/java/org/apache/samza/sql/impl/ConfigBasedUdfResolver.java	80
samza-sql/src/main/java/org/apache/samza/sql/avro/AvroRelSchemaProvider.java	6
samza-sql/src/main/java/org/apache/samza/sql/avro/AvroRelConverter.java	249
samza-sql/src/main/java/org/apache/samza/sql/avro/AvroTypeFactoryImpl.java	95
samza-sql/src/main/java/org/apache/samza/sql/avro/ConfigBasedAvroRelSchemaProviderFactory.java	31
samza-sql/src/main/java/org/apache/samza/sql/avro/AvroRelConverterFactory.java	15
samza-sql/src/main/java/org/apache/samza/sql/dsl/SamzaSqlDslConverter.java	71
samza-sql/src/main/java/org/apache/samza/sql/dsl/SamzaSqlDslConverterFactory.java	10