Path	Lines of Code
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/checkpoint/azure/AzureCheckpointManager.java	176
samza-azure/src/main/java/org/apache/samza/checkpoint/azure/AzureCheckpointManagerFactory.java	14
samza-azure/src/main/java/org/apache/samza/checkpoint/azure/TaskCheckpointEntity.java	17
samza-azure/src/main/java/org/apache/samza/config/AzureConfig.java	35
samza-azure/src/main/java/org/apache/samza/coordinator/AzureCoordinationUtils.java	31
samza-azure/src/main/java/org/apache/samza/coordinator/AzureCoordinationUtilsFactory.java	8
samza-azure/src/main/java/org/apache/samza/coordinator/AzureJobCoordinator.java	352
samza-azure/src/main/java/org/apache/samza/coordinator/AzureJobCoordinatorFactory.java	11
samza-azure/src/main/java/org/apache/samza/coordinator/AzureLeaderElector.java	58
samza-azure/src/main/java/org/apache/samza/coordinator/AzureLock.java	59
samza-azure/src/main/java/org/apache/samza/coordinator/data/BarrierState.java	4
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/scheduler/HeartbeatScheduler.java	48
samza-azure/src/main/java/org/apache/samza/coordinator/scheduler/JMVersionUpgradeScheduler.java	65
samza-azure/src/main/java/org/apache/samza/coordinator/scheduler/LeaderBarrierCompleteScheduler.java	83
samza-azure/src/main/java/org/apache/samza/coordinator/scheduler/LeaderLivenessCheckScheduler.java	72
samza-azure/src/main/java/org/apache/samza/coordinator/scheduler/LivenessCheckScheduler.java	71
samza-azure/src/main/java/org/apache/samza/coordinator/scheduler/RenewLeaseScheduler.java	48
samza-azure/src/main/java/org/apache/samza/coordinator/scheduler/SchedulerStateChangeListener.java	4
samza-azure/src/main/java/org/apache/samza/coordinator/scheduler/TaskScheduler.java	7
samza-azure/src/main/java/org/apache/samza/system/azureblob/AzureBlobBasicMetrics.java	43
samza-azure/src/main/java/org/apache/samza/system/azureblob/AzureBlobClientBuilder.java	74
samza-azure/src/main/java/org/apache/samza/system/azureblob/AzureBlobClientBuilderFactory.java	8
samza-azure/src/main/java/org/apache/samza/system/azureblob/AzureBlobConfig.java	181
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/BlobClientBuilder.java	5
samza-azure/src/main/java/org/apache/samza/system/azureblob/BlobClientBuilderFactory.java	4
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/AzureBlobAvroWriterFactory.java	22
samza-azure/src/main/java/org/apache/samza/system/azureblob/avro/AzureBlobOutputStream.java	225
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/CompressionFactory.java	15
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/GzipCompression.java	38
samza-azure/src/main/java/org/apache/samza/system/azureblob/compression/NoneCompression.java	11
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/AzureBlobSystemProducerMetrics.java	74
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/producer/AzureBlobWriterMetrics.java	33
samza-azure/src/main/java/org/apache/samza/system/azureblob/utils/BlobMetadataContext.java	20
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/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/NullBlobMetadataGeneratorFactory.java	8
samza-azure/src/main/java/org/apache/samza/system/eventhub/EventHubClientManager.java	8
samza-azure/src/main/java/org/apache/samza/system/eventhub/EventHubClientManagerFactory.java	11
samza-azure/src/main/java/org/apache/samza/system/eventhub/EventHubConfig.java	159
samza-azure/src/main/java/org/apache/samza/system/eventhub/EventHubSystemFactory.java	39
samza-azure/src/main/java/org/apache/samza/system/eventhub/Interceptor.java	4
samza-azure/src/main/java/org/apache/samza/system/eventhub/SamzaEventHubClientManager.java	86
samza-azure/src/main/java/org/apache/samza/system/eventhub/admin/EventHubSystemAdmin.java	236
samza-azure/src/main/java/org/apache/samza/system/eventhub/admin/PassThroughInterceptor.java	8
samza-azure/src/main/java/org/apache/samza/system/eventhub/consumer/EventHubIncomingMessageEnvelope.java	15
samza-azure/src/main/java/org/apache/samza/system/eventhub/consumer/EventHubSystemConsumer.java	392
samza-azure/src/main/java/org/apache/samza/system/eventhub/descriptors/EventHubsInputDescriptor.java	56
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/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/util/BlobUtils.java	175
samza-azure/src/main/java/org/apache/samza/util/LeaseBlobManager.java	52
samza-azure/src/main/java/org/apache/samza/util/TableUtils.java	131