Path	Lines of Code
samza-api/src/test/java/org/apache/samza/checkpoint/TestCheckpointId.java	24
samza-api/src/test/java/org/apache/samza/config/TestConfig.java	84
samza-api/src/test/java/org/apache/samza/metrics/TestSamzaHistogram.java	23
samza-api/src/test/java/org/apache/samza/metrics/TestSlidingTimeWindowReservoir.java	55
samza-api/src/test/java/org/apache/samza/metrics/TestSnapshot.java	22
samza-api/src/test/java/org/apache/samza/metrics/TestTimer.java	37
samza-api/src/test/java/org/apache/samza/operators/windows/TestWindowPane.java	12
samza-api/src/test/java/org/apache/samza/serializers/TestByteBufferSerde.java	30
samza-api/src/test/java/org/apache/samza/serializers/TestByteSerde.java	15
samza-api/src/test/java/org/apache/samza/serializers/TestDoubleSerde.java	17
samza-api/src/test/java/org/apache/samza/serializers/TestIntegerSerde.java	17
samza-api/src/test/java/org/apache/samza/serializers/TestJsonSerdeV2.java	25
samza-api/src/test/java/org/apache/samza/serializers/TestLongSerde.java	17
samza-api/src/test/java/org/apache/samza/serializers/TestSerializableSerde.java	31
samza-api/src/test/java/org/apache/samza/serializers/TestStringSerde.java	18
samza-api/src/test/java/org/apache/samza/serializers/TestUUIDSerde.java	29
samza-api/src/test/java/org/apache/samza/sql/TestSamzaSqlRelRecord.java	20
samza-api/src/test/java/org/apache/samza/startpoint/TestStartpoint.java	65
samza-api/src/test/java/org/apache/samza/system/TestBoundedSSPIterator.java	82
samza-api/src/test/java/org/apache/samza/system/TestStreamSpec.java	27
samza-api/src/test/java/org/apache/samza/system/TestSystemAdmin.java	74
samza-api/src/test/java/org/apache/samza/system/TestSystemStreamPartitionIterator.java	80
samza-api/src/test/java/org/apache/samza/system/descriptors/TestExpandingInputDescriptor.java	32
samza-api/src/test/java/org/apache/samza/system/descriptors/TestGenericInputDescriptor.java	87
samza-api/src/test/java/org/apache/samza/system/descriptors/TestGenericSystemDescriptor.java	37
samza-api/src/test/java/org/apache/samza/system/descriptors/TestSimpleInputDescriptor.java	36
samza-api/src/test/java/org/apache/samza/system/descriptors/TestTransformingInputDescriptor.java	37
samza-api/src/test/java/org/apache/samza/table/TestBaseTableDescriptor.java	46
samza-api/src/test/java/org/apache/samza/table/remote/TestTableRateLimiter.java	85
samza-api/src/test/java/org/apache/samza/util/TestBlockingEnvelopeMap.java	177
samza-api/src/test/java/org/apache/samza/util/TestNoOpMetricsRegistry.java	42
samza-api/src/test/java/org/apache/samza/util/TestSinglePartitionWithoutOffsetsSystemAdmin.java	26
samza-aws/src/test/java/org/apache/samza/system/kinesis/TestKinesisAWSCredentialsProvider.java	33
samza-aws/src/test/java/org/apache/samza/system/kinesis/TestKinesisConfig.java	82
samza-aws/src/test/java/org/apache/samza/system/kinesis/TestKinesisSystemFactory.java	84
samza-aws/src/test/java/org/apache/samza/system/kinesis/consumer/TestKinesisRecordProcessor.java	194
samza-aws/src/test/java/org/apache/samza/system/kinesis/consumer/TestKinesisSystemConsumer.java	187
samza-aws/src/test/java/org/apache/samza/system/kinesis/consumer/TestKinesisSystemConsumerOffset.java	21
samza-aws/src/test/java/org/apache/samza/system/kinesis/consumer/TestSSPAllocator.java	89
samza-aws/src/test/java/org/apache/samza/system/kinesis/descriptors/TestKinesisInputDescriptor.java	34
samza-aws/src/test/java/org/apache/samza/system/kinesis/descriptors/TestKinesisSystemDescriptor.java	32
samza-azure/src/test/java/org/apache/samza/checkpoint/azure/ITestAzureCheckpointManager.java	127
samza-azure/src/test/java/org/apache/samza/system/azureblob/avro/TestAzureBlobAvroWriter.java	490
samza-azure/src/test/java/org/apache/samza/system/azureblob/avro/TestAzureBlobOutputStream.java	366
samza-azure/src/test/java/org/apache/samza/system/azureblob/compression/TestGzipCompression.java	46
samza-azure/src/test/java/org/apache/samza/system/azureblob/producer/TestAzureBlobSystemProducer.java	461
samza-azure/src/test/java/org/apache/samza/system/azureblob/utils/TestNullBlobMetadataGenerator.java	23
samza-azure/src/test/java/org/apache/samza/system/eventhub/MockEventData.java	71
samza-azure/src/test/java/org/apache/samza/system/eventhub/MockEventHubClientManagerFactory.java	161
samza-azure/src/test/java/org/apache/samza/system/eventhub/MockEventHubConfigFactory.java	31
samza-azure/src/test/java/org/apache/samza/system/eventhub/TestMetricsRegistry.java	57
samza-azure/src/test/java/org/apache/samza/system/eventhub/admin/TestEventHubSystemAdmin.java	114
samza-azure/src/test/java/org/apache/samza/system/eventhub/consumer/ITestEventHubSystemConsumer.java	47
samza-azure/src/test/java/org/apache/samza/system/eventhub/consumer/TestEventHubSystemConsumer.java	335
samza-azure/src/test/java/org/apache/samza/system/eventhub/descriptors/TestEventHubsInputDescriptor.java	73
samza-azure/src/test/java/org/apache/samza/system/eventhub/descriptors/TestEventHubsOutputDescriptor.java	71
samza-azure/src/test/java/org/apache/samza/system/eventhub/descriptors/TestEventHubsSystemDescriptor.java	73
samza-azure/src/test/java/org/apache/samza/system/eventhub/producer/ITestEventHubSystemProducer.java	125
samza-azure/src/test/java/org/apache/samza/system/eventhub/producer/SwapFirstLastByteInterceptor.java	13
samza-azure/src/test/java/org/apache/samza/system/eventhub/producer/TestEventHubSystemProducer.java	263
samza-azure/src/test/resources/log4j.xml	18
samza-azure/src/test/resources/log4j2.xml	16
samza-core/src/test/java/org/apache/samza/application/MockStreamApplication.java	7
samza-core/src/test/java/org/apache/samza/application/TestApplicationUtil.java	61
samza-core/src/test/java/org/apache/samza/application/descriptors/TestStreamApplicationDescriptorImpl.java	507
samza-core/src/test/java/org/apache/samza/application/descriptors/TestTaskApplicationDescriptorImpl.java	133
samza-core/src/test/java/org/apache/samza/checkpoint/kafka/TestKafkaChangelogSSPOffset.java	39
samza-core/src/test/java/org/apache/samza/checkpoint/kafka/TestKafkaStateCheckpointMarker.java	80
samza-core/src/test/java/org/apache/samza/clustermanager/MockClusterResourceManager.java	96
samza-core/src/test/java/org/apache/samza/clustermanager/MockClusterResourceManagerCallback.java	29
samza-core/src/test/java/org/apache/samza/clustermanager/MockClusterResourceManagerFactory.java	8
samza-core/src/test/java/org/apache/samza/clustermanager/MockContainerAllocatorWithHostAffinity.java	30
samza-core/src/test/java/org/apache/samza/clustermanager/MockContainerAllocatorWithoutHostAffinity.java	64
samza-core/src/test/java/org/apache/samza/clustermanager/MockContainerListener.java	99
samza-core/src/test/java/org/apache/samza/clustermanager/MockContainerRequestState.java	55
samza-core/src/test/java/org/apache/samza/clustermanager/MockFaultDomainManager.java	34
samza-core/src/test/java/org/apache/samza/clustermanager/MockFaultDomainManagerFactory.java	9
samza-core/src/test/java/org/apache/samza/clustermanager/TestClusterBasedJobCoordinator.java	200
samza-core/src/test/java/org/apache/samza/clustermanager/TestClusterBasedJobCoordinatorRunner.java	49
samza-core/src/test/java/org/apache/samza/clustermanager/TestContainerAllocatorWithHostAffinity.java	491
samza-core/src/test/java/org/apache/samza/clustermanager/TestContainerAllocatorWithoutHostAffinity.java	253
samza-core/src/test/java/org/apache/samza/clustermanager/TestContainerPlacementActions.java	784
samza-core/src/test/java/org/apache/samza/clustermanager/TestContainerProcessManager.java	800
samza-core/src/test/java/org/apache/samza/clustermanager/TestContainerRequestState.java	197
samza-core/src/test/java/org/apache/samza/clustermanager/TestDefaultApplicationMain.java	48
samza-core/src/test/java/org/apache/samza/clustermanager/TestJobCoordinatorLaunchUtil.java	150
samza-core/src/test/java/org/apache/samza/clustermanager/TestStandbyAllocator.java	85
samza-core/src/test/java/org/apache/samza/clustermanager/container/placement/TestContainerPlacementMetadataStore.java	130
samza-core/src/test/java/org/apache/samza/clustermanager/container/placement/TestContainerPlacementObjectMapper.java	49
samza-core/src/test/java/org/apache/samza/config/EnvironmentConfigRewriterTest.java	44
samza-core/src/test/java/org/apache/samza/config/TestApplicationConfig.java	29
samza-core/src/test/java/org/apache/samza/config/TestFileSystemCheckpointManagerConfig.java	17
samza-core/src/test/java/org/apache/samza/config/TestJavaTableConfig.java	50
samza-core/src/test/java/org/apache/samza/config/TestJobConfig.java	536
samza-core/src/test/java/org/apache/samza/config/TestJobCoordinatorConfig.java	41
samza-core/src/test/java/org/apache/samza/config/TestMetricsConfig.java	78
samza-core/src/test/java/org/apache/samza/config/TestRunLoopConfig.java	25
samza-core/src/test/java/org/apache/samza/config/TestSerializerConfig.java	55
samza-core/src/test/java/org/apache/samza/config/TestShellCommandConfig.java	107
samza-core/src/test/java/org/apache/samza/config/TestStorageConfig.java	450
samza-core/src/test/java/org/apache/samza/config/TestStreamConfig.java	489
samza-core/src/test/java/org/apache/samza/config/TestSystemConfig.java	193
samza-core/src/test/java/org/apache/samza/config/TestTaskConfig.java	279
samza-core/src/test/java/org/apache/samza/config/loaders/TestPropertiesConfigLoader.java	22
samza-core/src/test/java/org/apache/samza/container/TestContainerHeartbeatClient.java	52
samza-core/src/test/java/org/apache/samza/container/TestContainerHeartbeatMonitor.java	190
samza-core/src/test/java/org/apache/samza/container/TestExecutionContainerIdManager.java	69
samza-core/src/test/java/org/apache/samza/container/TestLocalityManager.java	74
samza-core/src/test/java/org/apache/samza/container/TestRunLoop.java	626
samza-core/src/test/java/org/apache/samza/container/TestSamzaContainerMonitorListener.java	51
samza-core/src/test/java/org/apache/samza/container/TestSamzaUncaughtExceptionHandler.java	16
samza-core/src/test/java/org/apache/samza/container/disk/TestDiskQuotaPolicyEntry.java	53
samza-core/src/test/java/org/apache/samza/container/disk/TestPollingScanDiskSpaceMonitor.java	177
samza-core/src/test/java/org/apache/samza/container/disk/TestWatermarkDiskQuotaPolicy.java	113
samza-core/src/test/java/org/apache/samza/container/grouper/stream/TestAllSspToSingleTaskGrouper.java	80
samza-core/src/test/java/org/apache/samza/container/grouper/stream/TestGroupByPartition.java	71
samza-core/src/test/java/org/apache/samza/container/grouper/stream/TestGroupByPartitionWithGrouperProxy.java	297
samza-core/src/test/java/org/apache/samza/container/grouper/stream/TestGroupBySystemStreamPartition.java	66
samza-core/src/test/java/org/apache/samza/container/grouper/stream/TestGroupBySystemStreamPartitionWithGrouperProxy.java	307
samza-core/src/test/java/org/apache/samza/container/grouper/task/TestGroupByContainerCount.java	402
samza-core/src/test/java/org/apache/samza/container/grouper/task/TestGroupByContainerIds.java	366
samza-core/src/test/java/org/apache/samza/container/grouper/task/TestTaskAssignmentManager.java	68
samza-core/src/test/java/org/apache/samza/container/grouper/task/TestTaskNameGrouperProxy.java	82
samza-core/src/test/java/org/apache/samza/container/grouper/task/TestTaskPartitionAssignmentManager.java	84
samza-core/src/test/java/org/apache/samza/container/host/TestDefaultSystemStatisticsGetter.java	29
samza-core/src/test/java/org/apache/samza/container/host/TestOshiBasedStatisticsGetter.java	63
samza-core/src/test/java/org/apache/samza/container/host/TestStatisticsMonitorImpl.java	60
samza-core/src/test/java/org/apache/samza/container/mock/ContainerMocks.java	93
samza-core/src/test/java/org/apache/samza/context/MockContext.java	45
samza-core/src/test/java/org/apache/samza/context/TestContextImpl.java	58
samza-core/src/test/java/org/apache/samza/context/TestInternalTaskContext.java	19
samza-core/src/test/java/org/apache/samza/context/TestTaskContextImpl.java	61
samza-core/src/test/java/org/apache/samza/coordinator/JobModelManagerTestUtil.java	18
samza-core/src/test/java/org/apache/samza/coordinator/TestJobModelCalculator.java	402
samza-core/src/test/java/org/apache/samza/coordinator/TestJobModelHelper.java	399
samza-core/src/test/java/org/apache/samza/coordinator/TestJobModelMonitors.java	39
samza-core/src/test/java/org/apache/samza/coordinator/TestMetadataResourceUtil.java	49
samza-core/src/test/java/org/apache/samza/coordinator/TestNoProcessorJobCoordinatorListener.java	27
samza-core/src/test/java/org/apache/samza/coordinator/TestRunIdGenerator.java	52
samza-core/src/test/java/org/apache/samza/coordinator/communication/TestHttpCoordinatorCommunication.java	34
samza-core/src/test/java/org/apache/samza/coordinator/communication/TestJobModelHttpServlet.java	93
samza-core/src/test/java/org/apache/samza/coordinator/communication/TestJobModelServingContext.java	49
samza-core/src/test/java/org/apache/samza/coordinator/metadatastore/CoordinatorStreamStoreTestUtil.java	34
samza-core/src/test/java/org/apache/samza/coordinator/metadatastore/TestCoordinatorStreamStore.java	103
samza-core/src/test/java/org/apache/samza/coordinator/metadatastore/TestNamespaceAwareCoordinatorStreamStore.java	74
samza-core/src/test/java/org/apache/samza/coordinator/staticresource/TestStaticResourceJobCoordinator.java	405
samza-core/src/test/java/org/apache/samza/coordinator/stream/MockCoordinatorStreamSystemFactory.java	202
samza-core/src/test/java/org/apache/samza/coordinator/stream/MockCoordinatorStreamWrappedConsumer.java	73
samza-core/src/test/java/org/apache/samza/coordinator/stream/TestCoordinatorStreamMessage.java	75
samza-core/src/test/java/org/apache/samza/coordinator/stream/TestCoordinatorStreamSystemConsumer.java	158
samza-core/src/test/java/org/apache/samza/coordinator/stream/TestCoordinatorStreamSystemProducer.java	85
samza-core/src/test/java/org/apache/samza/coordinator/stream/TestCoordinatorStreamWriter.java	100
samza-core/src/test/java/org/apache/samza/diagnostics/TestDiagnosticsManager.java	240
samza-core/src/test/java/org/apache/samza/diagnostics/TestDiagnosticsStreamMessage.java	123
samza-core/src/test/java/org/apache/samza/drain/DrainMonitorTests.java	125
samza-core/src/test/java/org/apache/samza/drain/DrainNotificationObjectMapperTests.java	17
samza-core/src/test/java/org/apache/samza/drain/DrainUtilsTests.java	98
samza-core/src/test/java/org/apache/samza/execution/ExecutionPlannerTestBase.java	118
samza-core/src/test/java/org/apache/samza/execution/TestExecutionPlanner.java	619
samza-core/src/test/java/org/apache/samza/execution/TestIntermediateStreamManager.java	74
samza-core/src/test/java/org/apache/samza/execution/TestJobGraph.java	186
samza-core/src/test/java/org/apache/samza/execution/TestJobGraphJsonGenerator.java	315
samza-core/src/test/java/org/apache/samza/execution/TestJobNodeConfigurationGenerator.java	299
samza-core/src/test/java/org/apache/samza/execution/TestJobPlanner.java	59
samza-core/src/test/java/org/apache/samza/execution/TestLocalJobPlanner.java	155
samza-core/src/test/java/org/apache/samza/execution/TestRemoteJobPlanner.java	55
samza-core/src/test/java/org/apache/samza/execution/TestStreamEdge.java	53
samza-core/src/test/java/org/apache/samza/execution/TestStreamManager.java	105
samza-core/src/test/java/org/apache/samza/executors/TestKeyBasedExecutorService.java	58
samza-core/src/test/java/org/apache/samza/job/TestShellCommandBuilder.java	62
samza-core/src/test/java/org/apache/samza/job/metadata/TestJobCoordinatorMetadataManager.java	268
samza-core/src/test/java/org/apache/samza/job/model/TestJobModel.java	28
samza-core/src/test/java/org/apache/samza/job/model/TestJobModelUtil.java	141
samza-core/src/test/java/org/apache/samza/logging/TestLoggingContextHolder.java	32
samza-core/src/test/java/org/apache/samza/metrics/TestJmxMetricsAccessor.java	64
samza-core/src/test/java/org/apache/samza/metrics/reporter/TestLoggingMetricsReporter.java	146
samza-core/src/test/java/org/apache/samza/metrics/reporter/TestLoggingMetricsReporterConfig.java	27
samza-core/src/test/java/org/apache/samza/metrics/reporter/TestMetrics.java	27
samza-core/src/test/java/org/apache/samza/metrics/reporter/TestMetricsHeader.java	67
samza-core/src/test/java/org/apache/samza/metrics/reporter/TestMetricsSnapshot.java	27
samza-core/src/test/java/org/apache/samza/metrics/reporter/TestMetricsSnapshotReporter.java	130
samza-core/src/test/java/org/apache/samza/metrics/reporter/TestMetricsSnapshotReporterFactory.java	84
samza-core/src/test/java/org/apache/samza/operators/TestJoinOperator.java	292
samza-core/src/test/java/org/apache/samza/operators/TestMessageStreamImpl.java	359
samza-core/src/test/java/org/apache/samza/operators/TestOperatorSpecGraph.java	135
samza-core/src/test/java/org/apache/samza/operators/data/TestMessageEnvelope.java	15
samza-core/src/test/java/org/apache/samza/operators/data/TestOutputMessageEnvelope.java	27
samza-core/src/test/java/org/apache/samza/operators/impl/TestAsyncFlatmapOperatorImpl.java	46
samza-core/src/test/java/org/apache/samza/operators/impl/TestControlMessageSender.java	74
samza-core/src/test/java/org/apache/samza/operators/impl/TestEndOfStreamStates.java	48
samza-core/src/test/java/org/apache/samza/operators/impl/TestFlatmapOperatorImpl.java	45
samza-core/src/test/java/org/apache/samza/operators/impl/TestInputOperatorImpl.java	60
samza-core/src/test/java/org/apache/samza/operators/impl/TestOperatorImpl.java	275
samza-core/src/test/java/org/apache/samza/operators/impl/TestOperatorImplGraph.java	571
samza-core/src/test/java/org/apache/samza/operators/impl/TestSinkOperatorImpl.java	41
samza-core/src/test/java/org/apache/samza/operators/impl/TestStreamTableJoinOperatorImpl.java	98
samza-core/src/test/java/org/apache/samza/operators/impl/TestWatermarkStates.java	166
samza-core/src/test/java/org/apache/samza/operators/impl/TestWindowOperator.java	484
samza-core/src/test/java/org/apache/samza/operators/impl/store/TestInMemoryStore.java	118
samza-core/src/test/java/org/apache/samza/operators/impl/store/TestTimeSeriesKeySerde.java	40
samza-core/src/test/java/org/apache/samza/operators/impl/store/TestTimeSeriesStoreImpl.java	114
samza-core/src/test/java/org/apache/samza/operators/impl/store/TestTimestampedValueSerde.java	28
samza-core/src/test/java/org/apache/samza/operators/spec/OperatorSpecTestUtils.java	90
samza-core/src/test/java/org/apache/samza/operators/spec/TestOperatorSpec.java	366
samza-core/src/test/java/org/apache/samza/operators/spec/TestPartitionByOperatorSpec.java	163
samza-core/src/test/java/org/apache/samza/operators/spec/TestWindowOperatorSpec.java	252
samza-core/src/test/java/org/apache/samza/processor/TestStreamProcessor.java	472
samza-core/src/test/java/org/apache/samza/runtime/MockProcessorIdGenerator.java	8
samza-core/src/test/java/org/apache/samza/runtime/TestApplicationRunnerMain.java	96
samza-core/src/test/java/org/apache/samza/runtime/TestApplicationRunners.java	50
samza-core/src/test/java/org/apache/samza/runtime/TestClusterBasedProcessorLifecycleListener.java	58
samza-core/src/test/java/org/apache/samza/runtime/TestContainerLaunchUtil.java	62
samza-core/src/test/java/org/apache/samza/runtime/TestLocalApplicationRunner.java	461
samza-core/src/test/java/org/apache/samza/runtime/TestRemoteApplicationRunner.java	151
samza-core/src/test/java/org/apache/samza/scheduler/TestCallbackSchedulerImpl.java	35
samza-core/src/test/java/org/apache/samza/scheduler/TestEpochTimeScheduler.java	224
samza-core/src/test/java/org/apache/samza/serializers/TestCheckpointV2Serde.java	53
samza-core/src/test/java/org/apache/samza/serializers/TestMetricsSnapshotSerde.java	71
samza-core/src/test/java/org/apache/samza/serializers/model/TestSamzaObjectMapper.java	375
samza-core/src/test/java/org/apache/samza/serializers/model/serializers/TestIntermediateMessageSerde.java	119
samza-core/src/test/java/org/apache/samza/serializers/model/serializers/TestMetricsSnapshotSerdeV2.java	101
samza-core/src/test/java/org/apache/samza/startpoint/StartpointManagerTestUtil.java	28
samza-core/src/test/java/org/apache/samza/startpoint/StartpointMock.java	14
samza-core/src/test/java/org/apache/samza/startpoint/TestStartpointManager.java	311
samza-core/src/test/java/org/apache/samza/startpoint/TestStartpointObjectMapper.java	52
samza-core/src/test/java/org/apache/samza/storage/MockStorageEngine.java	48
samza-core/src/test/java/org/apache/samza/storage/MockStorageEngineFactory.java	23
samza-core/src/test/java/org/apache/samza/storage/TestChangelogStreamManager.java	87
samza-core/src/test/java/org/apache/samza/storage/TestKafkaChangelogStateBackendFactory.java	56
samza-core/src/test/java/org/apache/samza/storage/TestStorageRecovery.java	68
samza-core/src/test/java/org/apache/samza/storage/TestTaskSideInputHandler.java	148
samza-core/src/test/java/org/apache/samza/storage/TestTaskSideInputStorageManager.java	162
samza-core/src/test/java/org/apache/samza/storage/TestTaskStorageCommitManager.java	744
samza-core/src/test/java/org/apache/samza/storage/TestTransactionalStateTaskRestoreManager.java	1612
samza-core/src/test/java/org/apache/samza/storage/blobstore/TestBlobStoreBackupManager.java	418
samza-core/src/test/java/org/apache/samza/storage/blobstore/TestBlobStoreRestoreManager.java	272
samza-core/src/test/java/org/apache/samza/storage/blobstore/index/TestDirIndex.java	40
samza-core/src/test/java/org/apache/samza/storage/blobstore/serde/TestSnapshotIndexSerde.java	30
samza-core/src/test/java/org/apache/samza/storage/blobstore/util/BlobStoreTestUtil.java	227
samza-core/src/test/java/org/apache/samza/storage/blobstore/util/TestBlobStoreUtil.java	856
samza-core/src/test/java/org/apache/samza/storage/blobstore/util/TestDirDiffUtil.java	90
samza-core/src/test/java/org/apache/samza/storage/blobstore/util/TestDirDiffUtilAreSameFile.java	208
samza-core/src/test/java/org/apache/samza/storage/blobstore/util/TestDirDiffUtilMisc.java	36
samza-core/src/test/java/org/apache/samza/system/MockSystemFactory.java	128
samza-core/src/test/java/org/apache/samza/system/TestSSPMetadataCache.java	200
samza-core/src/test/java/org/apache/samza/system/inmemory/TestInMemoryManager.java	92
samza-core/src/test/java/org/apache/samza/system/inmemory/TestInMemorySystem.java	177
samza-core/src/test/java/org/apache/samza/system/inmemory/TestInMemorySystemAdmin.java	25
samza-core/src/test/java/org/apache/samza/system/inmemory/TestInMemorySystemConsumer.java	62
samza-core/src/test/java/org/apache/samza/system/inmemory/TestInMemorySystemProducer.java	52
samza-core/src/test/java/org/apache/samza/table/TestTableConfigGenerator.java	40
samza-core/src/test/java/org/apache/samza/table/TestTableManager.java	103
samza-core/src/test/java/org/apache/samza/table/batching/TestBatchProcessor.java	105
samza-core/src/test/java/org/apache/samza/table/batching/TestBatchTable.java	238
samza-core/src/test/java/org/apache/samza/table/caching/TestCachingTable.java	319
samza-core/src/test/java/org/apache/samza/table/descriptors/TestLocalTableDescriptor.java	123
samza-core/src/test/java/org/apache/samza/table/ratelimit/TestAsyncRateLimitedTable.java	314
samza-core/src/test/java/org/apache/samza/table/remote/TestAsyncRemoteTable.java	162
samza-core/src/test/java/org/apache/samza/table/remote/TestRemoteTable.java	629
samza-core/src/test/java/org/apache/samza/table/remote/descriptors/TestRemoteTableDescriptor.java	355
samza-core/src/test/java/org/apache/samza/table/retry/TestAsyncRetriableTable.java	561
samza-core/src/test/java/org/apache/samza/table/retry/TestTableRetryPolicy.java	66
samza-core/src/test/java/org/apache/samza/task/IdentityStreamTask.java	33
samza-core/src/test/java/org/apache/samza/task/MockAsyncStreamTask.java	7
samza-core/src/test/java/org/apache/samza/task/MockStreamTask.java	7
samza-core/src/test/java/org/apache/samza/task/TestAsyncStreamAdapter.java	97
samza-core/src/test/java/org/apache/samza/task/TestCoordinatorRequests.java	61
samza-core/src/test/java/org/apache/samza/task/TestDefaultTaskExecutorFactory.java	67
samza-core/src/test/java/org/apache/samza/task/TestStreamOperatorTask.java	81
samza-core/src/test/java/org/apache/samza/task/TestTaskCallbackImpl.java	87
samza-core/src/test/java/org/apache/samza/task/TestTaskCallbackManager.java	167
samza-core/src/test/java/org/apache/samza/task/TestTaskFactoryUtil.java	84
samza-core/src/test/java/org/apache/samza/testUtils/EmbeddedZookeeper.java	70
samza-core/src/test/java/org/apache/samza/testUtils/FileUtil.java	38
samza-core/src/test/java/org/apache/samza/testUtils/MockHttpServer.java	30
samza-core/src/test/java/org/apache/samza/testUtils/StreamTestUtils.java	32
samza-core/src/test/java/org/apache/samza/util/TestConfigUtil.java	163
samza-core/src/test/java/org/apache/samza/util/TestDefaultCoordinatorStreamConfigFactory.java	38
samza-core/src/test/java/org/apache/samza/util/TestDiagnosticsUtil.java	59
samza-core/src/test/java/org/apache/samza/util/TestEmbeddedTaggedRateLimiter.java	171
samza-core/src/test/java/org/apache/samza/util/TestFutureUtil.java	166
samza-core/src/test/java/org/apache/samza/util/TestMathUtils.java	42
samza-core/src/test/java/org/apache/samza/util/TestReflectionUtil.java	81
samza-core/src/test/java/org/apache/samza/util/TestShutdownUtil.java	38
samza-core/src/test/java/org/apache/samza/util/TestStreamUtil.java	231
samza-core/src/test/java/org/apache/samza/util/TestThrottlingExecutor.java	175
samza-core/src/test/java/org/apache/samza/util/TestThrottlingScheduler.java	157
samza-core/src/test/java/org/apache/samza/util/TestUtil.java	65
samza-core/src/test/java/org/apache/samza/zk/TestScheduleAfterDebounceTime.java	89
samza-core/src/test/java/org/apache/samza/zk/TestZkBarrierForVersionUpgrade.java	163
samza-core/src/test/java/org/apache/samza/zk/TestZkClusterMembership.java	79
samza-core/src/test/java/org/apache/samza/zk/TestZkDistributedLock.java	84
samza-core/src/test/java/org/apache/samza/zk/TestZkJobCoordinator.java	411
samza-core/src/test/java/org/apache/samza/zk/TestZkKeyBuilder.java	35
samza-core/src/test/java/org/apache/samza/zk/TestZkLeaderElector.java	311
samza-core/src/test/java/org/apache/samza/zk/TestZkMetadataStore.java	97
samza-core/src/test/java/org/apache/samza/zk/TestZkNamespace.java	103
samza-core/src/test/java/org/apache/samza/zk/TestZkProcessorLatch.java	177
samza-core/src/test/java/org/apache/samza/zk/TestZkStringSerializer.java	15
samza-core/src/test/java/org/apache/samza/zk/TestZkUtils.java	415
samza-core/src/test/resources/scalate/css/ropa-sans.css	6
samza-core/src/test/scala/org/apache/samza/checkpoint/TestCheckpointTool.scala	166
samza-core/src/test/scala/org/apache/samza/checkpoint/TestOffsetManager.scala	600
samza-core/src/test/scala/org/apache/samza/checkpoint/file/TestFileSystemCheckpointManager.scala	56
samza-core/src/test/scala/org/apache/samza/config/TestRegExTopicGenerator.scala	53
samza-core/src/test/scala/org/apache/samza/config/factories/TestPropertiesConfigFactory.scala	22
samza-core/src/test/scala/org/apache/samza/container/TestSamzaContainer.scala	307
samza-core/src/test/scala/org/apache/samza/container/TestTaskInstance.scala	1096
samza-core/src/test/scala/org/apache/samza/container/TestTaskInstanceExceptionHandler.scala	94
samza-core/src/test/scala/org/apache/samza/coordinator/TestInputRegexMonitor.java	91
samza-core/src/test/scala/org/apache/samza/coordinator/TestJobModelManager.scala	185
samza-core/src/test/scala/org/apache/samza/coordinator/TestStreamPartitionCountMonitor.scala	186
samza-core/src/test/scala/org/apache/samza/coordinator/server/TestHttpServer.scala	40
samza-core/src/test/scala/org/apache/samza/job/TestJobRunner.scala	56
samza-core/src/test/scala/org/apache/samza/job/local/TestProcessJob.scala	127
samza-core/src/test/scala/org/apache/samza/job/local/TestThreadJob.scala	28
samza-core/src/test/scala/org/apache/samza/metrics/TestBoundedList.java	65
samza-core/src/test/scala/org/apache/samza/metrics/TestJmxServer.scala	30
samza-core/src/test/scala/org/apache/samza/metrics/TestMetricsHelper.scala	10
samza-core/src/test/scala/org/apache/samza/metrics/reporter/TestJmxReporter.scala	35
samza-core/src/test/scala/org/apache/samza/processor/StreamProcessorTestUtils.scala	71
samza-core/src/test/scala/org/apache/samza/serializers/TestCheckpointV1Serde.scala	28
samza-core/src/test/scala/org/apache/samza/serializers/TestJsonSerde.scala	21
samza-core/src/test/scala/org/apache/samza/serializers/TestSerdeManager.scala	75
samza-core/src/test/scala/org/apache/samza/storage/TestContainerStorageManager.java	748
samza-core/src/test/scala/org/apache/samza/system/TestRangeSystemStreamPartitionMatcher.scala	70
samza-core/src/test/scala/org/apache/samza/system/TestRegexSystemStreamPartitionMatcher.scala	48
samza-core/src/test/scala/org/apache/samza/system/TestStreamMetadataCache.scala	102
samza-core/src/test/scala/org/apache/samza/system/TestSystemConsumers.scala	343
samza-core/src/test/scala/org/apache/samza/system/TestSystemProducers.scala	44
samza-core/src/test/scala/org/apache/samza/system/chooser/MockMessageChooser.scala	23
samza-core/src/test/scala/org/apache/samza/system/chooser/MockSystemAdmin.scala	9
samza-core/src/test/scala/org/apache/samza/system/chooser/TestBatchingChooser.scala	61
samza-core/src/test/scala/org/apache/samza/system/chooser/TestBootstrappingChooser.scala	199
samza-core/src/test/scala/org/apache/samza/system/chooser/TestDefaultChooser.scala	144
samza-core/src/test/scala/org/apache/samza/system/chooser/TestRoundRobinChooser.scala	55
samza-core/src/test/scala/org/apache/samza/system/chooser/TestTieredPriorityChooser.scala	191
samza-core/src/test/scala/org/apache/samza/system/filereader/TestFileReaderSystemAdmin.scala	57
samza-core/src/test/scala/org/apache/samza/system/filereader/TestFileReaderSystemConsumer.scala	92
samza-core/src/test/scala/org/apache/samza/system/filereader/TestFileReaderSystemFactory.scala	19
samza-core/src/test/scala/org/apache/samza/task/TestReadableCoordinator.scala	44
samza-core/src/test/scala/org/apache/samza/util/TestCoordinatorStreamUtil.scala	90
samza-core/src/test/scala/org/apache/samza/util/TestExponentialSleepStrategy.scala	134
samza-core/src/test/scala/org/apache/samza/util/TestFileUtil.scala	100
samza-elasticsearch/src/test/java/org/apache/samza/config/ElasticsearchConfigTest.java	69
samza-elasticsearch/src/test/java/org/apache/samza/system/elasticsearch/ElasticsearchSystemProducerMetricsTest.java	27
samza-elasticsearch/src/test/java/org/apache/samza/system/elasticsearch/ElasticsearchSystemProducerTest.java	119
samza-elasticsearch/src/test/java/org/apache/samza/system/elasticsearch/indexrequest/DefaultIndexRequestFactoryTest.java	77
samza-hdfs/src/test/java/org/apache/samza/system/hdfs/TestHdfsSystemConsumer.java	123
samza-hdfs/src/test/java/org/apache/samza/system/hdfs/TestPartitionDesctiptorUtil.java	64
samza-hdfs/src/test/java/org/apache/samza/system/hdfs/descriptors/TestHdfsSystemDescriptor.java	30
samza-hdfs/src/test/java/org/apache/samza/system/hdfs/partitioner/TestDirectoryPartitioner.java	256
samza-hdfs/src/test/java/org/apache/samza/system/hdfs/partitioner/TestHdfsFileSystemAdapter.java	34
samza-hdfs/src/test/java/org/apache/samza/system/hdfs/reader/TestAvroFileHdfsReader.java	131
samza-hdfs/src/test/java/org/apache/samza/system/hdfs/reader/TestMultiFileHdfsReader.java	141
samza-hdfs/src/test/resources/reader/TestEvent.avsc	32
samza-hdfs/src/test/scala/org/apache/samza/system/hdfs/TestHdfsSystemProducerTestSuite.scala	258
samza-kafka/src/test/java/org/apache/samza/checkpoint/kafka/TestKafkaCheckpointLogKeySerde.java	39
samza-kafka/src/test/java/org/apache/samza/checkpoint/kafka/TestKafkaCheckpointManager.java	453
samza-kafka/src/test/java/org/apache/samza/config/TestKafkaConsumerConfig.java	176
samza-kafka/src/test/java/org/apache/samza/storage/TestTaskStorageManager.scala	626
samza-kafka/src/test/java/org/apache/samza/storage/TestTransactionalStateTaskBackupManager.java	195
samza-kafka/src/test/java/org/apache/samza/system/kafka/MockKafkaProducer.java	237
samza-kafka/src/test/java/org/apache/samza/system/kafka/TestKafkaCheckpointManagerFactory.java	23
samza-kafka/src/test/java/org/apache/samza/system/kafka/TestKafkaStreamSpec.java	32
samza-kafka/src/test/java/org/apache/samza/system/kafka/TestKafkaSystemAdminJava.java	376
samza-kafka/src/test/java/org/apache/samza/system/kafka/TestKafkaSystemAdminWithMock.java	274
samza-kafka/src/test/java/org/apache/samza/system/kafka/TestKafkaSystemConsumer.java	183
samza-kafka/src/test/java/org/apache/samza/system/kafka/TestKafkaSystemConsumerMetrics.java	62
samza-kafka/src/test/java/org/apache/samza/system/kafka/TestKafkaSystemFactoryJava.java	39
samza-kafka/src/test/java/org/apache/samza/system/kafka/TestKafkaSystemProducerJava.java	28
samza-kafka/src/test/java/org/apache/samza/system/kafka/descriptors/TestKafkaInputDescriptor.java	34
samza-kafka/src/test/java/org/apache/samza/system/kafka/descriptors/TestKafkaSystemDescriptor.java	44
samza-kafka/src/test/java/org/apache/samza/util/TestKafkaUtil.java	76
samza-kafka/src/test/scala/org/apache/samza/config/TestKafkaConfig.scala	347
samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestKafkaSystemAdmin.scala	218
samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestKafkaSystemFactory.scala	61
samza-kafka/src/test/scala/org/apache/samza/system/kafka/TestKafkaSystemProducer.scala	434
samza-kv-couchbase/src/test/java/org/apache/samza/table/remote/couchbase/TestCouchbaseBucketRegistry.java	100
samza-kv-couchbase/src/test/java/org/apache/samza/table/remote/couchbase/TestCouchbaseTableReadFunction.java	143
samza-kv-couchbase/src/test/java/org/apache/samza/table/remote/couchbase/TestCouchbaseTableWriteFunction.java	156
samza-kv-inmemory/src/test/java/org/apache/samza/storage/kv/inmemory/TestInMemoryKeyValueStore.java	392
samza-kv-inmemory/src/test/java/org/apache/samza/storage/kv/inmemory/TestInMemoryTableDescriptor.java	39
samza-kv-rocksdb/src/test/java/org/apache/samza/storage/kv/TestRocksDbKeyValueReader.java	96
samza-kv-rocksdb/src/test/java/org/apache/samza/storage/kv/TestRocksDbKeyValueStoreJava.java	103
samza-kv-rocksdb/src/test/java/org/apache/samza/storage/kv/descriptors/TestRocksDbTableDescriptor.java	82
samza-kv-rocksdb/src/test/scala/org/apache/samza/storage/kv/TestRocksDbKeyValueStore.scala	187
samza-kv/src/test/java/org/apache/samza/storage/kv/MockKeyValueStorageEngineFactory.java	16
samza-kv/src/test/java/org/apache/samza/storage/kv/TestBaseKeyValueStorageEngineFactory.java	255
samza-kv/src/test/java/org/apache/samza/storage/kv/TestLargeMessageSafeStore.java	142
samza-kv/src/test/java/org/apache/samza/storage/kv/TestLocalTableProvider.java	39
samza-kv/src/test/java/org/apache/samza/storage/kv/TestLocalTableRead.java	116
samza-kv/src/test/java/org/apache/samza/storage/kv/TestLocalTableWrite.java	206
samza-kv/src/test/scala/org/apache/samza/storage/kv/MockKeyValueStore.scala	43
samza-kv/src/test/scala/org/apache/samza/storage/kv/TestCachedStore.scala	102
samza-kv/src/test/scala/org/apache/samza/storage/kv/TestKeyValueStorageEngine.scala	193
samza-log4j/src/test/java/org/apache/samza/config/TestLog4jSystemConfig.java	51
samza-log4j/src/test/java/org/apache/samza/logging/log4j/MockSystemAdmin.java	41
samza-log4j/src/test/java/org/apache/samza/logging/log4j/MockSystemFactory.java	21
samza-log4j/src/test/java/org/apache/samza/logging/log4j/MockSystemProducer.java	32
samza-log4j/src/test/java/org/apache/samza/logging/log4j/TestJmxAppender.java	90
samza-log4j/src/test/java/org/apache/samza/logging/log4j/TestStreamAppender.java	250
samza-log4j/src/test/java/org/apache/samza/logging/log4j/serializers/TestLoggingEventStringSerde.java	18
samza-log4j/src/test/resources/log4j.xml	20
samza-log4j2/src/test/java/org/apache/samza/logging/log4j2/MockSystemAdmin.java	48
samza-log4j2/src/test/java/org/apache/samza/logging/log4j2/MockSystemFactory.java	21
samza-log4j2/src/test/java/org/apache/samza/logging/log4j2/MockSystemProducer.java	32
samza-log4j2/src/test/java/org/apache/samza/logging/log4j2/TestStreamAppender.java	464
samza-log4j2/src/test/java/org/apache/samza/logging/log4j2/serializers/TestLoggingEventStringSerde.java	26
samza-log4j2/src/test/resources/log4j2.xml	18
samza-rest/src/test/java/org/apache/samza/monitor/TestLocalStoreMonitor.java	143
samza-rest/src/test/java/org/apache/samza/monitor/TestMonitorService.java	141
samza-rest/src/test/java/org/apache/samza/monitor/mock/DummyMonitor.java	7
samza-rest/src/test/java/org/apache/samza/monitor/mock/DummyMonitorFactory.java	12
samza-rest/src/test/java/org/apache/samza/monitor/mock/ExceptionThrowingMonitor.java	9
samza-rest/src/test/java/org/apache/samza/monitor/mock/ExceptionThrowingMonitorFactory.java	11
samza-rest/src/test/java/org/apache/samza/monitor/mock/MockMonitorFactory.java	15
samza-rest/src/test/java/org/apache/samza/rest/TestSamzaRestService.java	43
samza-rest/src/test/java/org/apache/samza/rest/proxy/job/TestYarnRestJobStatusProvider.java	47
samza-rest/src/test/java/org/apache/samza/rest/resources/BaseJerseyTest.java	8
samza-rest/src/test/java/org/apache/samza/rest/resources/TestJobsResource.java	163
samza-rest/src/test/java/org/apache/samza/rest/resources/TestTasksResource.java	67
samza-rest/src/test/java/org/apache/samza/rest/resources/mock/MockInstallationFinder.java	16
samza-rest/src/test/java/org/apache/samza/rest/resources/mock/MockJobProxy.java	41
samza-rest/src/test/java/org/apache/samza/rest/resources/mock/MockJobProxyFactory.java	10
samza-rest/src/test/java/org/apache/samza/rest/resources/mock/MockJobStatusProvider.java	27
samza-rest/src/test/java/org/apache/samza/rest/resources/mock/MockResourceFactory.java	22
samza-rest/src/test/java/org/apache/samza/rest/resources/mock/MockTaskProxy.java	35
samza-rest/src/test/java/org/apache/samza/rest/resources/mock/MockTaskProxyFactory.java	10
samza-sql-shell/src/test/java/org/apache/samza/sql/client/impl/SamzaExecutorTest.java	56
samza-sql-shell/src/test/java/org/apache/samza/sql/client/util/RandomAccessQueueTest.java	62
samza-sql-shell/src/test/resources/ProfileChangeStream.avsc	50
samza-sql/src/test/java/org/apache/samza/sql/avro/TestAvroRelConversion.java	343
samza-sql/src/test/java/org/apache/samza/sql/avro/schemas/AddressRecord.java	23
samza-sql/src/test/java/org/apache/samza/sql/avro/schemas/Company.avsc	38
samza-sql/src/test/java/org/apache/samza/sql/avro/schemas/Company.java	23
samza-sql/src/test/java/org/apache/samza/sql/avro/schemas/ComplexRecord.avsc	158
samza-sql/src/test/java/org/apache/samza/sql/avro/schemas/ComplexUnion.avsc	31
samza-sql/src/test/java/org/apache/samza/sql/avro/schemas/ComplexUnion.java	89
samza-sql/src/test/java/org/apache/samza/sql/avro/schemas/EnrichedPageView.avsc	80
samza-sql/src/test/java/org/apache/samza/sql/avro/schemas/EnrichedPageView.java	29
samza-sql/src/test/java/org/apache/samza/sql/avro/schemas/Kind.java	5
samza-sql/src/test/java/org/apache/samza/sql/avro/schemas/MyFixed.java	7
samza-sql/src/test/java/org/apache/samza/sql/avro/schemas/PageView.avsc	38
samza-sql/src/test/java/org/apache/samza/sql/avro/schemas/PageView.java	23
samza-sql/src/test/java/org/apache/samza/sql/avro/schemas/PageViewCount.avsc	44
samza-sql/src/test/java/org/apache/samza/sql/avro/schemas/PageViewCount.java	26
samza-sql/src/test/java/org/apache/samza/sql/avro/schemas/PhoneNumber.java	23
samza-sql/src/test/java/org/apache/samza/sql/avro/schemas/Profile.avsc	147
samza-sql/src/test/java/org/apache/samza/sql/avro/schemas/SimpleRecord.avsc	38
samza-sql/src/test/java/org/apache/samza/sql/avro/schemas/SimpleRecord.java	23
samza-sql/src/test/java/org/apache/samza/sql/avro/schemas/StreetNumRecord.java	20
samza-sql/src/test/java/org/apache/samza/sql/avro/schemas/SubRecord.java	23
samza-sql/src/test/java/org/apache/samza/sql/avro/schemas/TestEnumType.java	5
samza-sql/src/test/java/org/apache/samza/sql/avro/schemas/emptySubRecord.java	17
samza-sql/src/test/java/org/apache/samza/sql/data/TestSamzaSqlRelMessage.java	63
samza-sql/src/test/java/org/apache/samza/sql/fn/TestBuildOutputRecordUdf.java	57
samza-sql/src/test/java/org/apache/samza/sql/fn/TestConvertToStringUdf.java	34
samza-sql/src/test/java/org/apache/samza/sql/fn/TestGetSqlFieldUdf.java	127
samza-sql/src/test/java/org/apache/samza/sql/planner/CheckerTest.java	100
samza-sql/src/test/java/org/apache/samza/sql/planner/TestQueryPlanner.java	219
samza-sql/src/test/java/org/apache/samza/sql/planner/TestSamzaSqlValidator.java	206
samza-sql/src/test/java/org/apache/samza/sql/runner/TestSamzaSqlApplicationConfig.java	126
samza-sql/src/test/java/org/apache/samza/sql/runner/TestSamzaSqlApplicationRunner.java	26
samza-sql/src/test/java/org/apache/samza/sql/serializers/TestSamzaSqlRelMessageSerde.java	71
samza-sql/src/test/java/org/apache/samza/sql/serializers/TestSamzaSqlRelRecordSerde.java	57
samza-sql/src/test/java/org/apache/samza/sql/system/ConsoleLoggingSystemFactory.java	48
samza-sql/src/test/java/org/apache/samza/sql/system/SimpleSystemAdmin.java	41
samza-sql/src/test/java/org/apache/samza/sql/system/TestAvroSystemFactory.java	308
samza-sql/src/test/java/org/apache/samza/sql/translator/TestFilterTranslator.java	115
samza-sql/src/test/java/org/apache/samza/sql/translator/TestJoinTranslator.java	200
samza-sql/src/test/java/org/apache/samza/sql/translator/TestProjectTranslator.java	123
samza-sql/src/test/java/org/apache/samza/sql/translator/TestQueryTranslator.java	729
samza-sql/src/test/java/org/apache/samza/sql/translator/TestSamzaSqlLocalTableJoinFunction.java	121
samza-sql/src/test/java/org/apache/samza/sql/translator/TestSamzaSqlRemoteTableJoinFunction.java	73
samza-sql/src/test/java/org/apache/samza/sql/translator/TranslatorTestBase.java	34
samza-sql/src/test/java/org/apache/samza/sql/udf/impl/TestReflectionBasedUdfResolver.java	32
samza-sql/src/test/java/org/apache/samza/sql/udf/impl/TestSamzaSqlUdf.java	17
samza-sql/src/test/java/org/apache/samza/sql/util/MyTestArrayUdf.java	20
samza-sql/src/test/java/org/apache/samza/sql/util/MyTestObjUdf.java	21
samza-sql/src/test/java/org/apache/samza/sql/util/MyTestPolyUdf.java	25
samza-sql/src/test/java/org/apache/samza/sql/util/MyTestUdf.java	21
samza-sql/src/test/java/org/apache/samza/sql/util/RemoteStoreIOResolverTestFactory.java	116
samza-sql/src/test/java/org/apache/samza/sql/util/SampleRelConverterFactory.java	25
samza-sql/src/test/java/org/apache/samza/sql/util/SampleRelTableKeyConverter.java	17
samza-sql/src/test/java/org/apache/samza/sql/util/SampleRelTableKeyConverterFactory.java	13
samza-sql/src/test/java/org/apache/samza/sql/util/SampleRelTableKeyConverterTest.java	18
samza-sql/src/test/java/org/apache/samza/sql/util/SamzaSqlTestConfig.java	142
samza-sql/src/test/java/org/apache/samza/sql/util/TestMetricsRegistryImpl.java	61
samza-sql/src/test/java/org/apache/samza/sql/util/TestSamzaSqlFileParser.java	31
samza-sql/src/test/java/org/apache/samza/sql/util/TestSamzaSqlQueryParser.java	88
samza-sql/src/test/resources/log4j.xml	22
samza-sql/src/test/resources/log4j2.xml	19
samza-test/src/main/java/org/apache/samza/test/framework/MessageStreamAssert.java	134
samza-test/src/main/java/org/apache/samza/test/framework/StreamAssert.java	47
samza-test/src/main/java/org/apache/samza/test/framework/TestRunner.java	342
samza-test/src/main/java/org/apache/samza/test/framework/system/descriptors/InMemoryInputDescriptor.java	9
samza-test/src/main/java/org/apache/samza/test/framework/system/descriptors/InMemoryOutputDescriptor.java	10
samza-test/src/main/java/org/apache/samza/test/framework/system/descriptors/InMemorySystemDescriptor.java	41
samza-test/src/main/java/org/apache/samza/test/integration/LocalApplicationRunnerMain.java	34
samza-test/src/main/java/org/apache/samza/test/integration/NegateNumberTask.java	37
samza-test/src/main/java/org/apache/samza/test/integration/SimpleStatefulTask.java	30
samza-test/src/main/java/org/apache/samza/test/integration/StatePerfTestTask.java	30
samza-test/src/main/java/org/apache/samza/test/integration/TestStandaloneIntegrationApplication.java	28
samza-test/src/main/java/org/apache/samza/test/integration/join/Checker.java	82
samza-test/src/main/java/org/apache/samza/test/integration/join/Emitter.java	69
samza-test/src/main/java/org/apache/samza/test/integration/join/Joiner.java	92
samza-test/src/main/java/org/apache/samza/test/integration/join/Watcher.java	40
samza-test/src/main/python/integration_tests.py	11
samza-test/src/main/python/standalone_integration_tests.py	10
samza-test/src/main/python/tests/performance_tests.py	54
samza-test/src/main/python/tests/smoke_tests.py	39
samza-test/src/main/python/tests/standalone_failure_tests.py	197
samza-test/src/main/python/tests/util.py	49
samza-test/src/main/python/tests/zk_client.py	66
samza-test/src/main/scala/org/apache/samza/test/performance/TestKeyValuePerformance.scala	264
samza-test/src/main/scala/org/apache/samza/test/performance/TestPerformanceTask.scala	38
samza-test/src/test/java/org/apache/samza/checkpoint/CheckpointVersionIntegrationTest.java	125
samza-test/src/test/java/org/apache/samza/processor/TestStreamProcessorUtil.java	7
samza-test/src/test/java/org/apache/samza/processor/TestZkStreamProcessor.java	123
samza-test/src/test/java/org/apache/samza/processor/TestZkStreamProcessorBase.java	289
samza-test/src/test/java/org/apache/samza/processor/TestZkStreamProcessorFailures.java	75
samza-test/src/test/java/org/apache/samza/processor/TestZkStreamProcessorSession.java	67
samza-test/src/test/java/org/apache/samza/storage/MyStatefulApplication.java	207
samza-test/src/test/java/org/apache/samza/storage/kv/BaseStateBackendIntegrationTest.java	126
samza-test/src/test/java/org/apache/samza/storage/kv/BlobStoreStateBackendIntegrationTest.java	355
samza-test/src/test/java/org/apache/samza/storage/kv/KafkaNonTransactionalStateIntegrationTest.java	112
samza-test/src/test/java/org/apache/samza/storage/kv/KafkaTransactionalStateIntegrationTest.java	188
samza-test/src/test/java/org/apache/samza/storage/kv/TestKeyValueSizeHistogramMetric.java	102
samza-test/src/test/java/org/apache/samza/storage/kv/TestLargeMessageSafeKeyValueStores.java	189
samza-test/src/test/java/org/apache/samza/test/StandaloneTestUtils.java	81
samza-test/src/test/java/org/apache/samza/test/TestData.java	56
samza-test/src/test/java/org/apache/samza/test/controlmessages/EndOfStreamIntegrationTest.java	48
samza-test/src/test/java/org/apache/samza/test/controlmessages/WatermarkIntegrationTest.java	184
samza-test/src/test/java/org/apache/samza/test/drain/DrainHighLevelApiIntegrationTest.java	199
samza-test/src/test/java/org/apache/samza/test/drain/DrainLowLevelApiIntegrationTest.java	145
samza-test/src/test/java/org/apache/samza/test/framework/AsyncStreamTaskIntegrationTest.java	112
samza-test/src/test/java/org/apache/samza/test/framework/BroadcastAssertApp.java	34
samza-test/src/test/java/org/apache/samza/test/framework/FaultInjectionTest.java	84
samza-test/src/test/java/org/apache/samza/test/framework/MyAsyncStreamTask.java	40
samza-test/src/test/java/org/apache/samza/test/framework/MyStreamTestTask.java	24
samza-test/src/test/java/org/apache/samza/test/framework/SchedulingTest.java	27
samza-test/src/test/java/org/apache/samza/test/framework/StreamApplicationIntegrationTest.java	160
samza-test/src/test/java/org/apache/samza/test/framework/StreamApplicationIntegrationTestHarness.java	138
samza-test/src/test/java/org/apache/samza/test/framework/StreamTaskIntegrationTest.java	236
samza-test/src/test/java/org/apache/samza/test/framework/TestSchedulingApp.java	59
samza-test/src/test/java/org/apache/samza/test/framework/TestStreamApplicationIntegrationTestHarness.java	26
samza-test/src/test/java/org/apache/samza/test/functions/TestSchedulerFunction.java	58
samza-test/src/test/java/org/apache/samza/test/harness/InMemoryIntegrationTestHarness.java	29
samza-test/src/test/java/org/apache/samza/test/harness/IntegrationTestHarness.java	134
samza-test/src/test/java/org/apache/samza/test/kafka/KafkaCheckpointManagerIntegrationTest.java	126
samza-test/src/test/java/org/apache/samza/test/operator/RepartitionJoinWindowApp.java	87
samza-test/src/test/java/org/apache/samza/test/operator/SessionWindowApp.java	49
samza-test/src/test/java/org/apache/samza/test/operator/TestAsyncFlatMap.java	168
samza-test/src/test/java/org/apache/samza/test/operator/TestRepartitionJoinWindowApp.java	113
samza-test/src/test/java/org/apache/samza/test/operator/TestRepartitionWindowApp.java	66
samza-test/src/test/java/org/apache/samza/test/operator/TumblingWindowApp.java	49
samza-test/src/test/java/org/apache/samza/test/operator/data/AdClick.java	17
samza-test/src/test/java/org/apache/samza/test/operator/data/PageView.java	59
samza-test/src/test/java/org/apache/samza/test/operator/data/UserPageAdClick.java	35
samza-test/src/test/java/org/apache/samza/test/processor/IdentityStreamTask.java	37
samza-test/src/test/java/org/apache/samza/test/processor/SharedContextFactories.java	72
samza-test/src/test/java/org/apache/samza/test/processor/TestStreamApplication.java	102
samza-test/src/test/java/org/apache/samza/test/processor/TestStreamProcessor.java	219
samza-test/src/test/java/org/apache/samza/test/processor/TestTaskApplication.java	65
samza-test/src/test/java/org/apache/samza/test/processor/TestZkLocalApplicationRunner.java	866
samza-test/src/test/java/org/apache/samza/test/samzasql/SamzaSqlIntegrationTestHarness.java	30
samza-test/src/test/java/org/apache/samza/test/samzasql/TestSamzaSqlEndToEnd.java	969
samza-test/src/test/java/org/apache/samza/test/samzasql/TestSamzaSqlRemoteTable.java	379
samza-test/src/test/java/org/apache/samza/test/startpoint/TestStartpoint.java	373
samza-test/src/test/java/org/apache/samza/test/table/PageViewToProfileJoinFunction.java	21
samza-test/src/test/java/org/apache/samza/test/table/TestCouchbaseRemoteTableEndToEnd.java	137
samza-test/src/test/java/org/apache/samza/test/table/TestLocalTableEndToEnd.java	227
samza-test/src/test/java/org/apache/samza/test/table/TestLocalTableWithConfigRewriterEndToEnd.java	59
samza-test/src/test/java/org/apache/samza/test/table/TestLocalTableWithLowLevelApiEndToEnd.java	62
samza-test/src/test/java/org/apache/samza/test/table/TestLocalTableWithSideInputsEndToEnd.java	186
samza-test/src/test/java/org/apache/samza/test/table/TestRemoteTableEndToEnd.java	521
samza-test/src/test/java/org/apache/samza/test/table/TestRemoteTableWithBatchEndToEnd.java	262
samza-test/src/test/java/org/apache/samza/test/table/TestTableData.java	211
samza-test/src/test/java/org/apache/samza/test/util/ArraySystemConsumer.java	53
samza-test/src/test/java/org/apache/samza/test/util/ArraySystemFactory.java	21
samza-test/src/test/java/org/apache/samza/test/util/Base64Serializer.java	40
samza-test/src/test/java/org/apache/samza/test/util/SimpleSystemAdmin.java	60
samza-test/src/test/java/org/apache/samza/test/util/TestBlobStoreManager.java	140
samza-test/src/test/java/org/apache/samza/test/util/TestBlobStoreManagerFactory.java	15
samza-test/src/test/java/org/apache/samza/test/util/TestKafkaEvent.java	25
samza-test/src/test/java/org/apache/samza/test/util/TestStreamConsumer.java	26
samza-test/src/test/scala/org/apache/samza/storage/kv/TestKeyValueStores.scala	452
samza-test/src/test/scala/org/apache/samza/test/harness/AbstractKafkaServerTestHarness.scala	90
samza-test/src/test/scala/org/apache/samza/test/harness/AbstractZookeeperTestHarness.scala	35
samza-test/src/test/scala/org/apache/samza/test/integration/NonTransactionalStateIntegrationTest.scala	98
samza-test/src/test/scala/org/apache/samza/test/integration/NonTransactionalStateShutdownIntegrationTest.scala	83
samza-test/src/test/scala/org/apache/samza/test/integration/StreamTaskTestUtil.scala	240
samza-yarn/src/test/java/org/apache/samza/config/TestYarnConfig.java	17
samza-yarn/src/test/java/org/apache/samza/job/yarn/TestFileSystemImplConfig.java	53
samza-yarn/src/test/java/org/apache/samza/job/yarn/TestLocalizerResourceConfig.java	86
samza-yarn/src/test/java/org/apache/samza/job/yarn/TestLocalizerResourceMapper.java	118
samza-yarn/src/test/java/org/apache/samza/job/yarn/TestYarnClusterResourceManager.java	219
samza-yarn/src/test/java/org/apache/samza/job/yarn/TestYarnFaultDomainManager.java	140
samza-yarn/src/test/java/org/apache/samza/job/yarn/TestYarnJob.java	89
samza-yarn/src/test/java/org/apache/samza/job/yarn/TestYarnJobFactory.java	37
samza-yarn/src/test/java/org/apache/samza/job/yarn/util/MockContainerListener.java	100
samza-yarn/src/test/java/org/apache/samza/job/yarn/util/MockHttpServer.java	30
samza-yarn/src/test/java/org/apache/samza/job/yarn/util/MockNMClient.java	37
samza-yarn/src/test/java/org/apache/samza/job/yarn/util/TestAMRMClientImpl.java	62
samza-yarn/src/test/java/org/apache/samza/job/yarn/util/hadoop/TestHttpFileSystem.java	107
samza-yarn/src/test/java/org/apache/samza/validation/MockMetricsValidator.java	27
samza-yarn/src/test/java/org/apache/samza/validation/TestYarnJobValidationTool.java	107
samza-yarn/src/test/java/org/apache/samza/webapp/TestApplicationMasterRestClient.java	259
samza-yarn/src/test/java/org/apache/samza/webapp/TestLocalityServlet.java	88
samza-yarn/src/test/java/org/apache/samza/webapp/TestYarnContainerHeartbeatServlet.java	70
samza-yarn/src/test/scala/org/apache/samza/job/yarn/MockSystemAdmin.scala	17
samza-yarn/src/test/scala/org/apache/samza/job/yarn/MockSystemFactory.scala	16
samza-yarn/src/test/scala/org/apache/samza/job/yarn/TestClientHelper.scala	112
samza-yarn/src/test/scala/org/apache/samza/job/yarn/TestSamzaYarnAppMasterLifecycle.scala	152
samza-yarn/src/test/scala/org/apache/samza/job/yarn/TestSamzaYarnAppMasterService.scala	85
samza-yarn3/src/test/java/org/apache/samza/config/TestYarnConfig.java	17
samza-yarn3/src/test/java/org/apache/samza/job/yarn/TestFileSystemImplConfig.java	53
samza-yarn3/src/test/java/org/apache/samza/job/yarn/TestLocalizerResourceConfig.java	86
samza-yarn3/src/test/java/org/apache/samza/job/yarn/TestLocalizerResourceMapper.java	118
samza-yarn3/src/test/java/org/apache/samza/job/yarn/TestYarnClusterResourceManager.java	183
samza-yarn3/src/test/java/org/apache/samza/job/yarn/TestYarnFaultDomainManager.java	148
samza-yarn3/src/test/java/org/apache/samza/job/yarn/TestYarnJob.java	89
samza-yarn3/src/test/java/org/apache/samza/job/yarn/TestYarnJobFactory.java	37
samza-yarn3/src/test/java/org/apache/samza/job/yarn/util/MockContainerListener.java	100
samza-yarn3/src/test/java/org/apache/samza/job/yarn/util/MockHttpServer.java	30
samza-yarn3/src/test/java/org/apache/samza/job/yarn/util/MockNMClient.java	37
samza-yarn3/src/test/java/org/apache/samza/job/yarn/util/TestAMRMClientImpl.java	62
samza-yarn3/src/test/java/org/apache/samza/job/yarn/util/hadoop/TestHttpFileSystem.java	107
samza-yarn3/src/test/java/org/apache/samza/validation/MockMetricsValidator.java	27
samza-yarn3/src/test/java/org/apache/samza/validation/TestYarnJobValidationTool.java	107
samza-yarn3/src/test/java/org/apache/samza/webapp/TestApplicationMasterRestClient.java	258
samza-yarn3/src/test/java/org/apache/samza/webapp/TestLocalityServlet.java	88
samza-yarn3/src/test/java/org/apache/samza/webapp/TestYarnContainerHeartbeatServlet.java	70
samza-yarn3/src/test/scala/org/apache/samza/job/yarn/MockSystemAdmin.scala	17
samza-yarn3/src/test/scala/org/apache/samza/job/yarn/MockSystemFactory.scala	16
samza-yarn3/src/test/scala/org/apache/samza/job/yarn/TestClientHelper.scala	112
samza-yarn3/src/test/scala/org/apache/samza/job/yarn/TestSamzaYarnAppMasterLifecycle.scala	154
samza-yarn3/src/test/scala/org/apache/samza/job/yarn/TestSamzaYarnAppMasterService.scala	85