Path	Lines of Code
samza-api/src/main/java/org/apache/samza/Partition.java	40
samza-api/src/main/java/org/apache/samza/SamzaException.java	16
samza-api/src/main/java/org/apache/samza/annotation/InterfaceStability.java	16
samza-api/src/main/java/org/apache/samza/application/ApplicationApiType.java	6
samza-api/src/main/java/org/apache/samza/application/SamzaApplication.java	10
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/ApplicationDescriptor.java	27
samza-api/src/main/java/org/apache/samza/application/descriptors/StreamApplicationDescriptor.java	16
samza-api/src/main/java/org/apache/samza/application/descriptors/TaskApplicationDescriptor.java	19
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/CheckpointListener.java	13
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/CheckpointV1.java	39
samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV2.java	59
samza-api/src/main/java/org/apache/samza/config/Config.java	196
samza-api/src/main/java/org/apache/samza/config/ConfigException.java	14
samza-api/src/main/java/org/apache/samza/config/ConfigFactory.java	5
samza-api/src/main/java/org/apache/samza/config/ConfigLoader.java	4
samza-api/src/main/java/org/apache/samza/config/ConfigLoaderFactory.java	5
samza-api/src/main/java/org/apache/samza/config/ConfigRewriter.java	4
samza-api/src/main/java/org/apache/samza/config/JavaTableConfig.java	43
samza-api/src/main/java/org/apache/samza/config/MapConfig.java	101
samza-api/src/main/java/org/apache/samza/container/TaskName.java	30
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/SystemStreamPartitionGrouperFactory.java	5
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/placement/ContainerPlacementMessage.java	76
samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementRequestMessage.java	26
samza-api/src/main/java/org/apache/samza/container/placement/ContainerPlacementResponseMessage.java	58
samza-api/src/main/java/org/apache/samza/context/ApplicationContainerContext.java	7
samza-api/src/main/java/org/apache/samza/context/ApplicationContainerContextFactory.java	15
samza-api/src/main/java/org/apache/samza/context/ApplicationTaskContext.java	8
samza-api/src/main/java/org/apache/samza/context/ApplicationTaskContextFactory.java	17
samza-api/src/main/java/org/apache/samza/context/ContainerContext.java	10
samza-api/src/main/java/org/apache/samza/context/Context.java	11
samza-api/src/main/java/org/apache/samza/context/ExternalContext.java	3
samza-api/src/main/java/org/apache/samza/context/JobContext.java	9
samza-api/src/main/java/org/apache/samza/context/TaskContext.java	23
samza-api/src/main/java/org/apache/samza/coordinator/lifecycle/JobRestartSignal.java	4
samza-api/src/main/java/org/apache/samza/coordinator/lifecycle/JobRestartSignalFactory.java	4
samza-api/src/main/java/org/apache/samza/coordinator/lifecycle/JobRestartSignalFactoryContext.java	11
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/job/ApplicationStatus.java	50
samza-api/src/main/java/org/apache/samza/job/CommandBuilder.java	28
samza-api/src/main/java/org/apache/samza/job/JobCoordinatorMetadata.java	49
samza-api/src/main/java/org/apache/samza/job/JobMetadataChange.java	6
samza-api/src/main/java/org/apache/samza/job/StreamJob.java	8
samza-api/src/main/java/org/apache/samza/job/StreamJobFactory.java	5
samza-api/src/main/java/org/apache/samza/job/model/ContainerModel.java	48
samza-api/src/main/java/org/apache/samza/job/model/JobModel.java	62
samza-api/src/main/java/org/apache/samza/job/model/LocalityModel.java	31
samza-api/src/main/java/org/apache/samza/job/model/ProcessorLocality.java	47
samza-api/src/main/java/org/apache/samza/job/model/TaskMode.java	12
samza-api/src/main/java/org/apache/samza/job/model/TaskModel.java	73
samza-api/src/main/java/org/apache/samza/metadatastore/InMemoryMetadataStore.java	29
samza-api/src/main/java/org/apache/samza/metadatastore/InMemoryMetadataStoreFactory.java	12
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/metrics/Counter.java	42
samza-api/src/main/java/org/apache/samza/metrics/Gauge.java	31
samza-api/src/main/java/org/apache/samza/metrics/Metric.java	4
samza-api/src/main/java/org/apache/samza/metrics/MetricsAccessor.java	7
samza-api/src/main/java/org/apache/samza/metrics/MetricsRegistry.java	9
samza-api/src/main/java/org/apache/samza/metrics/MetricsRegistryWithSource.java	15
samza-api/src/main/java/org/apache/samza/metrics/MetricsReporter.java	6
samza-api/src/main/java/org/apache/samza/metrics/MetricsReporterFactory.java	6
samza-api/src/main/java/org/apache/samza/metrics/MetricsValidationFailureException.java	9
samza-api/src/main/java/org/apache/samza/metrics/MetricsValidator.java	7
samza-api/src/main/java/org/apache/samza/metrics/MetricsVisitor.java	15
samza-api/src/main/java/org/apache/samza/metrics/ReadableMetricsRegistry.java	9
samza-api/src/main/java/org/apache/samza/metrics/ReadableMetricsRegistryListener.java	6
samza-api/src/main/java/org/apache/samza/metrics/Reservoir.java	6
samza-api/src/main/java/org/apache/samza/metrics/SamzaHistogram.java	52
samza-api/src/main/java/org/apache/samza/metrics/SlidingTimeWindowReservoir.java	75
samza-api/src/main/java/org/apache/samza/metrics/Snapshot.java	54
samza-api/src/main/java/org/apache/samza/metrics/Timer.java	34
samza-api/src/main/java/org/apache/samza/operators/KV.java	44
samza-api/src/main/java/org/apache/samza/operators/MessageStream.java	48
samza-api/src/main/java/org/apache/samza/operators/OutputStream.java	5
samza-api/src/main/java/org/apache/samza/operators/Scheduler.java	5
samza-api/src/main/java/org/apache/samza/operators/UpdateMessage.java	50
samza-api/src/main/java/org/apache/samza/operators/UpdateOptions.java	5
samza-api/src/main/java/org/apache/samza/operators/functions/AsyncFlatMapFunction.java	11
samza-api/src/main/java/org/apache/samza/operators/functions/ClosableFunction.java	6
samza-api/src/main/java/org/apache/samza/operators/functions/FilterFunction.java	8
samza-api/src/main/java/org/apache/samza/operators/functions/FlatMapFunction.java	9
samza-api/src/main/java/org/apache/samza/operators/functions/FoldLeftFunction.java	8
samza-api/src/main/java/org/apache/samza/operators/functions/InitableFunction.java	7
samza-api/src/main/java/org/apache/samza/operators/functions/JoinFunction.java	9
samza-api/src/main/java/org/apache/samza/operators/functions/MapFunction.java	8
samza-api/src/main/java/org/apache/samza/operators/functions/ScheduledFunction.java	7
samza-api/src/main/java/org/apache/samza/operators/functions/SinkFunction.java	10
samza-api/src/main/java/org/apache/samza/operators/functions/StreamTableJoinFunction.java	9
samza-api/src/main/java/org/apache/samza/operators/functions/SupplierFunction.java	8
samza-api/src/main/java/org/apache/samza/operators/functions/WatermarkFunction.java	6
samza-api/src/main/java/org/apache/samza/operators/triggers/AnyTrigger.java	14
samza-api/src/main/java/org/apache/samza/operators/triggers/CountTrigger.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/FiringType.java	6
samza-api/src/main/java/org/apache/samza/operators/triggers/RepeatingTrigger.java	10
samza-api/src/main/java/org/apache/samza/operators/triggers/TimeBasedTrigger.java	7
samza-api/src/main/java/org/apache/samza/operators/triggers/TimeSinceFirstMessageTrigger.java	16
samza-api/src/main/java/org/apache/samza/operators/triggers/TimeSinceLastMessageTrigger.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/Trigger.java	6
samza-api/src/main/java/org/apache/samza/operators/triggers/Triggers.java	29
samza-api/src/main/java/org/apache/samza/operators/windows/AccumulationMode.java	4
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/WindowPane.java	23
samza-api/src/main/java/org/apache/samza/operators/windows/Windows.java	54
samza-api/src/main/java/org/apache/samza/operators/windows/internal/WindowInternal.java	106
samza-api/src/main/java/org/apache/samza/operators/windows/internal/WindowType.java	4
samza-api/src/main/java/org/apache/samza/runtime/ApplicationRunner.java	16
samza-api/src/main/java/org/apache/samza/runtime/LocationId.java	29
samza-api/src/main/java/org/apache/samza/runtime/LocationIdProvider.java	4
samza-api/src/main/java/org/apache/samza/runtime/LocationIdProviderFactory.java	5
samza-api/src/main/java/org/apache/samza/runtime/ProcessorContext.java	5
samza-api/src/main/java/org/apache/samza/runtime/ProcessorIdGenerator.java	7
samza-api/src/main/java/org/apache/samza/runtime/ProcessorLifecycleListener.java	9
samza-api/src/main/java/org/apache/samza/runtime/ProcessorLifecycleListenerFactory.java	8
samza-api/src/main/java/org/apache/samza/scheduler/CallbackScheduler.java	5
samza-api/src/main/java/org/apache/samza/scheduler/ScheduledCallback.java	6
samza-api/src/main/java/org/apache/samza/serializers/ByteBufferSerde.java	22
samza-api/src/main/java/org/apache/samza/serializers/ByteBufferSerdeFactory.java	9
samza-api/src/main/java/org/apache/samza/serializers/ByteSerde.java	11
samza-api/src/main/java/org/apache/samza/serializers/ByteSerdeFactory.java	8
samza-api/src/main/java/org/apache/samza/serializers/Deserializer.java	4
samza-api/src/main/java/org/apache/samza/serializers/DoubleSerde.java	20
samza-api/src/main/java/org/apache/samza/serializers/DoubleSerdeFactory.java	8
samza-api/src/main/java/org/apache/samza/serializers/IntegerSerde.java	20
samza-api/src/main/java/org/apache/samza/serializers/IntegerSerdeFactory.java	8
samza-api/src/main/java/org/apache/samza/serializers/JsonSerdeV2.java	63
samza-api/src/main/java/org/apache/samza/serializers/JsonSerdeV2Factory.java	8
samza-api/src/main/java/org/apache/samza/serializers/KVSerde.java	53
samza-api/src/main/java/org/apache/samza/serializers/LongSerde.java	20
samza-api/src/main/java/org/apache/samza/serializers/LongSerdeFactory.java	8
samza-api/src/main/java/org/apache/samza/serializers/NoOpSerde.java	12
samza-api/src/main/java/org/apache/samza/serializers/Serde.java	4
samza-api/src/main/java/org/apache/samza/serializers/SerdeFactory.java	5
samza-api/src/main/java/org/apache/samza/serializers/SerializableSerde.java	57
samza-api/src/main/java/org/apache/samza/serializers/SerializableSerdeFactory.java	9
samza-api/src/main/java/org/apache/samza/serializers/Serializer.java	4
samza-api/src/main/java/org/apache/samza/serializers/StringSerde.java	36
samza-api/src/main/java/org/apache/samza/serializers/StringSerdeFactory.java	8
samza-api/src/main/java/org/apache/samza/serializers/UUIDSerde.java	25
samza-api/src/main/java/org/apache/samza/serializers/UUIDSerdeFactory.java	9
samza-api/src/main/java/org/apache/samza/sql/SamzaSqlRelRecord.java	67
samza-api/src/main/java/org/apache/samza/sql/schema/SamzaSqlFieldType.java	19
samza-api/src/main/java/org/apache/samza/sql/schema/SqlFieldSchema.java	54
samza-api/src/main/java/org/apache/samza/sql/schema/SqlSchema.java	52
samza-api/src/main/java/org/apache/samza/sql/schema/SqlSchemaBuilder.java	22
samza-api/src/main/java/org/apache/samza/sql/udfs/SamzaSqlUdf.java	12
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/startpoint/Startpoint.java	40
samza-api/src/main/java/org/apache/samza/startpoint/StartpointOldest.java	15
samza-api/src/main/java/org/apache/samza/startpoint/StartpointSpecific.java	42
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/StartpointVisitor.java	18
samza-api/src/main/java/org/apache/samza/storage/BlobStoreAdminFactory.java	6
samza-api/src/main/java/org/apache/samza/storage/KafkaChangelogRestoreParams.java	46
samza-api/src/main/java/org/apache/samza/storage/SideInputsProcessor.java	12
samza-api/src/main/java/org/apache/samza/storage/SideInputsProcessorFactory.java	10
samza-api/src/main/java/org/apache/samza/storage/StateBackendAdmin.java	5
samza-api/src/main/java/org/apache/samza/storage/StateBackendFactory.java	38
samza-api/src/main/java/org/apache/samza/storage/StorageEngine.java	16
samza-api/src/main/java/org/apache/samza/storage/StorageEngineFactory.java	27
samza-api/src/main/java/org/apache/samza/storage/StoreProperties.java	43
samza-api/src/main/java/org/apache/samza/storage/TaskBackupManager.java	13
samza-api/src/main/java/org/apache/samza/storage/TaskRestoreManager.java	8
samza-api/src/main/java/org/apache/samza/storage/blobstore/BlobStoreManager.java	14
samza-api/src/main/java/org/apache/samza/storage/blobstore/BlobStoreManagerFactory.java	9
samza-api/src/main/java/org/apache/samza/storage/blobstore/Metadata.java	73
samza-api/src/main/java/org/apache/samza/storage/blobstore/exceptions/DeletedException.java	15
samza-api/src/main/java/org/apache/samza/storage/blobstore/exceptions/RetriableException.java	15
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/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/kv/KeyValueStore.java	44
samza-api/src/main/java/org/apache/samza/system/BoundedSSPIterator.java	51
samza-api/src/main/java/org/apache/samza/system/ChangelogSSPIterator.java	34
samza-api/src/main/java/org/apache/samza/system/ControlMessage.java	43
samza-api/src/main/java/org/apache/samza/system/DrainMessage.java	38
samza-api/src/main/java/org/apache/samza/system/EndOfStreamMessage.java	12
samza-api/src/main/java/org/apache/samza/system/IncomingMessageEnvelope.java	129
samza-api/src/main/java/org/apache/samza/system/MessageType.java	18
samza-api/src/main/java/org/apache/samza/system/OutgoingMessageEnvelope.java	101
samza-api/src/main/java/org/apache/samza/system/StreamSpec.java	114
samza-api/src/main/java/org/apache/samza/system/StreamValidationException.java	8
samza-api/src/main/java/org/apache/samza/system/SystemAdmin.java	53
samza-api/src/main/java/org/apache/samza/system/SystemConsumer.java	11
samza-api/src/main/java/org/apache/samza/system/SystemFactory.java	20
samza-api/src/main/java/org/apache/samza/system/SystemProducer.java	8
samza-api/src/main/java/org/apache/samza/system/SystemProducerException.java	14
samza-api/src/main/java/org/apache/samza/system/SystemStream.java	51
samza-api/src/main/java/org/apache/samza/system/SystemStreamMetadata.java	130
samza-api/src/main/java/org/apache/samza/system/SystemStreamPartition.java	101
samza-api/src/main/java/org/apache/samza/system/SystemStreamPartitionIterator.java	58
samza-api/src/main/java/org/apache/samza/system/SystemStreamPartitionMatcher.java	6
samza-api/src/main/java/org/apache/samza/system/WatermarkMessage.java	41
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/chooser/MessageChooserFactory.java	6
samza-api/src/main/java/org/apache/samza/system/descriptors/ExpandingInputDescriptorProvider.java	5
samza-api/src/main/java/org/apache/samza/system/descriptors/GenericInputDescriptor.java	8
samza-api/src/main/java/org/apache/samza/system/descriptors/GenericOutputDescriptor.java	8
samza-api/src/main/java/org/apache/samza/system/descriptors/GenericSystemDescriptor.java	18
samza-api/src/main/java/org/apache/samza/system/descriptors/InputDescriptor.java	77
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/OutputDescriptorProvider.java	5
samza-api/src/main/java/org/apache/samza/system/descriptors/SimpleInputDescriptorProvider.java	5
samza-api/src/main/java/org/apache/samza/system/descriptors/StreamDescriptor.java	68
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/TransformingInputDescriptorProvider.java	5
samza-api/src/main/java/org/apache/samza/table/AsyncReadWriteUpdateTable.java	27
samza-api/src/main/java/org/apache/samza/table/ReadWriteTable.java	27
samza-api/src/main/java/org/apache/samza/table/ReadWriteUpdateTable.java	23
samza-api/src/main/java/org/apache/samza/table/RecordNotFoundException.java	16
samza-api/src/main/java/org/apache/samza/table/Table.java	14
samza-api/src/main/java/org/apache/samza/table/TableProvider.java	9
samza-api/src/main/java/org/apache/samza/table/TableProviderFactory.java	6
samza-api/src/main/java/org/apache/samza/table/batching/Batch.java	18
samza-api/src/main/java/org/apache/samza/table/batching/BatchProvider.java	23
samza-api/src/main/java/org/apache/samza/table/batching/Operation.java	7
samza-api/src/main/java/org/apache/samza/table/descriptors/BaseTableDescriptor.java	39
samza-api/src/main/java/org/apache/samza/table/descriptors/CachingTableDescriptor.java	89
samza-api/src/main/java/org/apache/samza/table/descriptors/GuavaCacheTableDescriptor.java	34
samza-api/src/main/java/org/apache/samza/table/descriptors/HybridTableDescriptor.java	9
samza-api/src/main/java/org/apache/samza/table/descriptors/LocalTableDescriptor.java	108
samza-api/src/main/java/org/apache/samza/table/descriptors/RemoteTableDescriptor.java	200
samza-api/src/main/java/org/apache/samza/table/descriptors/TableDescriptor.java	17
samza-api/src/main/java/org/apache/samza/table/remote/BaseTableFunction.java	13
samza-api/src/main/java/org/apache/samza/table/remote/TableFunction.java	11
samza-api/src/main/java/org/apache/samza/table/remote/TablePart.java	11
samza-api/src/main/java/org/apache/samza/table/remote/TableRateLimiter.java	78
samza-api/src/main/java/org/apache/samza/table/remote/TableReadFunction.java	46
samza-api/src/main/java/org/apache/samza/table/remote/TableWriteFunction.java	79
samza-api/src/main/java/org/apache/samza/table/retry/TableRetryPolicy.java	109
samza-api/src/main/java/org/apache/samza/table/utils/SerdeUtils.java	57
samza-api/src/main/java/org/apache/samza/task/AsyncStreamTask.java	5
samza-api/src/main/java/org/apache/samza/task/AsyncStreamTaskFactory.java	5
samza-api/src/main/java/org/apache/samza/task/ClosableTask.java	7
samza-api/src/main/java/org/apache/samza/task/DrainListenerTask.java	4
samza-api/src/main/java/org/apache/samza/task/EndOfStreamListenerTask.java	4
samza-api/src/main/java/org/apache/samza/task/InitableTask.java	5
samza-api/src/main/java/org/apache/samza/task/MessageCollector.java	5
samza-api/src/main/java/org/apache/samza/task/StreamOperatorTaskFactory.java	4
samza-api/src/main/java/org/apache/samza/task/StreamTask.java	5
samza-api/src/main/java/org/apache/samza/task/StreamTaskFactory.java	5
samza-api/src/main/java/org/apache/samza/task/TaskCallback.java	5
samza-api/src/main/java/org/apache/samza/task/TaskCoordinator.java	9
samza-api/src/main/java/org/apache/samza/task/TaskExecutorFactory.java	12
samza-api/src/main/java/org/apache/samza/task/TaskFactory.java	7
samza-api/src/main/java/org/apache/samza/task/WindowableTask.java	4
samza-api/src/main/java/org/apache/samza/util/BlockingEnvelopeMap.java	208
samza-api/src/main/java/org/apache/samza/util/Clock.java	4
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