apache / samza
File Size

The distribution of size of files (measured in lines of code).

Intro
Learn more...
File Size Overall
0% | 7% | 24% | 25% | 42%
Legend:
1001+
501-1000
201-500
101-200
1-100


explore: grouped by folders | grouped by size | sunburst | 3D view
File Size per Extension
1001+
501-1000
201-500
101-200
1-100
java0% | 6% | 25% | 26% | 42%
scala0% | 13% | 21% | 20% | 44%
scaml0% | 0% | 84% | 0% | 15%
py0% | 0% | 0% | 55% | 44%
less0% | 0% | 0% | 97% | 2%
xsl0% | 0% | 0% | 100% | 0%
xml0% | 0% | 0% | 0% | 100%
avsc0% | 0% | 0% | 0% | 100%
html0% | 0% | 0% | 0% | 100%
js0% | 0% | 0% | 0% | 100%
rdf0% | 0% | 0% | 0% | 100%
css0% | 0% | 0% | 0% | 100%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
samza-core0% | 8% | 30% | 24% | 37%
samza-kafka0% | 26% | 42% | 10% | 20%
samza-sql-shell0% | 24% | 24% | 15% | 35%
samza-yarn0% | 18% | 20% | 19% | 41%
samza-yarn30% | 18% | 20% | 19% | 41%
samza-azure0% | 0% | 45% | 20% | 34%
samza-sql0% | 0% | 26% | 33% | 39%
samza-log4j20% | 0% | 56% | 16% | 26%
samza-kv-rocksdb0% | 0% | 35% | 51% | 13%
samza-log4j0% | 0% | 44% | 18% | 36%
samza-api0% | 0% | 3% | 20% | 76%
samza-kv0% | 0% | 0% | 76% | 23%
samza-hdfs0% | 0% | 0% | 58% | 41%
samza-tools0% | 0% | 0% | 36% | 63%
samza-aws0% | 0% | 0% | 46% | 53%
samza-rest0% | 0% | 0% | 17% | 82%
samza-test0% | 0% | 0% | 19% | 80%
samza-kv-couchbase0% | 0% | 0% | 57% | 42%
gradle0% | 0% | 0% | 100% | 0%
samza-elasticsearch0% | 0% | 0% | 29% | 70%
samza-kv-inmemory0% | 0% | 0% | 72% | 27%
samza-shell0% | 0% | 0% | 0% | 100%
ROOT0% | 0% | 0% | 0% | 100%
Longest Files (Top 50)
File# lines# units
SamzaContainer.scala
in samza-core/src/main/scala/org/apache/samza/container
 892 11
RunLoop.java
in samza-core/src/main/java/org/apache/samza/container
 742 43
KafkaSystemAdmin.java
in samza-kafka/src/main/java/org/apache/samza/system/kafka
 670 39
CliCommandHandler.java
in samza-sql-shell/src/main/java/org/apache/samza/sql/client/impl
 578 23
ZkJobCoordinator.java
in samza-core/src/main/java/org/apache/samza/zk
 553 39
TransactionalStateTaskRestoreManager.java
in samza-core/src/main/java/org/apache/samza/storage
 517 13
YarnClusterResourceManager.java
in samza-yarn/src/main/java/org/apache/samza/job/yarn
 509 30
YarnClusterResourceManager.java
in samza-yarn3/src/main/java/org/apache/samza/job/yarn
 507 30
TaskInstance.scala
in samza-core/src/main/scala/org/apache/samza/container
 506 15
ZkUtils.java
in samza-core/src/main/java/org/apache/samza/zk
 484 51
BlobStoreUtil.java
in samza-core/src/main/java/org/apache/samza/storage/blobstore/util
 473 17
ContainerProcessManager.java
in samza-core/src/main/java/org/apache/samza/clustermanager
 455 23
OperatorImpl.java
in samza-core/src/main/java/org/apache/samza/operators/impl
 412 28
OffsetManager.scala
in samza-core/src/main/scala/org/apache/samza/checkpoint
 406 14
StandbyContainerManager.java
in samza-core/src/main/java/org/apache/samza/clustermanager
 399 30
EventHubSystemConsumer.java
in samza-azure/src/main/java/org/apache/samza/system/eventhub/consumer
 392 14
LocalApplicationRunner.java
in samza-core/src/main/java/org/apache/samza/runtime
 389 31
SamzaExecutor.java
in samza-sql-shell/src/main/java/org/apache/samza/sql/client/impl
 389 28
SideInputsManager.java
in samza-core/src/main/scala/org/apache/samza/storage
 381 10
StreamProcessor.java
in samza-core/src/main/java/org/apache/samza/processor
 372 20
ContainerManager.java
in samza-core/src/main/java/org/apache/samza/clustermanager
 368 20
AzureJobCoordinator.java
in samza-azure/src/main/java/org/apache/samza/coordinator
 352 19
JobConfig.java
in samza-core/src/main/java/org/apache/samza/config
 345 57
RemoteTable.java
in samza-core/src/main/java/org/apache/samza/table/remote
 344 27
AzureBlobSystemProducer.java
in samza-azure/src/main/java/org/apache/samza/system/azureblob/producer
 343 14
StreamAppender.java
in samza-log4j2/src/main/java/org/apache/samza/logging/log4j2
 341 27
ClientHelper.scala
in samza-yarn/src/main/scala/org/apache/samza/job/yarn
 330 18
ClientHelper.scala
in samza-yarn3/src/main/scala/org/apache/samza/job/yarn
 330 18
KafkaConsumerProxy.java
in samza-kafka/src/main/java/org/apache/samza/system/kafka
 320 18
ContainerStorageManagerUtil.java
in samza-core/src/main/scala/org/apache/samza/storage
 318 10
ClusterBasedJobCoordinator.java
in samza-core/src/main/java/org/apache/samza/clustermanager
 308 17
ContainerStorageManager.java
in samza-core/src/main/scala/org/apache/samza/storage
 304 9
StorageManagerUtil.java
in samza-core/src/main/java/org/apache/samza/storage
 302 17
JoinTranslator.java
in samza-sql/src/main/java/org/apache/samza/sql/translator
 299 11
RocksDbKeyValueStore.scala
in samza-kv-rocksdb/src/main/scala/org/apache/samza/storage/kv
 296 22
KafkaCheckpointManager.scala
in samza-kafka/src/main/scala/org/apache/samza/checkpoint/kafka
 291 13
EventHubSystemProducer.java
in samza-azure/src/main/java/org/apache/samza/system/eventhub/producer
 290 12
WindowOperatorImpl.java
in samza-core/src/main/java/org/apache/samza/operators/impl
 288 12
ContainerStorageManagerRestoreUtil.java
in samza-core/src/main/scala/org/apache/samza/storage
 284 9
AzureBlobAvroWriter.java
in samza-azure/src/main/java/org/apache/samza/system/azureblob/avro
 284 11
SystemConsumers.scala
in samza-core/src/main/scala/org/apache/samza/system
 282 10
DirDiffUtil.java
in samza-core/src/main/java/org/apache/samza/storage/blobstore/util
 278 6
OperatorImplGraph.java
in samza-core/src/main/java/org/apache/samza/operators/impl
 276 14
TaskConfig.java
in samza-core/src/main/java/org/apache/samza/config
 276 38
SamzaSqlValidator.java
in samza-sql/src/main/java/org/apache/samza/sql/planner
 273 13
CachingTable.java
in samza-core/src/main/java/org/apache/samza/table/caching
 271 25
NonTransactionalStateTaskRestoreManager.java
in samza-core/src/main/java/org/apache/samza/storage
 268 12
JobGraph.java
in samza-core/src/main/java/org/apache/samza/execution
 265 27
ResourceRequestState.java
in samza-core/src/main/java/org/apache/samza/clustermanager
 264 21
BlobStoreRestoreManager.java
in samza-core/src/main/java/org/apache/samza/storage/blobstore
 264 12
Files With Most Units (Top 50)
File# lines# units
JobConfig.java
in samza-core/src/main/java/org/apache/samza/config
 345 57
ZkUtils.java
in samza-core/src/main/java/org/apache/samza/zk
 484 51
RunLoop.java
in samza-core/src/main/java/org/apache/samza/container
 742 43
ZkJobCoordinator.java
in samza-core/src/main/java/org/apache/samza/zk
 553 39
KafkaSystemAdmin.java
in samza-kafka/src/main/java/org/apache/samza/system/kafka
 670 39
TaskConfig.java
in samza-core/src/main/java/org/apache/samza/config
 276 38
StorageConfig.java
in samza-core/src/main/java/org/apache/samza/config
 238 33
LocalApplicationRunner.java
in samza-core/src/main/java/org/apache/samza/runtime
 389 31
DiagnosticsStreamMessage.java
in samza-core/src/main/scala/org/apache/samza/diagnostics
 200 30
StandbyContainerManager.java
in samza-core/src/main/java/org/apache/samza/clustermanager
 399 30
YarnClusterResourceManager.java
in samza-yarn/src/main/java/org/apache/samza/job/yarn
 509 30
YarnClusterResourceManager.java
in samza-yarn3/src/main/java/org/apache/samza/job/yarn
 507 30
Config.java
in samza-api/src/main/java/org/apache/samza/config
 196 29
OperatorImpl.java
in samza-core/src/main/java/org/apache/samza/operators/impl
 412 28
AzureBlobConfig.java
in samza-azure/src/main/java/org/apache/samza/system/azureblob
 181 28
SamzaExecutor.java
in samza-sql-shell/src/main/java/org/apache/samza/sql/client/impl
 389 28
StreamAppender.java
in samza-log4j2/src/main/java/org/apache/samza/logging/log4j2
 341 27
RemoteTable.java
in samza-core/src/main/java/org/apache/samza/table/remote
 344 27
StreamConfig.java
in samza-core/src/main/java/org/apache/samza/config
 174 27
JobGraph.java
in samza-core/src/main/java/org/apache/samza/execution
 265 27
CoordinatorStreamMessage.java
in samza-core/src/main/java/org/apache/samza/coordinator/stream/messages
 151 26
ApplicationDescriptorImpl.java
in samza-core/src/main/java/org/apache/samza/application/descriptors
 223 26
StreamSpec.java
in samza-api/src/main/java/org/apache/samza/system
 114 25
BlockingEnvelopeMap.java
in samza-api/src/main/java/org/apache/samza/util
 208 25
CachingTable.java
in samza-core/src/main/java/org/apache/samza/table/caching
 271 25
ContainerAllocator.java
in samza-core/src/main/java/org/apache/samza/clustermanager
 223 25
samza_job_yarn_deployer.py
in samza-test/src/main/python
 154 24
JobCoordinatorMetadataManager.java
in samza-core/src/main/java/org/apache/samza/job/metadata
 243 24
LocalTable.java
in samza-kv/src/main/java/org/apache/samza/storage/kv
 179 23
ContainerProcessManager.java
in samza-core/src/main/java/org/apache/samza/clustermanager
 455 23
CliCommandHandler.java
in samza-sql-shell/src/main/java/org/apache/samza/sql/client/impl
 578 23
StartpointManager.java
in samza-core/src/main/java/org/apache/samza/startpoint
 262 22
EventHubConfig.java
in samza-azure/src/main/java/org/apache/samza/system/eventhub
 159 22
YarnConfig.java
in samza-yarn/src/main/java/org/apache/samza/config
 113 22
YarnConfig.java
in samza-yarn3/src/main/java/org/apache/samza/config
 113 22
RocksDbKeyValueStore.scala
in samza-kv-rocksdb/src/main/scala/org/apache/samza/storage/kv
 296 22
SamzaSqlApplicationConfig.java
in samza-sql/src/main/java/org/apache/samza/sql/runner
 247 22
ResourceRequestState.java
in samza-core/src/main/java/org/apache/samza/clustermanager
 264 21
IncomingMessageEnvelope.java
in samza-api/src/main/java/org/apache/samza/system
 129 20
ContainerManager.java
in samza-core/src/main/java/org/apache/samza/clustermanager
 368 20
StreamProcessor.java
in samza-core/src/main/java/org/apache/samza/processor
 372 20
JobNode.java
in samza-core/src/main/java/org/apache/samza/execution
 125 20
TranslatorContext.java
in samza-sql/src/main/java/org/apache/samza/sql/translator
 131 20
AsyncRateLimitedTable.java
in samza-core/src/main/java/org/apache/samza/table/ratelimit
 152 19
GuavaCacheTable.java
in samza-core/src/main/java/org/apache/samza/table/caching/guava
 175 19
AzureJobCoordinator.java
in samza-azure/src/main/java/org/apache/samza/coordinator
 352 19
StreamAppender.java
in samza-log4j/src/main/java/org/apache/samza/logging/log4j
 252 19
TableRetryPolicy.java
in samza-api/src/main/java/org/apache/samza/table/retry
 109 18
RemoteTableDescriptor.java
in samza-api/src/main/java/org/apache/samza/table/descriptors
 200 18
MetricsHeader.java
in samza-core/src/main/java/org/apache/samza/metrics/reporter
 138 18
Files With Long Lines (Top 50)

There are 316 files with lines longer than 120 characters. In total, there are 1024 long lines.

File# lines# units# long lines
ContainerManager.java
in samza-core/src/main/java/org/apache/samza/clustermanager
 368 20 25
StreamProcessor.java
in samza-core/src/main/java/org/apache/samza/processor
 372 20 22
KafkaConfig.scala
in samza-kafka/src/main/scala/org/apache/samza/config
 247 15 21
StandbyContainerManager.java
in samza-core/src/main/java/org/apache/samza/clustermanager
 399 30 20
OffsetManager.scala
in samza-core/src/main/scala/org/apache/samza/checkpoint
 406 14 19
BlobStoreUtil.java
in samza-core/src/main/java/org/apache/samza/storage/blobstore/util
 473 17 18
KafkaSystemAdmin.java
in samza-kafka/src/main/java/org/apache/samza/system/kafka
 670 39 18
ZkJobCoordinator.java
in samza-core/src/main/java/org/apache/samza/zk
 553 39 16
YarnClusterResourceManager.java
in samza-yarn/src/main/java/org/apache/samza/job/yarn
 509 30 15
YarnClusterResourceManager.java
in samza-yarn3/src/main/java/org/apache/samza/job/yarn
 507 30 15
ContainerProcessManager.java
in samza-core/src/main/java/org/apache/samza/clustermanager
 455 23 14
SamzaObjectMapper.java
in samza-core/src/main/java/org/apache/samza/serializers/model
 237 18 13
BlockingEnvelopeMap.java
in samza-api/src/main/java/org/apache/samza/util
 208 25 12
SamzaContainer.scala
in samza-core/src/main/scala/org/apache/samza/container
 892 11 12
ZkBarrierForVersionUpgrade.java
in samza-core/src/main/java/org/apache/samza/zk
 156 15 12
CoordinatorStreamStore.java
in samza-core/src/main/java/org/apache/samza/coordinator/metadatastore
 185 14 12
AzureBlobConfig.java
in samza-azure/src/main/java/org/apache/samza/system/azureblob
 181 28 12
AzureJobCoordinator.java
in samza-azure/src/main/java/org/apache/samza/coordinator
 352 19 12
AzureBlobSystemProducer.java
in samza-azure/src/main/java/org/apache/samza/system/azureblob/producer
 343 14 11
xsl
rat-output-to-html.xsl
in gradle/resources
 153 - 10
DiagnosticsStreamMessage.java
in samza-core/src/main/scala/org/apache/samza/diagnostics
 200 30 10
ZkUtils.java
in samza-core/src/main/java/org/apache/samza/zk
 484 51 10
ContainerAllocator.java
in samza-core/src/main/java/org/apache/samza/clustermanager
 223 25 10
SSPGrouperProxy.java
in samza-core/src/main/java/org/apache/samza/container/grouper/stream
 152 6 10
BlobStoreRestoreManager.java
in samza-core/src/main/java/org/apache/samza/storage/blobstore
 264 12 10
TransactionalStateTaskRestoreManager.java
in samza-core/src/main/java/org/apache/samza/storage
 517 13 10
AzureBlobOutputStream.java
in samza-azure/src/main/java/org/apache/samza/system/azureblob/avro
 225 14 10
LocalApplicationRunner.java
in samza-core/src/main/java/org/apache/samza/runtime
 389 31 9
NonTransactionalStateTaskRestoreManager.java
in samza-core/src/main/java/org/apache/samza/storage
 268 12 9
LocalJobPlanner.java
in samza-core/src/main/java/org/apache/samza/execution
 146 6 8
EventHubsSystemDescriptor.java
in samza-azure/src/main/java/org/apache/samza/system/eventhub/descriptors
 87 9 8
KafkaSystemDescriptor.java
in samza-kafka/src/main/java/org/apache/samza/system/kafka/descriptors
 99 12 8
TaskConfig.java
in samza-core/src/main/java/org/apache/samza/config
 276 38 7
StartpointManager.java
in samza-core/src/main/java/org/apache/samza/startpoint
 262 22 7
StorageManagerUtil.java
in samza-core/src/main/java/org/apache/samza/storage
 302 17 7
AzureBlobAvroWriter.java
in samza-azure/src/main/java/org/apache/samza/system/azureblob/avro
 284 11 7
ClientHelper.scala
in samza-yarn/src/main/scala/org/apache/samza/job/yarn
 330 18 7
KafkaSystemProducer.scala
in samza-kafka/src/main/scala/org/apache/samza/system/kafka
 148 6 7
ClientHelper.scala
in samza-yarn3/src/main/scala/org/apache/samza/job/yarn
 330 18 7
samza_job_yarn_deployer.py
in samza-test/src/main/python
 154 24 6
ContainerProcessManagerMetrics.scala
in samza-core/src/main/scala/org/apache/samza/metrics
 40 - 6
ZkMetadataStore.java
in samza-core/src/main/java/org/apache/samza/zk
 120 9 6
ClusterManagerConfig.java
in samza-core/src/main/java/org/apache/samza/config
 164 16 6
TableUtils.java
in samza-azure/src/main/java/org/apache/samza/util
 131 10 6
BlobUtils.java
in samza-azure/src/main/java/org/apache/samza/util
 175 12 6
SamzaYarnAppMasterLifecycle.scala
in samza-yarn/src/main/scala/org/apache/samza/job/yarn
 78 4 6
KafkaSystemConsumer.java
in samza-kafka/src/main/java/org/apache/samza/system/kafka
 224 17 6
KafkaConsumerConfig.java
in samza-kafka/src/main/java/org/apache/samza/config
 130 9 6
SamzaYarnAppMasterLifecycle.scala
in samza-yarn3/src/main/scala/org/apache/samza/job/yarn
 78 4 6
Windows.java
in samza-api/src/main/java/org/apache/samza/operators/windows
 54 4 5
Correlations

File Size vs. Commits (all time): 1232 points

samza-core/src/main/scala/org/apache/samza/storage/ContainerStorageManager.java x: 72 commits (all time) y: 304 lines of code samza-core/src/main/java/org/apache/samza/config/TaskConfig.java x: 22 commits (all time) y: 276 lines of code samza-core/src/main/scala/org/apache/samza/container/TaskInstance.scala x: 117 commits (all time) y: 506 lines of code samza-core/src/main/scala/org/apache/samza/container/TaskInstanceMetrics.scala x: 14 commits (all time) y: 35 lines of code samza-core/src/main/java/org/apache/samza/storage/blobstore/util/BlobStoreUtil.java x: 14 commits (all time) y: 473 lines of code samza-core/src/main/java/org/apache/samza/config/StorageConfig.java x: 31 commits (all time) y: 238 lines of code samza-kv-rocksdb/src/main/java/org/apache/samza/storage/kv/RocksDbKeyValueReader.java x: 23 commits (all time) y: 66 lines of code samza-kv-rocksdb/src/main/java/org/apache/samza/storage/kv/RocksDbOptionsHelper.java x: 28 commits (all time) y: 175 lines of code samza-kv-rocksdb/src/main/scala/org/apache/samza/storage/kv/RocksDbKeyValueStorageEngineFactory.scala x: 25 commits (all time) y: 46 lines of code samza-azure/src/main/java/org/apache/samza/system/azureblob/AzureBlobClientBuilder.java x: 5 commits (all time) y: 74 lines of code samza-azure/src/main/java/org/apache/samza/system/azureblob/AzureBlobClientBuilderFactory.java x: 1 commits (all time) y: 8 lines of code samza-azure/src/main/java/org/apache/samza/system/azureblob/AzureBlobConfig.java x: 9 commits (all time) y: 181 lines of code samza-azure/src/main/java/org/apache/samza/system/azureblob/BlobClientBuilder.java x: 1 commits (all time) y: 5 lines of code samza-azure/src/main/java/org/apache/samza/system/azureblob/producer/AzureBlobSystemProducer.java x: 11 commits (all time) y: 343 lines of code samza-core/src/main/java/org/apache/samza/operators/impl/WatermarkMetrics.java x: 6 commits (all time) y: 26 lines of code samza-core/src/main/java/org/apache/samza/operators/impl/WatermarkStates.java x: 11 commits (all time) y: 144 lines of code samza-core/src/main/java/org/apache/samza/operators/impl/OperatorImplGraph.java x: 53 commits (all time) y: 276 lines of code samza-core/src/main/java/org/apache/samza/clustermanager/ContainerProcessManager.java x: 53 commits (all time) y: 455 lines of code samza-core/src/main/scala/org/apache/samza/storage/ContainerStorageManagerUtil.java x: 6 commits (all time) y: 318 lines of code samza-core/src/main/scala/org/apache/samza/storage/SideInputsManager.java x: 8 commits (all time) y: 381 lines of code samza-core/src/main/java/org/apache/samza/job/ShellCommandBuilder.java x: 6 commits (all time) y: 29 lines of code samza-core/src/main/java/org/apache/samza/storage/blobstore/BlobStoreBackupManager.java x: 14 commits (all time) y: 247 lines of code samza-core/src/main/java/org/apache/samza/storage/blobstore/util/DirDiffUtil.java x: 7 commits (all time) y: 278 lines of code samza-core/src/main/java/org/apache/samza/coordinator/stream/CoordinatorStreamSystemProducer.java x: 11 commits (all time) y: 96 lines of code samza-core/src/main/java/org/apache/samza/coordinator/stream/CoordinatorStreamWriter.java x: 13 commits (all time) y: 51 lines of code samza-core/src/main/java/org/apache/samza/config/JobConfig.java x: 43 commits (all time) y: 345 lines of code samza-core/src/main/java/org/apache/samza/operators/impl/OperatorImpl.java x: 60 commits (all time) y: 412 lines of code samza-core/src/main/java/org/apache/samza/config/ShellCommandConfig.java x: 7 commits (all time) y: 60 lines of code samza-core/src/main/java/org/apache/samza/task/DefaultTaskExecutorFactory.java x: 4 commits (all time) y: 40 lines of code samza-core/src/main/java/org/apache/samza/runtime/ContainerLaunchUtil.java x: 38 commits (all time) y: 195 lines of code samza-core/src/main/java/org/apache/samza/config/ApplicationConfig.java x: 20 commits (all time) y: 62 lines of code samza-core/src/main/java/org/apache/samza/config/RunLoopConfig.java x: 2 commits (all time) y: 50 lines of code samza-core/src/main/java/org/apache/samza/container/RunLoop.java x: 26 commits (all time) y: 742 lines of code samza-core/src/main/java/org/apache/samza/task/TaskCallbackManager.java x: 14 commits (all time) y: 86 lines of code samza-core/src/main/java/org/apache/samza/application/ApplicationUtil.java x: 12 commits (all time) y: 32 lines of code samza-core/src/main/java/org/apache/samza/container/RunLoopFactory.java x: 31 commits (all time) y: 27 lines of code samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala x: 257 commits (all time) y: 892 lines of code samza-core/src/main/java/org/apache/samza/config/BlobStoreConfig.java x: 9 commits (all time) y: 45 lines of code samza-core/src/main/java/org/apache/samza/storage/blobstore/BlobStoreRestoreManager.java x: 17 commits (all time) y: 264 lines of code samza-core/src/main/scala/org/apache/samza/storage/ContainerStorageManagerRestoreUtil.java x: 2 commits (all time) y: 284 lines of code samza-api/src/main/java/org/apache/samza/storage/blobstore/BlobStoreManager.java x: 3 commits (all time) y: 14 lines of code samza-core/src/main/java/org/apache/samza/storage/TaskStorageCommitManager.java x: 8 commits (all time) y: 260 lines of code samza-core/src/main/java/org/apache/samza/execution/IntermediateStreamManager.java x: 9 commits (all time) y: 107 lines of code samza-core/src/main/scala/org/apache/samza/container/SamzaContainerMetrics.scala x: 33 commits (all time) y: 38 lines of code samza-yarn/src/main/java/org/apache/samza/job/yarn/YarnClusterResourceManager.java x: 47 commits (all time) y: 509 lines of code samza-yarn/src/main/scala/org/apache/samza/job/yarn/SamzaAppMasterMetrics.scala x: 23 commits (all time) y: 41 lines of code samza-azure/src/main/java/org/apache/samza/system/azureblob/avro/AzureBlobAvroWriter.java x: 9 commits (all time) y: 284 lines of code samza-azure/src/main/java/org/apache/samza/system/azureblob/avro/AzureBlobAvroWriterFactory.java x: 4 commits (all time) y: 22 lines of code samza-azure/src/main/java/org/apache/samza/system/azureblob/avro/AzureBlobOutputStream.java x: 13 commits (all time) y: 225 lines of code samza-azure/src/main/java/org/apache/samza/system/azureblob/producer/AzureBlobWriterFactory.java x: 4 commits (all time) y: 14 lines of code samza-azure/src/main/java/org/apache/samza/system/eventhub/consumer/EventHubSystemConsumer.java x: 29 commits (all time) y: 392 lines of code samza-api/src/main/java/org/apache/samza/context/TaskContext.java x: 17 commits (all time) y: 23 lines of code samza-api/src/main/java/org/apache/samza/task/TaskExecutorFactory.java x: 2 commits (all time) y: 12 lines of code samza-core/src/main/java/org/apache/samza/context/TaskContextImpl.java x: 20 commits (all time) y: 95 lines of code samza-api/src/main/java/org/apache/samza/context/ContainerContext.java x: 13 commits (all time) y: 10 lines of code samza-api/src/main/java/org/apache/samza/task/StreamOperatorTaskFactory.java x: 2 commits (all time) y: 4 lines of code samza-core/src/main/java/org/apache/samza/context/ContainerContextImpl.java x: 5 commits (all time) y: 27 lines of code samza-core/src/main/java/org/apache/samza/storage/StorageRecovery.java x: 62 commits (all time) y: 175 lines of code samza-core/src/main/java/org/apache/samza/task/StreamOperatorTask.java x: 47 commits (all time) y: 130 lines of code samza-core/src/main/java/org/apache/samza/task/TaskFactoryUtil.java x: 26 commits (all time) y: 75 lines of code samza-azure/src/main/java/org/apache/samza/system/eventhub/EventHubConfig.java x: 26 commits (all time) y: 159 lines of code samza-azure/src/main/java/org/apache/samza/system/eventhub/SamzaEventHubClientManager.java x: 9 commits (all time) y: 86 lines of code samza-tools/src/main/java/org/apache/samza/tools/EventHubConsoleConsumer.java x: 5 commits (all time) y: 85 lines of code samza-core/src/main/java/org/apache/samza/coordinator/metadatastore/CoordinatorStreamStore.java x: 25 commits (all time) y: 185 lines of code samza-core/src/main/java/org/apache/samza/execution/JobPlanner.java x: 36 commits (all time) y: 145 lines of code samza-core/src/main/scala/org/apache/samza/metrics/JmxServer.scala x: 9 commits (all time) y: 65 lines of code samza-core/src/main/scala/org/apache/samza/util/Logging.scala x: 4 commits (all time) y: 65 lines of code samza-rest/src/main/java/org/apache/samza/monitor/LocalStoreMonitor.java x: 17 commits (all time) y: 103 lines of code samza-core/src/main/java/org/apache/samza/storage/NonTransactionalStateTaskRestoreManager.java x: 19 commits (all time) y: 268 lines of code samza-core/src/main/java/org/apache/samza/storage/SideInputTask.java x: 3 commits (all time) y: 106 lines of code samza-core/src/main/java/org/apache/samza/storage/StorageManagerUtil.java x: 34 commits (all time) y: 302 lines of code samza-core/src/main/java/org/apache/samza/storage/TransactionalStateTaskRestoreManager.java x: 21 commits (all time) y: 517 lines of code samza-core/src/main/java/org/apache/samza/storage/blobstore/metrics/BlobStoreBackupManagerMetrics.java x: 4 commits (all time) y: 92 lines of code samza-log4j2/src/main/java/org/apache/samza/logging/log4j2/StreamAppender.java x: 29 commits (all time) y: 341 lines of code samza-core/src/main/java/org/apache/samza/util/FutureUtil.java x: 11 commits (all time) y: 116 lines of code samza-core/src/main/java/org/apache/samza/util/RetryPolicyConfig.java x: 3 commits (all time) y: 42 lines of code samza-core/src/main/java/org/apache/samza/zk/ZkCoordinationUtils.java x: 12 commits (all time) y: 48 lines of code samza-core/src/main/java/org/apache/samza/zk/ZkCoordinationUtilsFactory.java x: 11 commits (all time) y: 46 lines of code samza-core/src/main/java/org/apache/samza/zk/ZkJobCoordinator.java x: 92 commits (all time) y: 553 lines of code samza-core/src/main/java/org/apache/samza/zk/ZkJobCoordinatorFactory.java x: 34 commits (all time) y: 41 lines of code samza-core/src/main/java/org/apache/samza/zk/ZkLeaderElector.java x: 16 commits (all time) y: 127 lines of code samza-core/src/main/java/org/apache/samza/zk/ZkMetadataStore.java x: 9 commits (all time) y: 120 lines of code samza-core/src/main/java/org/apache/samza/zk/ZkStringSerializer.java x: 4 commits (all time) y: 31 lines of code samza-core/src/main/java/org/apache/samza/zk/ZkUtils.java x: 38 commits (all time) y: 484 lines of code samza-sql-shell/src/main/java/org/apache/samza/sql/client/impl/SamzaExecutor.java x: 31 commits (all time) y: 389 lines of code samza-api/src/main/java/org/apache/samza/drain/DrainNotification.java x: 2 commits (all time) y: 55 lines of code samza-api/src/main/java/org/apache/samza/system/IncomingMessageEnvelope.java x: 30 commits (all time) y: 129 lines of code samza-core/src/main/java/org/apache/samza/container/SamzaContainerMonitorListener.java x: 3 commits (all time) y: 48 lines of code samza-core/src/main/java/org/apache/samza/container/host/DefaultSystemStatisticsGetter.java x: 2 commits (all time) y: 23 lines of code samza-core/src/main/java/org/apache/samza/container/host/OshiBasedStatisticsGetter.java x: 2 commits (all time) y: 63 lines of code samza-core/src/main/java/org/apache/samza/container/host/PosixCommandBasedStatisticsGetter.java x: 9 commits (all time) y: 53 lines of code samza-core/src/main/java/org/apache/samza/container/host/ProcessCPUStatistics.java x: 2 commits (all time) y: 30 lines of code samza-core/src/main/java/org/apache/samza/container/host/StatisticsMonitorImpl.java x: 5 commits (all time) y: 92 lines of code samza-core/src/main/java/org/apache/samza/container/host/SystemStatistics.java x: 2 commits (all time) y: 35 lines of code samza-core/src/main/java/org/apache/samza/container/host/SystemStatisticsGetter.java x: 3 commits (all time) y: 5 lines of code samza-core/src/main/java/org/apache/samza/container/host/SystemStatisticsMonitor.java x: 3 commits (all time) y: 9 lines of code samza-core/src/main/java/org/apache/samza/drain/DrainNotificationObjectMapper.java x: 4 commits (all time) y: 60 lines of code samza-core/src/main/java/org/apache/samza/drain/DrainUtils.java x: 5 commits (all time) y: 95 lines of code samza-core/src/main/java/org/apache/samza/operators/impl/ControlMessageSender.java x: 9 commits (all time) y: 52 lines of code samza-core/src/main/scala/org/apache/samza/system/SystemConsumers.scala x: 61 commits (all time) y: 282 lines of code samza-log4j2/src/main/java/org/apache/samza/logging/log4j2/StreamAppenderMetrics.java x: 7 commits (all time) y: 20 lines of code samza-api/src/main/java/org/apache/samza/storage/StateBackendFactory.java x: 8 commits (all time) y: 38 lines of code samza-core/src/main/java/org/apache/samza/storage/KafkaChangelogStateBackendFactory.java x: 11 commits (all time) y: 170 lines of code samza-core/src/main/java/org/apache/samza/storage/blobstore/BlobStoreStateBackendFactory.java x: 6 commits (all time) y: 79 lines of code samza-hdfs/src/main/java/org/apache/samza/system/hdfs/HdfsSystemAdmin.java x: 13 commits (all time) y: 133 lines of code samza-hdfs/src/main/java/org/apache/samza/system/hdfs/HdfsSystemConsumer.java x: 11 commits (all time) y: 180 lines of code samza-hdfs/src/main/java/org/apache/samza/system/hdfs/partitioner/DirectoryPartitioner.java x: 6 commits (all time) y: 135 lines of code samza-kafka/src/main/scala/org/apache/samza/config/KafkaConfig.scala x: 78 commits (all time) y: 247 lines of code samza-rest/src/main/java/org/apache/samza/monitor/LocalStoreMonitorConfig.java x: 9 commits (all time) y: 29 lines of code samza-rest/src/main/java/org/apache/samza/monitor/MonitorConfig.java x: 5 commits (all time) y: 49 lines of code samza-rest/src/main/java/org/apache/samza/rest/SamzaRestApplication.java x: 9 commits (all time) y: 47 lines of code samza-rest/src/main/java/org/apache/samza/rest/resources/TasksResource.java x: 8 commits (all time) y: 53 lines of code samza-yarn/src/main/scala/org/apache/samza/job/yarn/ClientHelper.scala x: 27 commits (all time) y: 330 lines of code samza-yarn3/src/main/java/org/apache/samza/config/YarnConfig.java x: 1 commits (all time) y: 113 lines of code samza-yarn3/src/main/java/org/apache/samza/job/yarn/FileSystemImplConfig.java x: 1 commits (all time) y: 31 lines of code samza-yarn3/src/main/java/org/apache/samza/job/yarn/LocalizerResourceConfig.java x: 1 commits (all time) y: 54 lines of code samza-yarn3/src/main/java/org/apache/samza/job/yarn/LocalizerResourceException.java x: 1 commits (all time) y: 15 lines of code samza-yarn3/src/main/java/org/apache/samza/job/yarn/LocalizerResourceMapper.java x: 1 commits (all time) y: 64 lines of code samza-yarn3/src/main/java/org/apache/samza/job/yarn/YarnAppState.java x: 1 commits (all time) y: 51 lines of code samza-yarn3/src/main/java/org/apache/samza/job/yarn/YarnClusterResourceManager.java x: 1 commits (all time) y: 507 lines of code samza-yarn3/src/main/java/org/apache/samza/job/yarn/YarnFaultDomainManager.java x: 1 commits (all time) y: 79 lines of code samza-yarn3/src/main/java/org/apache/samza/job/yarn/YarnFaultDomainManagerFactory.java x: 1 commits (all time) y: 11 lines of code samza-yarn3/src/main/java/org/apache/samza/job/yarn/YarnResourceManagerFactory.java x: 1 commits (all time) y: 19 lines of code samza-yarn3/src/main/java/org/apache/samza/validation/YarnJobValidationTool.java x: 1 commits (all time) y: 152 lines of code samza-yarn3/src/main/java/org/apache/samza/webapp/ApplicationMasterRestClient.java x: 1 commits (all time) y: 61 lines of code samza-yarn3/src/main/java/org/apache/samza/webapp/YarnContainerHeartbeatServlet.java x: 1 commits (all time) y: 58 lines of code samza-yarn3/src/main/less/main.less x: 1 commits (all time) y: 118 lines of code samza-yarn3/src/main/less/variables.less x: 1 commits (all time) y: 3 lines of code samza-yarn3/src/main/resources/scalate/WEB-INF/layouts/default.scaml x: 1 commits (all time) y: 41 lines of code samza-yarn3/src/main/resources/scalate/WEB-INF/views/index.scaml x: 1 commits (all time) y: 224 lines of code samza-yarn3/src/main/scala/org/apache/samza/job/yarn/ClientHelper.scala x: 1 commits (all time) y: 330 lines of code samza-yarn3/src/main/scala/org/apache/samza/job/yarn/SamzaAppMasterMetrics.scala x: 1 commits (all time) y: 34 lines of code samza-yarn3/src/main/scala/org/apache/samza/job/yarn/SamzaAppMasterSecurityManager.scala x: 1 commits (all time) y: 74 lines of code samza-yarn3/src/main/scala/org/apache/samza/job/yarn/SamzaContainerSecurityManager.scala x: 1 commits (all time) y: 71 lines of code samza-yarn3/src/main/scala/org/apache/samza/job/yarn/YarnContainer.scala x: 1 commits (all time) y: 22 lines of code samza-yarn3/src/main/scala/org/apache/samza/job/yarn/YarnJob.scala x: 1 commits (all time) y: 137 lines of code samza-yarn3/src/main/scala/org/apache/samza/job/yarn/YarnJobFactory.scala x: 1 commits (all time) y: 28 lines of code samza-yarn3/src/main/scala/org/apache/samza/webapp/ApplicationMasterRestServlet.scala x: 1 commits (all time) y: 84 lines of code samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsManager.java x: 12 commits (all time) y: 205 lines of code samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.java x: 71 commits (all time) y: 389 lines of code samza-core/src/main/scala/org/apache/samza/util/CoordinatorStreamUtil.scala x: 30 commits (all time) y: 141 lines of code samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointManager.java x: 12 commits (all time) y: 11 lines of code samza-core/src/main/java/org/apache/samza/container/grouper/stream/GroupByPartition.java x: 16 commits (all time) y: 44 lines of code samza-core/src/main/java/org/apache/samza/container/grouper/stream/GroupBySystemStreamPartition.java x: 15 commits (all time) y: 41 lines of code samza-core/src/main/java/org/apache/samza/serializers/model/SamzaObjectMapper.java x: 30 commits (all time) y: 237 lines of code samza-core/src/main/scala/org/apache/samza/checkpoint/OffsetManager.scala x: 60 commits (all time) y: 406 lines of code samza-core/src/main/scala/org/apache/samza/serializers/CheckpointV1Serde.scala x: 6 commits (all time) y: 47 lines of code samza-kafka/src/main/scala/org/apache/samza/checkpoint/kafka/KafkaCheckpointManager.scala x: 70 commits (all time) y: 291 lines of code samza-api/src/main/java/org/apache/samza/system/DrainMessage.java x: 1 commits (all time) y: 38 lines of code samza-api/src/main/java/org/apache/samza/system/MessageType.java x: 3 commits (all time) y: 18 lines of code samza-core/src/main/java/org/apache/samza/config/StreamConfig.java x: 5 commits (all time) y: 174 lines of code samza-core/src/main/java/org/apache/samza/container/RunLoopTask.java x: 3 commits (all time) y: 23 lines of code samza-core/src/main/java/org/apache/samza/drain/DrainMonitor.java x: 2 commits (all time) y: 158 lines of code samza-core/src/main/java/org/apache/samza/operators/impl/BroadcastOperatorImpl.java x: 14 commits (all time) y: 64 lines of code samza-core/src/main/java/org/apache/samza/operators/impl/PartitionByOperatorImpl.java x: 24 commits (all time) y: 81 lines of code samza-core/src/main/java/org/apache/samza/processor/StreamProcessor.java x: 71 commits (all time) y: 372 lines of code samza-core/src/main/java/org/apache/samza/serializers/IntermediateMessageSerde.java x: 11 commits (all time) y: 83 lines of code samza-core/src/main/scala/org/apache/samza/job/local/ThreadJobFactory.scala x: 66 commits (all time) y: 116 lines of code samza-core/src/main/java/org/apache/samza/util/ThrottlingScheduler.java x: 4 commits (all time) y: 76 lines of code samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaSystemFactory.scala x: 58 commits (all time) y: 73 lines of code samza-core/src/main/java/org/apache/samza/startpoint/StartpointManager.java x: 16 commits (all time) y: 262 lines of code samza-core/src/main/java/org/apache/samza/clustermanager/ClusterBasedJobCoordinator.java x: 60 commits (all time) y: 308 lines of code samza-kv-rocksdb/src/main/scala/org/apache/samza/storage/kv/RocksDbKeyValueStore.scala x: 56 commits (all time) y: 296 lines of code samza-core/src/main/java/org/apache/samza/util/DiagnosticsUtil.java x: 28 commits (all time) y: 124 lines of code samza-core/src/main/java/org/apache/samza/storage/blobstore/diff/DirDiff.java x: 4 commits (all time) y: 162 lines of code samza-rest/src/main/java/org/apache/samza/rest/SamzaRestService.java x: 17 commits (all time) y: 112 lines of code samza-core/src/main/java/org/apache/samza/runtime/RemoteApplicationRunner.java x: 45 commits (all time) y: 122 lines of code samza-core/src/main/scala/org/apache/samza/job/local/ProcessJobFactory.scala x: 42 commits (all time) y: 69 lines of code samza-yarn/src/main/scala/org/apache/samza/job/yarn/YarnJob.scala x: 34 commits (all time) y: 137 lines of code samza-core/src/main/scala/org/apache/samza/metrics/JvmMetrics.scala x: 10 commits (all time) y: 131 lines of code samza-core/src/main/java/org/apache/samza/config/JobCoordinatorConfig.java x: 20 commits (all time) y: 55 lines of code samza-core/src/main/scala/org/apache/samza/util/FileUtil.scala x: 14 commits (all time) y: 110 lines of code samza-core/src/main/java/org/apache/samza/storage/blobstore/index/serde/SnapshotIndexSerde.java x: 5 commits (all time) y: 53 lines of code samza-api/src/main/java/org/apache/samza/system/SystemStreamPartition.java x: 8 commits (all time) y: 101 lines of code samza-api/src/main/java/org/apache/samza/table/remote/TableWriteFunction.java x: 12 commits (all time) y: 79 lines of code samza-core/src/main/java/org/apache/samza/table/utils/TableMetrics.java x: 7 commits (all time) y: 56 lines of code samza-api/src/main/java/org/apache/samza/operators/MessageStream.java x: 43 commits (all time) y: 48 lines of code samza-api/src/main/java/org/apache/samza/table/ReadWriteTable.java x: 16 commits (all time) y: 27 lines of code samza-api/src/main/java/org/apache/samza/table/Table.java x: 15 commits (all time) y: 14 lines of code samza-api/src/main/java/org/apache/samza/table/TableProvider.java x: 26 commits (all time) y: 9 lines of code samza-api/src/main/java/org/apache/samza/table/batching/Batch.java x: 2 commits (all time) y: 18 lines of code samza-api/src/main/java/org/apache/samza/table/descriptors/RemoteTableDescriptor.java x: 30 commits (all time) y: 200 lines of code samza-api/src/main/java/org/apache/samza/table/descriptors/TableDescriptor.java x: 21 commits (all time) y: 17 lines of code samza-core/src/main/java/org/apache/samza/operators/MessageStreamImpl.java x: 47 commits (all time) y: 166 lines of code samza-core/src/main/java/org/apache/samza/operators/impl/SendToTableOperatorImpl.java x: 22 commits (all time) y: 43 lines of code samza-core/src/main/java/org/apache/samza/operators/impl/SendToTableWithUpdateOperatorImpl.java x: 1 commits (all time) y: 85 lines of code samza-core/src/main/java/org/apache/samza/operators/impl/StreamTableJoinOperatorImpl.java x: 22 commits (all time) y: 51 lines of code samza-core/src/main/java/org/apache/samza/operators/spec/OperatorSpec.java x: 32 commits (all time) y: 66 lines of code samza-core/src/main/java/org/apache/samza/operators/spec/OperatorSpecs.java x: 39 commits (all time) y: 77 lines of code samza-core/src/main/java/org/apache/samza/operators/spec/SendToTableOperatorSpec.java x: 18 commits (all time) y: 24 lines of code samza-core/src/main/java/org/apache/samza/table/TableManager.java x: 39 commits (all time) y: 60 lines of code samza-core/src/main/java/org/apache/samza/table/batching/AbstractBatch.java x: 2 commits (all time) y: 39 lines of code samza-core/src/main/java/org/apache/samza/table/batching/AsyncBatchingTable.java x: 3 commits (all time) y: 120 lines of code samza-core/src/main/java/org/apache/samza/table/batching/BatchProcessor.java x: 5 commits (all time) y: 125 lines of code samza-core/src/main/java/org/apache/samza/table/batching/DeleteOperation.java x: 2 commits (all time) y: 27 lines of code samza-core/src/main/java/org/apache/samza/table/batching/TableBatchHandler.java x: 4 commits (all time) y: 111 lines of code samza-core/src/main/java/org/apache/samza/table/caching/CachingTable.java x: 31 commits (all time) y: 271 lines of code samza-core/src/main/java/org/apache/samza/table/caching/CachingTableProvider.java x: 30 commits (all time) y: 61 lines of code samza-core/src/main/java/org/apache/samza/table/caching/guava/GuavaCacheTable.java x: 27 commits (all time) y: 175 lines of code samza-core/src/main/java/org/apache/samza/table/caching/guava/GuavaCacheTableProvider.java x: 27 commits (all time) y: 32 lines of code samza-core/src/main/java/org/apache/samza/table/ratelimit/AsyncRateLimitedTable.java x: 8 commits (all time) y: 152 lines of code samza-core/src/main/java/org/apache/samza/table/remote/AsyncRemoteTable.java x: 7 commits (all time) y: 98 lines of code samza-core/src/main/java/org/apache/samza/table/remote/RemoteTable.java x: 15 commits (all time) y: 344 lines of code samza-core/src/main/java/org/apache/samza/table/remote/RemoteTableProvider.java x: 40 commits (all time) y: 119 lines of code samza-core/src/main/java/org/apache/samza/table/retry/AsyncRetriableTable.java x: 8 commits (all time) y: 123 lines of code samza-kv-couchbase/src/main/java/org/apache/samza/table/remote/couchbase/BaseCouchbaseTableFunction.java x: 7 commits (all time) y: 117 lines of code samza-kv-couchbase/src/main/java/org/apache/samza/table/remote/couchbase/CouchbaseTableReadFunction.java x: 6 commits (all time) y: 82 lines of code samza-kv-couchbase/src/main/java/org/apache/samza/table/remote/couchbase/CouchbaseTableWriteFunction.java x: 10 commits (all time) y: 75 lines of code samza-kv/src/main/java/org/apache/samza/storage/kv/LocalTable.java x: 18 commits (all time) y: 179 lines of code samza-kv/src/main/java/org/apache/samza/storage/kv/LocalTableProvider.java x: 17 commits (all time) y: 29 lines of code samza-api/src/main/java/org/apache/samza/container/grouper/stream/SystemStreamPartitionGrouper.java x: 5 commits (all time) y: 8 lines of code samza-api/src/main/java/org/apache/samza/storage/TaskRestoreManager.java x: 6 commits (all time) y: 8 lines of code samza-core/src/main/java/org/apache/samza/coordinator/staticresource/StaticResourceJobCoordinator.java x: 5 commits (all time) y: 199 lines of code samza-core/src/main/java/org/apache/samza/coordinator/staticresource/StaticResourceJobCoordinatorFactory.java x: 3 commits (all time) y: 87 lines of code samza-core/src/main/java/org/apache/samza/metrics/reporter/Metrics.java x: 2 commits (all time) y: 47 lines of code samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsHeader.java x: 2 commits (all time) y: 138 lines of code samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsSnapshotReporter.java x: 2 commits (all time) y: 179 lines of code samza-core/src/main/java/org/apache/samza/runtime/LocalContainerRunner.java x: 58 commits (all time) y: 49 lines of code samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsStreamMessage.java x: 7 commits (all time) y: 200 lines of code samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsSnapshotReporterFactory.java x: 1 commits (all time) y: 110 lines of code samza-sql/src/main/java/org/apache/samza/sql/avro/AvroRelConverter.java x: 46 commits (all time) y: 249 lines of code samza-core/src/main/java/org/apache/samza/clustermanager/JobCoordinatorLaunchUtil.java x: 8 commits (all time) y: 97 lines of code samza-core/src/main/java/org/apache/samza/coordinator/CoordinationConstants.java x: 3 commits (all time) y: 16 lines of code samza-test/src/main/python/stream_processor.py x: 11 commits (all time) y: 62 lines of code samza-core/src/main/java/org/apache/samza/util/MetricsReporterLoader.java x: 9 commits (all time) y: 28 lines of code samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV2.java x: 3 commits (all time) y: 59 lines of code samza-api/src/main/java/org/apache/samza/config/Config.java x: 15 commits (all time) y: 196 lines of code samza-api/src/main/java/org/apache/samza/config/MapConfig.java x: 13 commits (all time) y: 101 lines of code samza-api/src/main/java/org/apache/samza/job/model/TaskModel.java x: 11 commits (all time) y: 73 lines of code samza-api/src/main/java/org/apache/samza/metrics/SamzaHistogram.java x: 14 commits (all time) y: 52 lines of code samza-api/src/main/java/org/apache/samza/metrics/SlidingTimeWindowReservoir.java x: 3 commits (all time) y: 75 lines of code samza-api/src/main/java/org/apache/samza/serializers/ByteBufferSerdeFactory.java x: 2 commits (all time) y: 9 lines of code samza-api/src/main/java/org/apache/samza/serializers/JsonSerdeV2.java x: 3 commits (all time) y: 63 lines of code samza-api/src/main/java/org/apache/samza/serializers/KVSerde.java x: 4 commits (all time) y: 53 lines of code samza-api/src/main/java/org/apache/samza/serializers/SerializableSerde.java x: 4 commits (all time) y: 57 lines of code samza-api/src/main/java/org/apache/samza/serializers/StringSerde.java x: 2 commits (all time) y: 36 lines of code samza-api/src/main/java/org/apache/samza/util/BlockingEnvelopeMap.java x: 22 commits (all time) y: 208 lines of code samza-api/src/main/java/org/apache/samza/storage/StorageEngine.java x: 18 commits (all time) y: 16 lines of code samza-api/src/main/java/org/apache/samza/storage/kv/KeyValueStore.java x: 18 commits (all time) y: 44 lines of code samza-kv/src/main/scala/org/apache/samza/storage/kv/KeyValueStorageEngine.scala x: 42 commits (all time) y: 192 lines of code samza-core/src/main/scala/org/apache/samza/coordinator/JobModelManager.scala x: 75 commits (all time) y: 63 lines of code samza-log4j/src/main/java/org/apache/samza/logging/log4j/StreamAppender.java x: 34 commits (all time) y: 252 lines of code samza-core/src/main/java/org/apache/samza/coordinator/JobCoordinator.java x: 7 commits (all time) y: 12 lines of code samza-core/src/main/java/org/apache/samza/coordinator/communication/JobModelHttpServlet.java x: 1 commits (all time) y: 46 lines of code samza-core/src/main/java/org/apache/samza/coordinator/StreamPartitionCountMonitor.java x: 10 commits (all time) y: 146 lines of code samza-yarn/src/main/resources/scalate/WEB-INF/views/index.scaml x: 21 commits (all time) y: 224 lines of code samza-core/src/main/java/org/apache/samza/clustermanager/container/placement/ContainerPlacementMetadataStore.java x: 5 commits (all time) y: 176 lines of code samza-test/src/main/java/org/apache/samza/system/mock/MockSystemConsumer.java x: 8 commits (all time) y: 90 lines of code samza-core/src/main/java/org/apache/samza/job/metadata/JobCoordinatorMetadataManager.java x: 1 commits (all time) y: 243 lines of code samza-azure/src/main/java/org/apache/samza/coordinator/AzureJobCoordinator.java x: 20 commits (all time) y: 352 lines of code samza-core/src/main/java/org/apache/samza/coordinator/JobModelCalculator.java x: 1 commits (all time) y: 160 lines of code samza-core/src/main/java/org/apache/samza/coordinator/JobModelHelper.java x: 1 commits (all time) y: 151 lines of code samza-core/src/main/java/org/apache/samza/standalone/PassthroughJobCoordinator.java x: 32 commits (all time) y: 91 lines of code samza-api/src/main/java/org/apache/samza/checkpoint/Checkpoint.java x: 5 commits (all time) y: 7 lines of code samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointId.java x: 5 commits (all time) y: 59 lines of code samza-api/src/main/java/org/apache/samza/storage/StoreProperties.java x: 3 commits (all time) y: 43 lines of code samza-api/src/main/java/org/apache/samza/storage/blobstore/Metadata.java x: 2 commits (all time) y: 73 lines of code samza-api/src/main/java/org/apache/samza/storage/blobstore/exceptions/DeletedException.java x: 2 commits (all time) y: 15 lines of code samza-api/src/main/java/org/apache/samza/system/ChangelogSSPIterator.java x: 6 commits (all time) y: 34 lines of code samza-api/src/main/java/org/apache/samza/system/SystemFactory.java x: 11 commits (all time) y: 20 lines of code samza-azure/src/main/java/org/apache/samza/checkpoint/azure/AzureCheckpointManager.java x: 7 commits (all time) y: 176 lines of code samza-core/src/main/java/org/apache/samza/checkpoint/kafka/KafkaStateCheckpointMarker.java x: 2 commits (all time) y: 88 lines of code samza-core/src/main/java/org/apache/samza/coordinator/MetadataResourceUtil.java x: 11 commits (all time) y: 33 lines of code samza-core/src/main/java/org/apache/samza/serializers/CheckpointV2Serde.java x: 3 commits (all time) y: 25 lines of code samza-core/src/main/java/org/apache/samza/storage/TaskSideInputStorageManager.java x: 28 commits (all time) y: 131 lines of code samza-core/src/main/java/org/apache/samza/storage/blobstore/index/FileIndex.java x: 2 commits (all time) y: 67 lines of code samza-core/src/main/java/org/apache/samza/storage/blobstore/index/FileMetadata.java x: 2 commits (all time) y: 97 lines of code samza-core/src/main/java/org/apache/samza/storage/blobstore/index/SnapshotIndex.java x: 2 commits (all time) y: 75 lines of code samza-core/src/main/java/org/apache/samza/storage/blobstore/index/SnapshotMetadata.java x: 2 commits (all time) y: 78 lines of code samza-core/src/main/java/org/apache/samza/system/inmemory/InMemoryManager.java x: 26 commits (all time) y: 137 lines of code samza-core/src/main/scala/org/apache/samza/checkpoint/CheckpointTool.scala x: 38 commits (all time) y: 160 lines of code samza-core/src/main/scala/org/apache/samza/checkpoint/file/FileSystemCheckpointManager.scala x: 10 commits (all time) y: 55 lines of code samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKey.java x: 9 commits (all time) y: 63 lines of code samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKeySerde.java x: 12 commits (all time) y: 36 lines of code samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaConsumerProxy.java x: 9 commits (all time) y: 320 lines of code samza-kv-inmemory/src/main/java/org/apache/samza/storage/kv/inmemory/InMemoryKeyValueStorageEngineFactory.java x: 4 commits (all time) y: 20 lines of code samza-kv/src/main/java/org/apache/samza/storage/kv/BaseKeyValueStorageEngineFactory.java x: 8 commits (all time) y: 166 lines of code samza-core/src/main/java/org/apache/samza/config/ClusterManagerConfig.java x: 19 commits (all time) y: 164 lines of code samza-core/src/main/java/org/apache/samza/metrics/reporter/LoggingMetricsReporter.java x: 3 commits (all time) y: 84 lines of code samza-kv-rocksdb/src/main/java/org/apache/samza/storage/kv/descriptors/RocksDbTableDescriptor.java x: 24 commits (all time) y: 143 lines of code samza-core/src/main/java/org/apache/samza/config/ZkConfig.java x: 5 commits (all time) y: 32 lines of code samza-core/src/main/java/org/apache/samza/job/model/JobModelUtil.java x: 8 commits (all time) y: 93 lines of code samza-core/src/main/java/org/apache/samza/zk/ZkKeyBuilder.java x: 12 commits (all time) y: 45 lines of code samza-sql/src/main/java/org/apache/samza/sql/planner/Checker.java x: 9 commits (all time) y: 139 lines of code samza-sql/src/main/java/org/apache/samza/sql/avro/AvroTypeFactoryImpl.java x: 25 commits (all time) y: 95 lines of code samza-sql/src/main/java/org/apache/samza/sql/planner/QueryPlanner.java x: 34 commits (all time) y: 189 lines of code samza-sql/src/main/java/org/apache/samza/sql/planner/RelSchemaConverter.java x: 15 commits (all time) y: 74 lines of code samza-sql/src/main/java/org/apache/samza/sql/planner/SamzaSqlOperatorTable.java x: 13 commits (all time) y: 109 lines of code samza-sql/src/main/java/org/apache/samza/sql/runner/SamzaSqlApplicationRunner.java x: 36 commits (all time) y: 95 lines of code samza-sql/src/main/java/org/apache/samza/sql/translator/FilterTranslator.java x: 28 commits (all time) y: 102 lines of code samza-sql/src/main/java/org/apache/samza/sql/translator/JoinTranslator.java x: 47 commits (all time) y: 299 lines of code samza-sql/src/main/java/org/apache/samza/sql/translator/ProjectTranslator.java x: 37 commits (all time) y: 143 lines of code samza-sql/src/main/java/org/apache/samza/sql/translator/SamzaSqlRemoteTableJoinFunction.java x: 11 commits (all time) y: 50 lines of code samza-sql/src/main/java/org/apache/samza/sql/translator/SamzaSqlTableJoinFunction.java x: 15 commits (all time) y: 72 lines of code samza-sql/src/main/java/org/apache/samza/sql/translator/ScanTranslator.java x: 54 commits (all time) y: 158 lines of code samza-sql/src/main/java/org/apache/samza/sql/translator/TranslatorContext.java x: 27 commits (all time) y: 131 lines of code samza-api/src/main/java/org/apache/samza/sql/SamzaSqlRelRecord.java x: 13 commits (all time) y: 67 lines of code samza-api/src/main/java/org/apache/samza/startpoint/Startpoint.java x: 12 commits (all time) y: 40 lines of code samza-api/src/main/java/org/apache/samza/system/WatermarkMessage.java x: 5 commits (all time) y: 41 lines of code samza-aws/src/main/java/org/apache/samza/system/kinesis/consumer/KinesisSystemConsumerOffset.java x: 6 commits (all time) y: 60 lines of code samza-core/src/main/java/org/apache/samza/clustermanager/container/placement/ContainerPlacementMessageObjectMapper.java x: 2 commits (all time) y: 99 lines of code samza-core/src/main/java/org/apache/samza/container/ContainerHeartbeatClient.java x: 8 commits (all time) y: 72 lines of code samza-core/src/main/java/org/apache/samza/container/grouper/task/TaskPartitionAssignmentManager.java x: 11 commits (all time) y: 89 lines of code samza-core/src/main/java/org/apache/samza/execution/ExecutionPlan.java x: 5 commits (all time) y: 13 lines of code samza-core/src/main/java/org/apache/samza/execution/JobGraphJsonGenerator.java x: 36 commits (all time) y: 202 lines of code samza-core/src/main/java/org/apache/samza/serializers/model/JsonContainerModelMixIn.java x: 6 commits (all time) y: 14 lines of code samza-core/src/main/java/org/apache/samza/serializers/model/JsonJobModelMixIn.java x: 6 commits (all time) y: 17 lines of code samza-core/src/main/java/org/apache/samza/serializers/model/JsonTaskModelMixIn.java x: 10 commits (all time) y: 20 lines of code samza-core/src/main/java/org/apache/samza/startpoint/StartpointFanOutPerTask.java x: 3 commits (all time) y: 50 lines of code samza-core/src/main/scala/org/apache/samza/serializers/JsonSerde.scala x: 5 commits (all time) y: 30 lines of code samza-core/src/main/scala/org/apache/samza/serializers/MetricsSnapshotSerde.scala x: 4 commits (all time) y: 17 lines of code samza-core/src/main/scala/org/apache/samza/serializers/MetricsSnapshotSerdeV2.java x: 4 commits (all time) y: 44 lines of code samza-hdfs/src/main/java/org/apache/samza/system/hdfs/PartitionDescriptorUtil.java x: 2 commits (all time) y: 57 lines of code samza-rest/src/main/java/org/apache/samza/monitor/JobsClient.java x: 5 commits (all time) y: 70 lines of code samza-rest/src/main/java/org/apache/samza/rest/model/Job.java x: 2 commits (all time) y: 44 lines of code samza-rest/src/main/java/org/apache/samza/rest/model/Partition.java x: 2 commits (all time) y: 64 lines of code samza-rest/src/main/java/org/apache/samza/rest/model/Task.java x: 4 commits (all time) y: 89 lines of code samza-rest/src/main/java/org/apache/samza/rest/model/yarn/YarnApplicationInfo.java x: 6 commits (all time) y: 41 lines of code samza-rest/src/main/java/org/apache/samza/rest/proxy/job/YarnRestJobStatusProvider.java x: 7 commits (all time) y: 99 lines of code samza-sql/src/main/java/org/apache/samza/sql/data/SamzaSqlRelMessage.java x: 33 commits (all time) y: 107 lines of code samza-sql/src/main/java/org/apache/samza/sql/data/SamzaSqlRelMsgMetadata.java x: 13 commits (all time) y: 80 lines of code samza-sql/src/main/java/org/apache/samza/sql/runner/SamzaSqlApplicationConfig.java x: 54 commits (all time) y: 247 lines of code samza-sql/src/main/java/org/apache/samza/sql/serializers/SamzaSqlRelMessageSerdeFactory.java x: 7 commits (all time) y: 35 lines of code samza-sql/src/main/java/org/apache/samza/sql/util/JsonUtil.java x: 6 commits (all time) y: 44 lines of code samza-tools/src/main/java/org/apache/samza/tools/ConsoleLoggingSystemFactory.java x: 8 commits (all time) y: 102 lines of code samza-yarn/src/main/java/org/apache/samza/webapp/ApplicationMasterRestClient.java x: 5 commits (all time) y: 61 lines of code samza-yarn/src/main/java/org/apache/samza/webapp/YarnContainerHeartbeatServlet.java x: 6 commits (all time) y: 58 lines of code samza-yarn/src/main/scala/org/apache/samza/webapp/ApplicationMasterRestServlet.scala x: 21 commits (all time) y: 84 lines of code samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaSystemConsumer.java x: 28 commits (all time) y: 224 lines of code samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaSystemConsumerMetrics.scala x: 13 commits (all time) y: 58 lines of code samza-kv-inmemory/src/main/java/org/apache/samza/storage/kv/inmemory/InMemoryKeyValueStore.java x: 4 commits (all time) y: 122 lines of code samza-core/src/main/java/org/apache/samza/container/ContainerHeartbeatMonitor.java x: 15 commits (all time) y: 212 lines of code samza-core/src/main/java/org/apache/samza/clustermanager/ContainerManager.java x: 19 commits (all time) y: 368 lines of code samza-core/src/main/java/org/apache/samza/clustermanager/StandbyContainerManager.java x: 14 commits (all time) y: 399 lines of code samza-core/src/main/java/org/apache/samza/clustermanager/SamzaApplicationState.java x: 20 commits (all time) y: 42 lines of code samza-core/src/main/java/org/apache/samza/clustermanager/SamzaResourceRequest.java x: 9 commits (all time) y: 97 lines of code samza-core/src/main/scala/org/apache/samza/metrics/ContainerProcessManagerMetrics.scala x: 18 commits (all time) y: 40 lines of code samza-core/src/main/java/org/apache/samza/coordinator/stream/CoordinatorStreamValueSerde.java x: 17 commits (all time) y: 88 lines of code samza-yarn/src/main/scala/org/apache/samza/job/yarn/SamzaYarnAppMasterLifecycle.scala x: 4 commits (all time) y: 78 lines of code samza-yarn/src/main/scala/org/apache/samza/webapp/ApplicationMasterWebServlet.scala x: 6 commits (all time) y: 23 lines of code samza-core/src/main/java/org/apache/samza/container/ExecutionContainerIdManager.java x: 1 commits (all time) y: 44 lines of code samza-rest/src/main/java/org/apache/samza/monitor/SamzaMonitorService.java x: 12 commits (all time) y: 86 lines of code samza-core/src/main/java/org/apache/samza/task/TaskCallbackImpl.java x: 9 commits (all time) y: 92 lines of code samza-api/src/main/java/org/apache/samza/system/SystemAdmin.java x: 34 commits (all time) y: 53 lines of code samza-core/src/main/java/org/apache/samza/config/SystemConfig.java x: 14 commits (all time) y: 116 lines of code samza-core/src/main/java/org/apache/samza/execution/StreamManager.java x: 27 commits (all time) y: 101 lines of code samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaSystemAdmin.java x: 53 commits (all time) y: 670 lines of code samza-tools/src/main/java/org/apache/samza/tools/benchmark/SystemConsumerWithSamzaBench.java x: 22 commits (all time) y: 88 lines of code samza-log4j2/src/main/java/org/apache/samza/logging/log4j2/serializers/LoggingEventJsonSerde.java x: 5 commits (all time) y: 102 lines of code samza-core/src/main/java/org/apache/samza/container/LocalityManager.java x: 38 commits (all time) y: 52 lines of code samza-core/src/main/java/org/apache/samza/context/JobContextImpl.java x: 10 commits (all time) y: 39 lines of code samza-core/src/main/java/org/apache/samza/execution/LocalJobPlanner.java x: 21 commits (all time) y: 146 lines of code samza-core/src/main/java/org/apache/samza/execution/RemoteJobPlanner.java x: 15 commits (all time) y: 58 lines of code samza-yarn/src/main/java/org/apache/samza/validation/YarnJobValidationTool.java x: 25 commits (all time) y: 152 lines of code samza-core/src/main/java/org/apache/samza/coordinator/stream/CoordinatorStreamSystemConsumer.java x: 19 commits (all time) y: 197 lines of code samza-core/src/main/java/org/apache/samza/storage/TaskSideInputHandler.java x: 4 commits (all time) y: 187 lines of code samza-aws/src/main/java/org/apache/samza/system/kinesis/KinesisConfig.java x: 9 commits (all time) y: 171 lines of code samza-aws/src/main/java/org/apache/samza/system/kinesis/consumer/KinesisSystemConsumer.java x: 8 commits (all time) y: 157 lines of code samza-aws/src/main/java/org/apache/samza/system/kinesis/descriptors/KinesisSystemDescriptor.java x: 8 commits (all time) y: 60 lines of code samza-azure/src/main/java/org/apache/samza/coordinator/scheduler/HeartbeatScheduler.java x: 4 commits (all time) y: 48 lines of code samza-azure/src/main/java/org/apache/samza/coordinator/scheduler/JMVersionUpgradeScheduler.java x: 6 commits (all time) y: 65 lines of code samza-azure/src/main/java/org/apache/samza/coordinator/scheduler/LeaderBarrierCompleteScheduler.java x: 4 commits (all time) y: 83 lines of code samza-azure/src/main/java/org/apache/samza/coordinator/scheduler/LeaderLivenessCheckScheduler.java x: 7 commits (all time) y: 72 lines of code samza-azure/src/main/java/org/apache/samza/coordinator/scheduler/LivenessCheckScheduler.java x: 4 commits (all time) y: 71 lines of code samza-azure/src/main/java/org/apache/samza/system/eventhub/admin/EventHubSystemAdmin.java x: 20 commits (all time) y: 236 lines of code samza-azure/src/main/java/org/apache/samza/system/eventhub/producer/AsyncSystemProducer.java x: 17 commits (all time) y: 115 lines of code samza-azure/src/main/java/org/apache/samza/system/eventhub/producer/EventHubSystemProducer.java x: 18 commits (all time) y: 290 lines of code samza-core/src/main/java/org/apache/samza/clustermanager/ClusterResourceManager.java x: 14 commits (all time) y: 27 lines of code samza-core/src/main/java/org/apache/samza/clustermanager/ResourceRequestState.java x: 16 commits (all time) y: 264 lines of code samza-core/src/main/java/org/apache/samza/clustermanager/container/placement/ContainerPlacementMetadata.java x: 3 commits (all time) y: 78 lines of code samza-core/src/main/java/org/apache/samza/container/grouper/stream/AllSspToSingleTaskGrouperFactory.java x: 7 commits (all time) y: 48 lines of code samza-core/src/main/java/org/apache/samza/container/grouper/stream/SSPGrouperProxy.java x: 15 commits (all time) y: 152 lines of code samza-core/src/main/java/org/apache/samza/container/grouper/task/TaskAssignmentManager.java x: 38 commits (all time) y: 91 lines of code samza-core/src/main/java/org/apache/samza/coordinator/metadatastore/NamespaceAwareCoordinatorStreamStore.java x: 6 commits (all time) y: 73 lines of code samza-core/src/main/java/org/apache/samza/execution/JobGraph.java x: 39 commits (all time) y: 265 lines of code samza-core/src/main/java/org/apache/samza/execution/JobNode.java x: 48 commits (all time) y: 125 lines of code samza-core/src/main/java/org/apache/samza/execution/JobNodeConfigurationGenerator.java x: 39 commits (all time) y: 250 lines of code samza-core/src/main/java/org/apache/samza/execution/StreamEdge.java x: 33 commits (all time) y: 94 lines of code samza-core/src/main/java/org/apache/samza/operators/impl/EndOfStreamStates.java x: 6 commits (all time) y: 50 lines of code samza-core/src/main/java/org/apache/samza/scheduler/EpochTimeScheduler.java x: 5 commits (all time) y: 122 lines of code samza-core/src/main/java/org/apache/samza/system/inmemory/InMemorySystemAdmin.java x: 11 commits (all time) y: 59 lines of code samza-core/src/main/java/org/apache/samza/table/TableConfigGenerator.java x: 28 commits (all time) y: 58 lines of code samza-core/src/main/java/org/apache/samza/util/EmbeddedTaggedRateLimiter.java x: 14 commits (all time) y: 103 lines of code samza-core/src/main/java/org/apache/samza/zk/ZkBarrierForVersionUpgrade.java x: 23 commits (all time) y: 156 lines of code samza-elasticsearch/src/main/java/org/apache/samza/config/ElasticsearchConfig.java x: 7 commits (all time) y: 79 lines of code samza-elasticsearch/src/main/java/org/apache/samza/system/elasticsearch/ElasticsearchSystemAdmin.java x: 7 commits (all time) y: 27 lines of code samza-hdfs/src/main/java/org/apache/samza/system/hdfs/descriptors/HdfsSystemDescriptor.java x: 8 commits (all time) y: 112 lines of code samza-kafka/src/main/java/org/apache/samza/config/KafkaConsumerConfig.java x: 22 commits (all time) y: 130 lines of code samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaStreamSpec.java x: 22 commits (all time) y: 84 lines of code samza-kafka/src/main/java/org/apache/samza/system/kafka/descriptors/KafkaSystemDescriptor.java x: 15 commits (all time) y: 99 lines of code samza-kv-rocksdb/src/main/java/org/apache/samza/storage/kv/RocksDbReadingTool.java x: 4 commits (all time) y: 108 lines of code samza-kv/src/main/java/org/apache/samza/storage/kv/LargeMessageSafeStore.java x: 7 commits (all time) y: 106 lines of code samza-kv/src/main/scala/org/apache/samza/storage/kv/CachedStore.scala x: 36 commits (all time) y: 200 lines of code samza-kv/src/main/scala/org/apache/samza/storage/kv/LoggedStore.scala x: 19 commits (all time) y: 79 lines of code samza-kv/src/main/scala/org/apache/samza/storage/kv/NullSafeKeyValueStore.scala x: 17 commits (all time) y: 75 lines of code samza-kv/src/main/scala/org/apache/samza/storage/kv/SerializedKeyValueStore.scala x: 30 commits (all time) y: 159 lines of code samza-rest/src/main/java/org/apache/samza/monitor/Monitor.java x: 4 commits (all time) y: 4 lines of code samza-rest/src/main/java/org/apache/samza/monitor/MonitorLoader.java x: 10 commits (all time) y: 16 lines of code samza-rest/src/main/java/org/apache/samza/rest/proxy/job/AbstractJobProxy.java x: 9 commits (all time) y: 59 lines of code samza-rest/src/main/java/org/apache/samza/rest/proxy/job/SimpleYarnJobProxy.java x: 9 commits (all time) y: 71 lines of code samza-rest/src/main/java/org/apache/samza/rest/resources/BaseResourceConfig.java x: 3 commits (all time) y: 31 lines of code samza-rest/src/main/java/org/apache/samza/rest/resources/JobsResource.java x: 6 commits (all time) y: 95 lines of code samza-sql-shell/src/main/java/org/apache/samza/sql/client/cli/CliConstants.java x: 12 commits (all time) y: 28 lines of code samza-sql-shell/src/main/java/org/apache/samza/sql/client/cli/CliEnvironment.java x: 16 commits (all time) y: 169 lines of code samza-sql-shell/src/main/java/org/apache/samza/sql/client/cli/CliHighlighter.java x: 7 commits (all time) y: 57 lines of code samza-sql-shell/src/main/java/org/apache/samza/sql/client/cli/CliShell.java x: 20 commits (all time) y: 193 lines of code samza-sql-shell/src/main/java/org/apache/samza/sql/client/cli/Main.java x: 12 commits (all time) y: 77 lines of code samza-sql-shell/src/main/java/org/apache/samza/sql/client/cli/QueryResultLogView.java x: 11 commits (all time) y: 209 lines of code samza-sql-shell/src/main/java/org/apache/samza/sql/client/impl/CliCommandHandler.java x: 6 commits (all time) y: 578 lines of code samza-sql-shell/src/main/java/org/apache/samza/sql/client/interfaces/EnvironmentVariableHandlerImpl.java x: 9 commits (all time) y: 67 lines of code samza-sql-shell/src/main/java/org/apache/samza/sql/client/interfaces/ExecutionContext.java x: 10 commits (all time) y: 3 lines of code samza-sql-shell/src/main/java/org/apache/samza/sql/client/util/Pair.java x: 6 commits (all time) y: 21 lines of code samza-sql/src/main/java/org/apache/samza/sql/SamzaSqlInputMessage.java x: 8 commits (all time) y: 20 lines of code samza-sql/src/main/java/org/apache/samza/sql/data/RexToJavaCompiler.java x: 9 commits (all time) y: 116 lines of code samza-sql/src/main/java/org/apache/samza/sql/dsl/SamzaSqlDslConverter.java x: 17 commits (all time) y: 71 lines of code samza-sql/src/main/java/org/apache/samza/sql/fn/GetSqlFieldUdf.java x: 14 commits (all time) y: 60 lines of code samza-sql/src/main/java/org/apache/samza/sql/impl/ConfigBasedIOResolverFactory.java x: 26 commits (all time) y: 84 lines of code samza-sql/src/main/java/org/apache/samza/sql/impl/ConfigBasedUdfResolver.java x: 14 commits (all time) y: 80 lines of code samza-sql/src/main/java/org/apache/samza/sql/interfaces/UdfMetadata.java x: 12 commits (all time) y: 63 lines of code samza-sql/src/main/java/org/apache/samza/sql/planner/SamzaSqlFilterRemoteJoinRule.java x: 2 commits (all time) y: 159 lines of code samza-sql/src/main/java/org/apache/samza/sql/planner/SamzaSqlUdfOperatorTable.java x: 10 commits (all time) y: 48 lines of code samza-sql/src/main/java/org/apache/samza/sql/planner/SamzaSqlValidator.java x: 16 commits (all time) y: 273 lines of code samza-sql/src/main/java/org/apache/samza/sql/translator/LogicalAggregateTranslator.java x: 22 commits (all time) y: 71 lines of code samza-sql/src/main/java/org/apache/samza/sql/translator/QueryTranslator.java x: 72 commits (all time) y: 229 lines of code samza-sql/src/main/java/org/apache/samza/sql/translator/TranslatorInputMetricsMapFunction.java x: 8 commits (all time) y: 29 lines of code samza-sql/src/main/java/org/apache/samza/sql/translator/TranslatorOutputMetricsMapFunction.java x: 8 commits (all time) y: 35 lines of code samza-sql/src/main/java/org/apache/samza/sql/util/SamzaSqlQueryParser.java x: 10 commits (all time) y: 158 lines of code samza-test/src/main/python/deployment.py x: 7 commits (all time) y: 64 lines of code samza-test/src/main/python/samza_job_yarn_deployer.py x: 11 commits (all time) y: 154 lines of code samza-tools/src/main/java/org/apache/samza/tools/GenerateKafkaEvents.java x: 6 commits (all time) y: 152 lines of code samza-tools/src/main/java/org/apache/samza/tools/SamzaSqlConsole.java x: 19 commits (all time) y: 130 lines of code samza-tools/src/main/java/org/apache/samza/tools/benchmark/AbstractSamzaBench.java x: 9 commits (all time) y: 103 lines of code samza-tools/src/main/java/org/apache/samza/tools/benchmark/ConfigBasedSspGrouperFactory.java x: 4 commits (all time) y: 51 lines of code samza-yarn/src/main/java/org/apache/samza/job/yarn/YarnAppState.java x: 10 commits (all time) y: 51 lines of code samza-core/src/main/java/org/apache/samza/runtime/ApplicationRunnerMain.java x: 22 commits (all time) y: 46 lines of code samza-core/src/main/java/org/apache/samza/operators/impl/AsyncFlatmapOperatorImpl.java x: 4 commits (all time) y: 34 lines of code samza-core/src/main/java/org/apache/samza/metrics/MetricGroup.java x: 13 commits (all time) y: 35 lines of code samza-core/src/main/scala/org/apache/samza/metrics/MetricsHelper.scala x: 11 commits (all time) y: 17 lines of code samza-kv/src/main/scala/org/apache/samza/storage/kv/SerializedKeyValueStoreMetrics.scala x: 15 commits (all time) y: 21 lines of code samza-core/src/main/scala/org/apache/samza/job/local/ProcessJob.scala x: 12 commits (all time) y: 100 lines of code samza-core/src/main/java/org/apache/samza/clustermanager/SamzaResource.java x: 10 commits (all time) y: 62 lines of code samza-core/src/main/scala/org/apache/samza/util/CommandLine.scala x: 8 commits (all time) y: 23 lines of code samza-core/src/main/scala/org/apache/samza/job/JobRunner.scala x: 42 commits (all time) y: 71 lines of code samza-api/src/main/java/org/apache/samza/system/StreamSpec.java x: 21 commits (all time) y: 114 lines of code samza-rest/src/main/resources/log4j2.xml x: 5 commits (all time) y: 19 lines of code samza-tools/src/main/resources/log4j2.xml x: 5 commits (all time) y: 16 lines of code samza-api/src/main/java/org/apache/samza/config/ConfigLoaderFactory.java x: 7 commits (all time) y: 5 lines of code samza-api/src/main/java/org/apache/samza/config/ConfigLoader.java x: 6 commits (all time) y: 4 lines of code samza-core/src/main/java/org/apache/samza/config/loaders/PropertiesConfigLoader.java x: 6 commits (all time) y: 36 lines of code samza-core/src/main/java/org/apache/samza/config/loaders/PropertiesConfigLoaderFactory.java x: 7 commits (all time) y: 16 lines of code samza-kafka/src/main/scala/org/apache/samza/checkpoint/kafka/KafkaCheckpointManagerFactory.scala x: 32 commits (all time) y: 32 lines of code samza-api/src/main/java/org/apache/samza/sql/schema/SqlFieldSchema.java x: 6 commits (all time) y: 54 lines of code samza-sql-shell/src/main/java/org/apache/samza/sql/client/util/CliUtil.java x: 7 commits (all time) y: 37 lines of code samza-api/src/main/java/org/apache/samza/table/descriptors/LocalTableDescriptor.java x: 15 commits (all time) y: 108 lines of code samza-yarn/src/main/java/org/apache/samza/config/YarnConfig.java x: 14 commits (all time) y: 113 lines of code samza-sql/src/main/java/org/apache/samza/sql/runner/SamzaSqlApplication.java x: 31 commits (all time) y: 59 lines of code samza-core/src/main/java/org/apache/samza/util/StreamUtil.java x: 11 commits (all time) y: 45 lines of code samza-log4j/src/main/java/org/apache/samza/config/Log4jSystemConfig.java x: 19 commits (all time) y: 34 lines of code samza-core/src/main/java/org/apache/samza/config/DefaultChooserConfig.java x: 7 commits (all time) y: 41 lines of code samza-core/src/main/java/org/apache/samza/execution/ExecutionPlanner.java x: 57 commits (all time) y: 183 lines of code samza-core/src/main/java/org/apache/samza/runtime/ClusterBasedProcessorLifecycleListener.java x: 1 commits (all time) y: 101 lines of code samza-api/src/main/java/org/apache/samza/operators/KV.java x: 5 commits (all time) y: 44 lines of code samza-hdfs/src/main/scala/org/apache/samza/system/hdfs/HdfsSystemFactory.scala x: 7 commits (all time) y: 30 lines of code samza-core/src/main/java/org/apache/samza/coordinator/JobCoordinatorFactory.java x: 11 commits (all time) y: 10 lines of code samza-sql-shell/src/main/java/org/apache/samza/sql/client/cli/CliView.java x: 9 commits (all time) y: 6 lines of code samza-sql-shell/src/main/java/org/apache/samza/sql/client/interfaces/SqlExecutor.java x: 14 commits (all time) y: 23 lines of code samza-core/src/main/java/org/apache/samza/zk/ZkJobCoordinatorMetrics.java x: 4 commits (all time) y: 26 lines of code samza-sql/src/main/java/org/apache/samza/sql/fn/FlattenUdf.java x: 12 commits (all time) y: 18 lines of code samza-test/src/main/python/standalone_deployment.py x: 5 commits (all time) y: 65 lines of code samza-core/src/main/scala/org/apache/samza/system/chooser/DefaultChooser.scala x: 12 commits (all time) y: 94 lines of code samza-api/src/main/java/org/apache/samza/sql/udfs/ScalarUdf.java x: 11 commits (all time) y: 6 lines of code samza-core/src/main/java/org/apache/samza/container/SamzaContainerListener.java x: 10 commits (all time) y: 7 lines of code samza-core/src/main/scala/org/apache/samza/diagnostics/BoundedList.java x: 1 commits (all time) y: 67 lines of code samza-core/src/main/scala/org/apache/samza/metrics/reporter/JmxReporter.scala x: 9 commits (all time) y: 91 lines of code samza-azure/src/main/java/org/apache/samza/coordinator/AzureLock.java x: 8 commits (all time) y: 59 lines of code samza-core/src/main/java/org/apache/samza/coordinator/CoordinationUtils.java x: 7 commits (all time) y: 10 lines of code samza-api/src/main/java/org/apache/samza/table/remote/TableRateLimiter.java x: 16 commits (all time) y: 78 lines of code samza-api/src/main/java/org/apache/samza/table/utils/SerdeUtils.java x: 16 commits (all time) y: 57 lines of code samza-api/src/main/java/org/apache/samza/startpoint/StartpointOldest.java x: 9 commits (all time) y: 15 lines of code samza-api/src/main/java/org/apache/samza/startpoint/StartpointSpecific.java x: 9 commits (all time) y: 42 lines of code samza-api/src/main/java/org/apache/samza/system/SystemConsumer.java x: 14 commits (all time) y: 11 lines of code samza-core/src/main/java/org/apache/samza/container/grouper/task/GroupByContainerCount.java x: 21 commits (all time) y: 149 lines of code samza-kv-inmemory/src/main/java/org/apache/samza/storage/kv/inmemory/descriptors/InMemoryTableDescriptor.java x: 18 commits (all time) y: 26 lines of code samza-api/src/main/java/org/apache/samza/table/retry/TableRetryPolicy.java x: 10 commits (all time) y: 109 lines of code samza-aws/src/main/java/org/apache/samza/system/kinesis/consumer/KinesisRecordProcessor.java x: 5 commits (all time) y: 111 lines of code samza-azure/src/main/java/org/apache/samza/system/eventhub/descriptors/EventHubsInputDescriptor.java x: 15 commits (all time) y: 56 lines of code samza-azure/src/main/java/org/apache/samza/system/eventhub/descriptors/EventHubsOutputDescriptor.java x: 15 commits (all time) y: 49 lines of code samza-azure/src/main/java/org/apache/samza/system/eventhub/descriptors/EventHubsSystemDescriptor.java x: 15 commits (all time) y: 87 lines of code samza-core/src/main/java/org/apache/samza/application/descriptors/ApplicationDescriptorImpl.java x: 14 commits (all time) y: 223 lines of code samza-core/src/main/java/org/apache/samza/application/descriptors/StreamApplicationDescriptorImpl.java x: 13 commits (all time) y: 145 lines of code samza-core/src/main/java/org/apache/samza/container/grouper/task/TaskNameGrouperProxy.java x: 6 commits (all time) y: 68 lines of code samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/CoordinatorStreamMessage.java x: 7 commits (all time) y: 151 lines of code samza-core/src/main/java/org/apache/samza/operators/impl/FlatmapOperatorImpl.java x: 3 commits (all time) y: 34 lines of code samza-core/src/main/java/org/apache/samza/operators/impl/OutputOperatorImpl.java x: 20 commits (all time) y: 48 lines of code samza-core/src/main/java/org/apache/samza/operators/impl/PartialJoinOperatorImpl.java x: 19 commits (all time) y: 69 lines of code samza-core/src/main/java/org/apache/samza/operators/impl/WindowOperatorImpl.java x: 32 commits (all time) y: 288 lines of code samza-core/src/main/scala/org/apache/samza/system/SystemConsumersMetrics.scala x: 9 commits (all time) y: 37 lines of code samza-hdfs/src/main/java/org/apache/samza/system/hdfs/reader/MultiFileHdfsReader.java x: 8 commits (all time) y: 120 lines of code samza-hdfs/src/main/java/org/apache/samza/system/hdfs/reader/SingleFileHdfsReader.java x: 4 commits (all time) y: 10 lines of code samza-kafka/src/main/java/org/apache/samza/system/kafka/descriptors/KafkaInputDescriptor.java x: 13 commits (all time) y: 38 lines of code samza-kv-couchbase/src/main/java/org/apache/samza/table/remote/couchbase/CouchbaseBucketRegistry.java x: 3 commits (all time) y: 114 lines of code samza-test/src/main/java/org/apache/samza/example/AppWithGlobalConfigExample.java x: 19 commits (all time) y: 54 lines of code samza-test/src/main/java/org/apache/samza/example/BroadcastExample.java x: 19 commits (all time) y: 42 lines of code samza-test/src/main/java/org/apache/samza/example/KeyValueStoreExample.java x: 23 commits (all time) y: 96 lines of code samza-test/src/main/java/org/apache/samza/example/PageViewCounterExample.java x: 22 commits (all time) y: 60 lines of code samza-test/src/main/java/org/apache/samza/example/RepartitionExample.java x: 19 commits (all time) y: 58 lines of code samza-test/src/main/java/org/apache/samza/example/WindowExample.java x: 19 commits (all time) y: 48 lines of code samza-sql-shell/src/main/java/org/apache/samza/sql/client/interfaces/QueryResult.java x: 13 commits (all time) y: 16 lines of code samza-api/src/main/java/org/apache/samza/storage/StorageEngineFactory.java x: 11 commits (all time) y: 27 lines of code samza-core/src/main/scala/org/apache/samza/util/ScalaJavaUtil.scala x: 7 commits (all time) y: 43 lines of code samza-api/src/main/java/org/apache/samza/context/ApplicationContainerContextFactory.java x: 19 commits (all time) y: 15 lines of code samza-api/src/main/java/org/apache/samza/context/ExternalContext.java x: 3 commits (all time) y: 3 lines of code samza-api/src/main/java/org/apache/samza/runtime/ApplicationRunner.java x: 24 commits (all time) y: 16 lines of code samza-api/src/main/java/org/apache/samza/table/descriptors/BaseTableDescriptor.java x: 14 commits (all time) y: 39 lines of code samza-core/src/main/java/org/apache/samza/util/SamzaUncaughtExceptionHandler.java x: 5 commits (all time) y: 23 lines of code samza-core/src/main/java/org/apache/samza/util/ThreadUtil.java x: 3 commits (all time) y: 88 lines of code samza-core/src/main/java/org/apache/samza/container/grouper/task/GroupByContainerCountFactory.java x: 8 commits (all time) y: 9 lines of code samza-core/src/main/java/org/apache/samza/coordinator/StreamRegexMonitor.java x: 4 commits (all time) y: 125 lines of code samza-core/src/main/java/org/apache/samza/execution/OperatorSpecGraphAnalyzer.java x: 18 commits (all time) y: 99 lines of code samza-api/src/main/java/org/apache/samza/table/TableProviderFactory.java x: 14 commits (all time) y: 6 lines of code samza-api/src/main/java/org/apache/samza/table/descriptors/GuavaCacheTableDescriptor.java x: 9 commits (all time) y: 34 lines of code samza-api/src/main/java/org/apache/samza/table/descriptors/HybridTableDescriptor.java x: 9 commits (all time) y: 9 lines of code samza-core/src/main/java/org/apache/samza/application/descriptors/TaskApplicationDescriptorImpl.java x: 14 commits (all time) y: 45 lines of code samza-core/src/main/java/org/apache/samza/table/BaseTableProvider.java x: 14 commits (all time) y: 21 lines of code samza-core/src/main/java/org/apache/samza/table/caching/CachingTableProviderFactory.java x: 14 commits (all time) y: 9 lines of code samza-test/src/main/java/org/apache/samza/example/TaskApplicationExample.java x: 18 commits (all time) y: 48 lines of code samza-api/src/main/java/org/apache/samza/application/SamzaApplication.java x: 15 commits (all time) y: 10 lines of code samza-api/src/main/java/org/apache/samza/application/StreamApplication.java x: 21 commits (all time) y: 19 lines of code samza-api/src/main/java/org/apache/samza/application/TaskApplication.java x: 17 commits (all time) y: 14 lines of code samza-api/src/main/java/org/apache/samza/context/ApplicationContainerContext.java x: 16 commits (all time) y: 7 lines of code samza-api/src/main/java/org/apache/samza/context/ApplicationTaskContext.java x: 16 commits (all time) y: 8 lines of code samza-api/src/main/java/org/apache/samza/system/descriptors/StreamExpander.java x: 8 commits (all time) y: 7 lines of code samza-core/src/main/java/org/apache/samza/operators/impl/store/TimeSeriesStoreImpl.java x: 11 commits (all time) y: 143 lines of code samza-api/src/main/java/org/apache/samza/system/descriptors/OutputDescriptor.java x: 10 commits (all time) y: 8 lines of code samza-api/src/main/java/org/apache/samza/system/descriptors/SystemDescriptor.java x: 10 commits (all time) y: 72 lines of code samza-core/src/main/java/org/apache/samza/application/LegacyTaskApplication.java x: 13 commits (all time) y: 13 lines of code samza-test/src/main/java/org/apache/samza/example/OrderShipmentJoinExample.java x: 16 commits (all time) y: 82 lines of code samza-api/src/main/java/org/apache/samza/operators/functions/ClosableFunction.java x: 12 commits (all time) y: 6 lines of code samza-core/src/main/java/org/apache/samza/operators/OperatorSpecGraph.java x: 16 commits (all time) y: 73 lines of code samza-core/src/main/java/org/apache/samza/operators/spec/InputOperatorSpec.java x: 25 commits (all time) y: 45 lines of code samza-core/src/main/java/org/apache/samza/operators/stream/IntermediateMessageStreamImpl.java x: 20 commits (all time) y: 33 lines of code samza-log4j2/src/main/java/org/apache/samza/logging/log4j2/serializers/LoggingEventStringSerde.java x: 4 commits (all time) y: 38 lines of code samza-core/src/main/java/org/apache/samza/operators/spec/JoinOperatorSpec.java x: 14 commits (all time) y: 77 lines of code samza-core/src/main/java/org/apache/samza/operators/spec/PartitionByOperatorSpec.java x: 11 commits (all time) y: 40 lines of code samza-core/src/main/java/org/apache/samza/operators/spec/WindowOperatorSpec.java x: 19 commits (all time) y: 92 lines of code samza-core/src/main/java/org/apache/samza/system/inmemory/InMemorySystemFactory.java x: 10 commits (all time) y: 28 lines of code samza-core/src/main/java/org/apache/samza/operators/spec/OutputStreamImpl.java x: 13 commits (all time) y: 28 lines of code samza-core/src/main/scala/org/apache/samza/system/chooser/BootstrappingChooser.scala x: 23 commits (all time) y: 143 lines of code samza-core/src/main/java/org/apache/samza/executors/KeyBasedExecutorService.java x: 2 commits (all time) y: 106 lines of code samza-api/src/main/java/org/apache/samza/operators/windows/Windows.java x: 11 commits (all time) y: 54 lines of code samza-api/src/main/java/org/apache/samza/operators/windows/internal/WindowInternal.java x: 6 commits (all time) y: 106 lines of code samza-azure/src/main/java/org/apache/samza/util/TableUtils.java x: 4 commits (all time) y: 131 lines of code samza-core/src/main/java/org/apache/samza/container/disk/PollingScanDiskSpaceMonitor.java x: 4 commits (all time) y: 117 lines of code samza-core/src/main/scala/org/apache/samza/system/filereader/FileReaderSystemConsumer.scala x: 5 commits (all time) y: 84 lines of code samza-hdfs/src/main/scala/org/apache/samza/system/hdfs/HdfsConfig.scala x: 7 commits (all time) y: 83 lines of code samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaSystemProducer.scala x: 27 commits (all time) y: 148 lines of code samza-yarn/src/main/scala/org/apache/samza/job/yarn/SamzaContainerSecurityManager.scala x: 3 commits (all time) y: 71 lines of code samza-test/src/main/java/org/apache/samza/system/mock/MockSystemAdmin.java x: 15 commits (all time) y: 38 lines of code samza-core/src/main/scala/org/apache/samza/system/filereader/FileReaderSystemAdmin.scala x: 7 commits (all time) y: 86 lines of code samza-core/src/main/java/org/apache/samza/container/disk/WatermarkDiskQuotaPolicy.java x: 2 commits (all time) y: 126 lines of code samza-hdfs/src/main/java/org/apache/samza/system/hdfs/reader/AvroFileHdfsReader.java x: 1 commits (all time) y: 143 lines of code samza-yarn/src/main/less/main.less x: 2 commits (all time) y: 118 lines of code samza-test/src/main/python/samza_failure_testing.py x: 2 commits (all time) y: 120 lines of code samza-core/src/main/scala/org/apache/samza/system/chooser/BatchingChooser.scala x: 3 commits (all time) y: 66 lines of code samza-log4j/src/main/java/org/apache/samza/logging/log4j/JmxAppender.java x: 3 commits (all time) y: 53 lines of code samza-api/src/main/java/org/apache/samza/system/SystemStreamMetadata.java x: 7 commits (all time) y: 130 lines of code
892.0
lines of code
  min: 3.0
  average: 63.15
  25th percentile: 13.0
  median: 35.0
  75th percentile: 74.0
  max: 892.0
0 257.0
commits (all time)
min: 1.0 | average: 9.06 | 25th percentile: 2.0 | median: 4.0 | 75th percentile: 11.0 | max: 257.0

File Size vs. Contributors (all time): 1232 points

samza-core/src/main/scala/org/apache/samza/storage/ContainerStorageManager.java x: 22 contributors (all time) y: 304 lines of code samza-core/src/main/java/org/apache/samza/config/TaskConfig.java x: 13 contributors (all time) y: 276 lines of code samza-core/src/main/scala/org/apache/samza/container/TaskInstance.scala x: 50 contributors (all time) y: 506 lines of code samza-core/src/main/scala/org/apache/samza/container/TaskInstanceMetrics.scala x: 12 contributors (all time) y: 35 lines of code samza-core/src/main/java/org/apache/samza/storage/blobstore/util/BlobStoreUtil.java x: 4 contributors (all time) y: 473 lines of code samza-core/src/main/java/org/apache/samza/config/StorageConfig.java x: 19 contributors (all time) y: 238 lines of code samza-kv-rocksdb/src/main/java/org/apache/samza/storage/kv/RocksDbKeyValueReader.java x: 13 contributors (all time) y: 66 lines of code samza-kv-rocksdb/src/main/java/org/apache/samza/storage/kv/RocksDbOptionsHelper.java x: 17 contributors (all time) y: 175 lines of code samza-kv-rocksdb/src/main/scala/org/apache/samza/storage/kv/RocksDbKeyValueStorageEngineFactory.scala x: 19 contributors (all time) y: 46 lines of code samza-azure/src/main/java/org/apache/samza/system/azureblob/AzureBlobClientBuilder.java x: 4 contributors (all time) y: 74 lines of code samza-azure/src/main/java/org/apache/samza/system/azureblob/AzureBlobClientBuilderFactory.java x: 1 contributors (all time) y: 8 lines of code samza-azure/src/main/java/org/apache/samza/system/azureblob/AzureBlobConfig.java x: 6 contributors (all time) y: 181 lines of code samza-azure/src/main/java/org/apache/samza/system/azureblob/BlobClientBuilder.java x: 1 contributors (all time) y: 5 lines of code samza-azure/src/main/java/org/apache/samza/system/azureblob/producer/AzureBlobSystemProducer.java x: 7 contributors (all time) y: 343 lines of code samza-core/src/main/java/org/apache/samza/operators/impl/WatermarkMetrics.java x: 6 contributors (all time) y: 26 lines of code samza-core/src/main/java/org/apache/samza/operators/impl/WatermarkStates.java x: 7 contributors (all time) y: 144 lines of code samza-core/src/main/java/org/apache/samza/operators/impl/OperatorImplGraph.java x: 20 contributors (all time) y: 276 lines of code samza-core/src/main/java/org/apache/samza/clustermanager/ContainerProcessManager.java x: 24 contributors (all time) y: 455 lines of code samza-core/src/main/scala/org/apache/samza/storage/ContainerStorageManagerUtil.java x: 3 contributors (all time) y: 318 lines of code samza-core/src/main/scala/org/apache/samza/storage/SideInputsManager.java x: 4 contributors (all time) y: 381 lines of code samza-core/src/main/java/org/apache/samza/job/ShellCommandBuilder.java x: 4 contributors (all time) y: 29 lines of code samza-core/src/main/java/org/apache/samza/storage/blobstore/BlobStoreBackupManager.java x: 6 contributors (all time) y: 247 lines of code samza-core/src/main/java/org/apache/samza/storage/blobstore/util/DirDiffUtil.java x: 4 contributors (all time) y: 278 lines of code samza-core/src/main/java/org/apache/samza/coordinator/stream/CoordinatorStreamSystemProducer.java x: 10 contributors (all time) y: 96 lines of code samza-core/src/main/java/org/apache/samza/coordinator/stream/CoordinatorStreamWriter.java x: 12 contributors (all time) y: 51 lines of code samza-core/src/main/java/org/apache/samza/config/JobConfig.java x: 17 contributors (all time) y: 345 lines of code samza-core/src/main/java/org/apache/samza/operators/impl/OperatorImpl.java x: 20 contributors (all time) y: 412 lines of code samza-core/src/main/java/org/apache/samza/config/ShellCommandConfig.java x: 6 contributors (all time) y: 60 lines of code samza-core/src/main/java/org/apache/samza/task/DefaultTaskExecutorFactory.java x: 2 contributors (all time) y: 40 lines of code samza-core/src/main/java/org/apache/samza/runtime/ContainerLaunchUtil.java x: 18 contributors (all time) y: 195 lines of code samza-core/src/main/java/org/apache/samza/config/ApplicationConfig.java x: 15 contributors (all time) y: 62 lines of code samza-core/src/main/java/org/apache/samza/config/RunLoopConfig.java x: 1 contributors (all time) y: 50 lines of code samza-core/src/main/java/org/apache/samza/container/RunLoop.java x: 11 contributors (all time) y: 742 lines of code samza-core/src/main/java/org/apache/samza/task/TaskCallbackManager.java x: 13 contributors (all time) y: 86 lines of code samza-core/src/main/java/org/apache/samza/application/ApplicationUtil.java x: 9 contributors (all time) y: 32 lines of code samza-core/src/main/java/org/apache/samza/container/RunLoopFactory.java x: 24 contributors (all time) y: 27 lines of code samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala x: 75 contributors (all time) y: 892 lines of code samza-core/src/main/java/org/apache/samza/config/BlobStoreConfig.java x: 3 contributors (all time) y: 45 lines of code samza-core/src/main/java/org/apache/samza/storage/blobstore/BlobStoreRestoreManager.java x: 6 contributors (all time) y: 264 lines of code samza-core/src/main/scala/org/apache/samza/storage/ContainerStorageManagerRestoreUtil.java x: 1 contributors (all time) y: 284 lines of code samza-api/src/main/java/org/apache/samza/storage/blobstore/BlobStoreManager.java x: 2 contributors (all time) y: 14 lines of code samza-core/src/main/java/org/apache/samza/storage/TaskStorageCommitManager.java x: 4 contributors (all time) y: 260 lines of code samza-core/src/main/java/org/apache/samza/execution/IntermediateStreamManager.java x: 7 contributors (all time) y: 107 lines of code samza-core/src/main/scala/org/apache/samza/container/SamzaContainerMetrics.scala x: 21 contributors (all time) y: 38 lines of code samza-yarn/src/main/java/org/apache/samza/job/yarn/YarnClusterResourceManager.java x: 24 contributors (all time) y: 509 lines of code samza-yarn/src/main/scala/org/apache/samza/job/yarn/SamzaAppMasterMetrics.scala x: 18 contributors (all time) y: 41 lines of code samza-azure/src/main/java/org/apache/samza/system/azureblob/avro/AzureBlobAvroWriter.java x: 5 contributors (all time) y: 284 lines of code samza-azure/src/main/java/org/apache/samza/system/azureblob/avro/AzureBlobAvroWriterFactory.java x: 3 contributors (all time) y: 22 lines of code samza-azure/src/main/java/org/apache/samza/system/azureblob/avro/AzureBlobOutputStream.java x: 6 contributors (all time) y: 225 lines of code samza-azure/src/main/java/org/apache/samza/system/azureblob/producer/AzureBlobWriterFactory.java x: 3 contributors (all time) y: 14 lines of code samza-azure/src/main/java/org/apache/samza/system/eventhub/consumer/EventHubSystemConsumer.java x: 14 contributors (all time) y: 392 lines of code samza-api/src/main/java/org/apache/samza/context/TaskContext.java x: 7 contributors (all time) y: 23 lines of code samza-core/src/main/java/org/apache/samza/context/TaskContextImpl.java x: 9 contributors (all time) y: 95 lines of code samza-api/src/main/java/org/apache/samza/context/ContainerContext.java x: 6 contributors (all time) y: 10 lines of code samza-api/src/main/java/org/apache/samza/task/StreamOperatorTaskFactory.java x: 2 contributors (all time) y: 4 lines of code samza-core/src/main/java/org/apache/samza/context/ContainerContextImpl.java x: 5 contributors (all time) y: 27 lines of code samza-core/src/main/java/org/apache/samza/storage/StorageRecovery.java x: 29 contributors (all time) y: 175 lines of code samza-core/src/main/java/org/apache/samza/task/StreamOperatorTask.java x: 19 contributors (all time) y: 130 lines of code samza-core/src/main/java/org/apache/samza/task/TaskFactoryUtil.java x: 13 contributors (all time) y: 75 lines of code samza-azure/src/main/java/org/apache/samza/system/eventhub/EventHubConfig.java x: 11 contributors (all time) y: 159 lines of code samza-azure/src/main/java/org/apache/samza/system/eventhub/SamzaEventHubClientManager.java x: 6 contributors (all time) y: 86 lines of code samza-tools/src/main/java/org/apache/samza/tools/EventHubConsoleConsumer.java x: 3 contributors (all time) y: 85 lines of code samza-core/src/main/java/org/apache/samza/coordinator/metadatastore/CoordinatorStreamStore.java x: 11 contributors (all time) y: 185 lines of code samza-core/src/main/java/org/apache/samza/execution/JobPlanner.java x: 13 contributors (all time) y: 145 lines of code samza-core/src/main/scala/org/apache/samza/metrics/JmxServer.scala x: 7 contributors (all time) y: 65 lines of code samza-core/src/main/scala/org/apache/samza/util/Logging.scala x: 4 contributors (all time) y: 65 lines of code samza-rest/src/main/java/org/apache/samza/monitor/LocalStoreMonitor.java x: 9 contributors (all time) y: 103 lines of code samza-core/src/main/java/org/apache/samza/storage/NonTransactionalStateTaskRestoreManager.java x: 10 contributors (all time) y: 268 lines of code samza-core/src/main/java/org/apache/samza/storage/SideInputTask.java x: 3 contributors (all time) y: 106 lines of code samza-core/src/main/java/org/apache/samza/storage/StorageManagerUtil.java x: 14 contributors (all time) y: 302 lines of code samza-core/src/main/java/org/apache/samza/storage/TransactionalStateTaskRestoreManager.java x: 11 contributors (all time) y: 517 lines of code samza-core/src/main/java/org/apache/samza/storage/blobstore/metrics/BlobStoreBackupManagerMetrics.java x: 3 contributors (all time) y: 92 lines of code samza-log4j2/src/main/java/org/apache/samza/logging/log4j2/StreamAppender.java x: 16 contributors (all time) y: 341 lines of code samza-core/src/main/java/org/apache/samza/util/FutureUtil.java x: 4 contributors (all time) y: 116 lines of code samza-core/src/main/java/org/apache/samza/zk/ZkCoordinationUtils.java x: 7 contributors (all time) y: 48 lines of code samza-core/src/main/java/org/apache/samza/zk/ZkJobCoordinator.java x: 27 contributors (all time) y: 553 lines of code samza-core/src/main/java/org/apache/samza/zk/ZkJobCoordinatorFactory.java x: 16 contributors (all time) y: 41 lines of code samza-core/src/main/java/org/apache/samza/zk/ZkLeaderElector.java x: 8 contributors (all time) y: 127 lines of code samza-core/src/main/java/org/apache/samza/zk/ZkMetadataStore.java x: 5 contributors (all time) y: 120 lines of code samza-core/src/main/java/org/apache/samza/zk/ZkUtils.java x: 15 contributors (all time) y: 484 lines of code samza-sql-shell/src/main/java/org/apache/samza/sql/client/impl/SamzaExecutor.java x: 14 contributors (all time) y: 389 lines of code samza-api/src/main/java/org/apache/samza/drain/DrainNotification.java x: 2 contributors (all time) y: 55 lines of code samza-api/src/main/java/org/apache/samza/system/IncomingMessageEnvelope.java x: 17 contributors (all time) y: 129 lines of code samza-core/src/main/java/org/apache/samza/container/SamzaContainerMonitorListener.java x: 2 contributors (all time) y: 48 lines of code samza-core/src/main/java/org/apache/samza/container/host/DefaultSystemStatisticsGetter.java x: 2 contributors (all time) y: 23 lines of code samza-core/src/main/java/org/apache/samza/container/host/OshiBasedStatisticsGetter.java x: 2 contributors (all time) y: 63 lines of code samza-core/src/main/java/org/apache/samza/container/host/PosixCommandBasedStatisticsGetter.java x: 7 contributors (all time) y: 53 lines of code samza-core/src/main/java/org/apache/samza/container/host/ProcessCPUStatistics.java x: 2 contributors (all time) y: 30 lines of code samza-core/src/main/java/org/apache/samza/container/host/StatisticsMonitorImpl.java x: 5 contributors (all time) y: 92 lines of code samza-core/src/main/java/org/apache/samza/container/host/SystemStatistics.java x: 2 contributors (all time) y: 35 lines of code samza-core/src/main/java/org/apache/samza/container/host/SystemStatisticsGetter.java x: 3 contributors (all time) y: 5 lines of code samza-core/src/main/java/org/apache/samza/container/host/SystemStatisticsMonitor.java x: 3 contributors (all time) y: 9 lines of code samza-core/src/main/java/org/apache/samza/drain/DrainUtils.java x: 2 contributors (all time) y: 95 lines of code samza-core/src/main/java/org/apache/samza/operators/impl/ControlMessageSender.java x: 8 contributors (all time) y: 52 lines of code samza-core/src/main/scala/org/apache/samza/system/SystemConsumers.scala x: 32 contributors (all time) y: 282 lines of code samza-log4j2/src/main/java/org/apache/samza/logging/log4j2/StreamAppenderMetrics.java x: 7 contributors (all time) y: 20 lines of code samza-api/src/main/java/org/apache/samza/storage/StateBackendFactory.java x: 4 contributors (all time) y: 38 lines of code samza-core/src/main/java/org/apache/samza/storage/KafkaChangelogStateBackendFactory.java x: 5 contributors (all time) y: 170 lines of code samza-core/src/main/java/org/apache/samza/storage/blobstore/BlobStoreStateBackendFactory.java x: 4 contributors (all time) y: 79 lines of code samza-hdfs/src/main/java/org/apache/samza/system/hdfs/HdfsSystemAdmin.java x: 9 contributors (all time) y: 133 lines of code samza-hdfs/src/main/java/org/apache/samza/system/hdfs/HdfsSystemConsumer.java x: 11 contributors (all time) y: 180 lines of code samza-hdfs/src/main/java/org/apache/samza/system/hdfs/partitioner/DirectoryPartitioner.java x: 6 contributors (all time) y: 135 lines of code samza-kafka/src/main/scala/org/apache/samza/config/KafkaConfig.scala x: 36 contributors (all time) y: 247 lines of code samza-rest/src/main/java/org/apache/samza/monitor/LocalStoreMonitorConfig.java x: 7 contributors (all time) y: 29 lines of code samza-rest/src/main/java/org/apache/samza/monitor/MonitorConfig.java x: 5 contributors (all time) y: 49 lines of code samza-rest/src/main/java/org/apache/samza/rest/SamzaRestApplication.java x: 6 contributors (all time) y: 47 lines of code samza-rest/src/main/java/org/apache/samza/rest/proxy/task/SamzaTaskProxyFactory.java x: 5 contributors (all time) y: 29 lines of code samza-rest/src/main/java/org/apache/samza/rest/resources/TasksResource.java x: 6 contributors (all time) y: 53 lines of code samza-yarn/src/main/scala/org/apache/samza/job/yarn/ClientHelper.scala x: 22 contributors (all time) y: 330 lines of code samza-yarn3/src/main/java/org/apache/samza/config/YarnConfig.java x: 1 contributors (all time) y: 113 lines of code samza-yarn3/src/main/java/org/apache/samza/job/yarn/FileSystemImplConfig.java x: 1 contributors (all time) y: 31 lines of code samza-yarn3/src/main/java/org/apache/samza/job/yarn/LocalizerResourceConfig.java x: 1 contributors (all time) y: 54 lines of code samza-yarn3/src/main/java/org/apache/samza/job/yarn/LocalizerResourceException.java x: 1 contributors (all time) y: 15 lines of code samza-yarn3/src/main/java/org/apache/samza/job/yarn/LocalizerResourceMapper.java x: 1 contributors (all time) y: 64 lines of code samza-yarn3/src/main/java/org/apache/samza/job/yarn/YarnClusterResourceManager.java x: 1 contributors (all time) y: 507 lines of code samza-yarn3/src/main/java/org/apache/samza/job/yarn/YarnFaultDomainManager.java x: 1 contributors (all time) y: 79 lines of code samza-yarn3/src/main/java/org/apache/samza/job/yarn/YarnFaultDomainManagerFactory.java x: 1 contributors (all time) y: 11 lines of code samza-yarn3/src/main/java/org/apache/samza/job/yarn/YarnResourceManagerFactory.java x: 1 contributors (all time) y: 19 lines of code samza-yarn3/src/main/java/org/apache/samza/validation/YarnJobValidationTool.java x: 1 contributors (all time) y: 152 lines of code samza-yarn3/src/main/java/org/apache/samza/webapp/ApplicationMasterRestClient.java x: 1 contributors (all time) y: 61 lines of code samza-yarn3/src/main/java/org/apache/samza/webapp/YarnContainerHeartbeatServlet.java x: 1 contributors (all time) y: 58 lines of code samza-yarn3/src/main/less/main.less x: 1 contributors (all time) y: 118 lines of code samza-yarn3/src/main/less/variables.less x: 1 contributors (all time) y: 3 lines of code samza-yarn3/src/main/resources/scalate/WEB-INF/layouts/default.scaml x: 1 contributors (all time) y: 41 lines of code samza-yarn3/src/main/resources/scalate/WEB-INF/views/index.scaml x: 1 contributors (all time) y: 224 lines of code samza-yarn3/src/main/scala/org/apache/samza/job/yarn/ClientHelper.scala x: 1 contributors (all time) y: 330 lines of code samza-yarn3/src/main/scala/org/apache/samza/job/yarn/SamzaAppMasterMetrics.scala x: 1 contributors (all time) y: 34 lines of code samza-yarn3/src/main/scala/org/apache/samza/job/yarn/SamzaAppMasterSecurityManager.scala x: 1 contributors (all time) y: 74 lines of code samza-yarn3/src/main/scala/org/apache/samza/job/yarn/SamzaContainerSecurityManager.scala x: 1 contributors (all time) y: 71 lines of code samza-yarn3/src/main/scala/org/apache/samza/job/yarn/YarnContainer.scala x: 1 contributors (all time) y: 22 lines of code samza-yarn3/src/main/scala/org/apache/samza/job/yarn/YarnJob.scala x: 1 contributors (all time) y: 137 lines of code samza-yarn3/src/main/scala/org/apache/samza/job/yarn/YarnJobFactory.scala x: 1 contributors (all time) y: 28 lines of code samza-yarn3/src/main/scala/org/apache/samza/webapp/ApplicationMasterRestServlet.scala x: 1 contributors (all time) y: 84 lines of code samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsManager.java x: 7 contributors (all time) y: 205 lines of code samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.java x: 27 contributors (all time) y: 389 lines of code samza-core/src/main/scala/org/apache/samza/util/CoordinatorStreamUtil.scala x: 18 contributors (all time) y: 141 lines of code samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointManager.java x: 9 contributors (all time) y: 11 lines of code samza-core/src/main/java/org/apache/samza/container/grouper/stream/GroupByPartition.java x: 10 contributors (all time) y: 44 lines of code samza-core/src/main/java/org/apache/samza/container/grouper/stream/GroupBySystemStreamPartition.java x: 9 contributors (all time) y: 41 lines of code samza-core/src/main/java/org/apache/samza/serializers/model/SamzaObjectMapper.java x: 20 contributors (all time) y: 237 lines of code samza-core/src/main/scala/org/apache/samza/checkpoint/OffsetManager.scala x: 30 contributors (all time) y: 406 lines of code samza-core/src/main/scala/org/apache/samza/serializers/CheckpointV1Serde.scala x: 4 contributors (all time) y: 47 lines of code samza-kafka/src/main/scala/org/apache/samza/checkpoint/kafka/KafkaCheckpointManager.scala x: 30 contributors (all time) y: 291 lines of code samza-api/src/main/java/org/apache/samza/system/DrainMessage.java x: 1 contributors (all time) y: 38 lines of code samza-api/src/main/java/org/apache/samza/system/MessageType.java x: 3 contributors (all time) y: 18 lines of code samza-core/src/main/java/org/apache/samza/config/StreamConfig.java x: 4 contributors (all time) y: 174 lines of code samza-core/src/main/java/org/apache/samza/drain/DrainMonitor.java x: 1 contributors (all time) y: 158 lines of code samza-core/src/main/java/org/apache/samza/operators/impl/BroadcastOperatorImpl.java x: 10 contributors (all time) y: 64 lines of code samza-core/src/main/java/org/apache/samza/operators/impl/PartitionByOperatorImpl.java x: 13 contributors (all time) y: 81 lines of code samza-core/src/main/java/org/apache/samza/processor/StreamProcessor.java x: 23 contributors (all time) y: 372 lines of code samza-core/src/main/java/org/apache/samza/serializers/IntermediateMessageSerde.java x: 9 contributors (all time) y: 83 lines of code samza-core/src/main/scala/org/apache/samza/job/local/ThreadJobFactory.scala x: 28 contributors (all time) y: 116 lines of code samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaSystemFactory.scala x: 30 contributors (all time) y: 73 lines of code samza-core/src/main/java/org/apache/samza/startpoint/StartpointManager.java x: 11 contributors (all time) y: 262 lines of code samza-core/src/main/java/org/apache/samza/clustermanager/ClusterBasedJobCoordinator.java x: 25 contributors (all time) y: 308 lines of code samza-kv-rocksdb/src/main/scala/org/apache/samza/storage/kv/RocksDbKeyValueStore.scala x: 29 contributors (all time) y: 296 lines of code samza-core/src/main/java/org/apache/samza/util/DiagnosticsUtil.java x: 10 contributors (all time) y: 124 lines of code samza-core/src/main/java/org/apache/samza/storage/blobstore/diff/DirDiff.java x: 3 contributors (all time) y: 162 lines of code samza-core/src/main/java/org/apache/samza/storage/blobstore/index/DirIndex.java x: 4 contributors (all time) y: 180 lines of code samza-rest/src/main/java/org/apache/samza/rest/SamzaRestService.java x: 13 contributors (all time) y: 112 lines of code samza-core/src/main/java/org/apache/samza/runtime/RemoteApplicationRunner.java x: 18 contributors (all time) y: 122 lines of code samza-core/src/main/scala/org/apache/samza/job/local/ProcessJobFactory.scala x: 24 contributors (all time) y: 69 lines of code samza-yarn/src/main/scala/org/apache/samza/job/yarn/YarnJob.scala x: 25 contributors (all time) y: 137 lines of code samza-core/src/main/java/org/apache/samza/config/JobCoordinatorConfig.java x: 11 contributors (all time) y: 55 lines of code samza-core/src/main/scala/org/apache/samza/util/FileUtil.scala x: 10 contributors (all time) y: 110 lines of code samza-core/src/main/java/org/apache/samza/storage/blobstore/index/serde/SnapshotIndexSerde.java x: 3 contributors (all time) y: 53 lines of code samza-api/src/main/java/org/apache/samza/system/SystemStreamPartition.java x: 7 contributors (all time) y: 101 lines of code samza-api/src/main/java/org/apache/samza/operators/MessageStream.java x: 14 contributors (all time) y: 48 lines of code samza-api/src/main/java/org/apache/samza/table/Table.java x: 6 contributors (all time) y: 14 lines of code samza-api/src/main/java/org/apache/samza/table/TableProvider.java x: 8 contributors (all time) y: 9 lines of code samza-api/src/main/java/org/apache/samza/table/batching/Batch.java x: 2 contributors (all time) y: 18 lines of code samza-api/src/main/java/org/apache/samza/table/descriptors/RemoteTableDescriptor.java x: 10 contributors (all time) y: 200 lines of code samza-api/src/main/java/org/apache/samza/table/descriptors/TableDescriptor.java x: 5 contributors (all time) y: 17 lines of code samza-core/src/main/java/org/apache/samza/operators/MessageStreamImpl.java x: 14 contributors (all time) y: 166 lines of code samza-core/src/main/java/org/apache/samza/operators/impl/SendToTableOperatorImpl.java x: 8 contributors (all time) y: 43 lines of code samza-core/src/main/java/org/apache/samza/operators/impl/SendToTableWithUpdateOperatorImpl.java x: 1 contributors (all time) y: 85 lines of code samza-core/src/main/java/org/apache/samza/operators/spec/OperatorSpec.java x: 14 contributors (all time) y: 66 lines of code samza-core/src/main/java/org/apache/samza/operators/spec/OperatorSpecs.java x: 14 contributors (all time) y: 77 lines of code samza-core/src/main/java/org/apache/samza/operators/spec/SendToTableOperatorSpec.java x: 9 contributors (all time) y: 24 lines of code samza-core/src/main/java/org/apache/samza/table/TableManager.java x: 10 contributors (all time) y: 60 lines of code samza-core/src/main/java/org/apache/samza/table/batching/AsyncBatchingTable.java x: 3 contributors (all time) y: 120 lines of code samza-core/src/main/java/org/apache/samza/table/batching/BatchProcessor.java x: 5 contributors (all time) y: 125 lines of code samza-core/src/main/java/org/apache/samza/table/batching/DeleteOperation.java x: 2 contributors (all time) y: 27 lines of code samza-core/src/main/java/org/apache/samza/table/batching/TableBatchHandler.java x: 4 contributors (all time) y: 111 lines of code samza-core/src/main/java/org/apache/samza/table/caching/CachingTable.java x: 10 contributors (all time) y: 271 lines of code samza-core/src/main/java/org/apache/samza/table/caching/CachingTableProvider.java x: 8 contributors (all time) y: 61 lines of code samza-core/src/main/java/org/apache/samza/table/caching/guava/GuavaCacheTable.java x: 9 contributors (all time) y: 175 lines of code samza-core/src/main/java/org/apache/samza/table/caching/guava/GuavaCacheTableProvider.java x: 8 contributors (all time) y: 32 lines of code samza-core/src/main/java/org/apache/samza/table/ratelimit/AsyncRateLimitedTable.java x: 5 contributors (all time) y: 152 lines of code samza-core/src/main/java/org/apache/samza/table/remote/AsyncRemoteTable.java x: 4 contributors (all time) y: 98 lines of code samza-core/src/main/java/org/apache/samza/table/remote/RemoteTable.java x: 9 contributors (all time) y: 344 lines of code samza-core/src/main/java/org/apache/samza/table/remote/RemoteTableProvider.java x: 9 contributors (all time) y: 119 lines of code samza-kv-couchbase/src/main/java/org/apache/samza/table/remote/couchbase/CouchbaseTableReadFunction.java x: 4 contributors (all time) y: 82 lines of code samza-kv-couchbase/src/main/java/org/apache/samza/table/remote/couchbase/CouchbaseTableWriteFunction.java x: 5 contributors (all time) y: 75 lines of code samza-kv/src/main/java/org/apache/samza/storage/kv/LocalTable.java x: 5 contributors (all time) y: 179 lines of code samza-api/src/main/java/org/apache/samza/container/grouper/stream/SystemStreamPartitionGrouper.java x: 5 contributors (all time) y: 8 lines of code samza-core/src/main/java/org/apache/samza/coordinator/staticresource/StaticResourceJobCoordinator.java x: 1 contributors (all time) y: 199 lines of code samza-core/src/main/java/org/apache/samza/metrics/reporter/Metrics.java x: 1 contributors (all time) y: 47 lines of code samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsSnapshotReporter.java x: 1 contributors (all time) y: 179 lines of code samza-core/src/main/java/org/apache/samza/runtime/LocalContainerRunner.java x: 23 contributors (all time) y: 49 lines of code samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsStreamMessage.java x: 5 contributors (all time) y: 200 lines of code samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsSnapshotReporterFactory.java x: 1 contributors (all time) y: 110 lines of code samza-sql/src/main/java/org/apache/samza/sql/avro/AvroRelConverter.java x: 13 contributors (all time) y: 249 lines of code samza-core/src/main/java/org/apache/samza/coordinator/CoordinationConstants.java x: 2 contributors (all time) y: 16 lines of code samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV1.java x: 3 contributors (all time) y: 39 lines of code samza-api/src/main/java/org/apache/samza/checkpoint/CheckpointV2.java x: 3 contributors (all time) y: 59 lines of code samza-api/src/main/java/org/apache/samza/config/Config.java x: 12 contributors (all time) y: 196 lines of code samza-api/src/main/java/org/apache/samza/config/MapConfig.java x: 10 contributors (all time) y: 101 lines of code samza-api/src/main/java/org/apache/samza/job/model/TaskMode.java x: 4 contributors (all time) y: 12 lines of code samza-api/src/main/java/org/apache/samza/job/model/TaskModel.java x: 7 contributors (all time) y: 73 lines of code samza-api/src/main/java/org/apache/samza/metrics/SamzaHistogram.java x: 9 contributors (all time) y: 52 lines of code samza-api/src/main/java/org/apache/samza/metrics/SlidingTimeWindowReservoir.java x: 3 contributors (all time) y: 75 lines of code samza-api/src/main/java/org/apache/samza/serializers/ByteBufferSerdeFactory.java x: 2 contributors (all time) y: 9 lines of code samza-api/src/main/java/org/apache/samza/serializers/JsonSerdeV2.java x: 3 contributors (all time) y: 63 lines of code samza-api/src/main/java/org/apache/samza/serializers/SerializableSerde.java x: 4 contributors (all time) y: 57 lines of code samza-api/src/main/java/org/apache/samza/serializers/StringSerde.java x: 2 contributors (all time) y: 36 lines of code samza-api/src/main/java/org/apache/samza/system/BoundedSSPIterator.java x: 2 contributors (all time) y: 51 lines of code samza-api/src/main/java/org/apache/samza/util/BlockingEnvelopeMap.java x: 16 contributors (all time) y: 208 lines of code samza-api/src/main/java/org/apache/samza/storage/StorageEngine.java x: 12 contributors (all time) y: 16 lines of code samza-kv/src/main/scala/org/apache/samza/storage/kv/KeyValueStorageEngine.scala x: 28 contributors (all time) y: 192 lines of code samza-core/src/main/scala/org/apache/samza/coordinator/JobModelManager.scala x: 28 contributors (all time) y: 63 lines of code samza-log4j/src/main/java/org/apache/samza/logging/log4j/StreamAppender.java x: 18 contributors (all time) y: 252 lines of code samza-core/src/main/java/org/apache/samza/coordinator/JobCoordinator.java x: 5 contributors (all time) y: 12 lines of code samza-core/src/main/java/org/apache/samza/coordinator/StreamPartitionCountMonitor.java x: 8 contributors (all time) y: 146 lines of code samza-yarn/src/main/resources/scalate/WEB-INF/views/index.scaml x: 15 contributors (all time) y: 224 lines of code samza-core/src/main/java/org/apache/samza/clustermanager/container/placement/ContainerPlacementMetadataStore.java x: 4 contributors (all time) y: 176 lines of code samza-test/src/main/java/org/apache/samza/system/mock/MockSystemConsumer.java x: 7 contributors (all time) y: 90 lines of code samza-core/src/main/java/org/apache/samza/job/metadata/JobCoordinatorMetadataManager.java x: 1 contributors (all time) y: 243 lines of code samza-azure/src/main/java/org/apache/samza/coordinator/AzureJobCoordinator.java x: 14 contributors (all time) y: 352 lines of code samza-core/src/main/java/org/apache/samza/coordinator/JobModelCalculator.java x: 1 contributors (all time) y: 160 lines of code samza-core/src/main/java/org/apache/samza/coordinator/JobModelHelper.java x: 1 contributors (all time) y: 151 lines of code samza-core/src/main/java/org/apache/samza/standalone/PassthroughJobCoordinator.java x: 16 contributors (all time) y: 91 lines of code samza-api/src/main/java/org/apache/samza/checkpoint/Checkpoint.java x: 4 contributors (all time) y: 7 lines of code samza-api/src/main/java/org/apache/samza/storage/blobstore/Metadata.java x: 2 contributors (all time) y: 73 lines of code samza-api/src/main/java/org/apache/samza/system/ChangelogSSPIterator.java x: 4 contributors (all time) y: 34 lines of code samza-api/src/main/java/org/apache/samza/system/SystemFactory.java x: 5 contributors (all time) y: 20 lines of code samza-core/src/main/java/org/apache/samza/checkpoint/kafka/KafkaStateCheckpointMarker.java x: 2 contributors (all time) y: 88 lines of code samza-core/src/main/java/org/apache/samza/coordinator/MetadataResourceUtil.java x: 7 contributors (all time) y: 33 lines of code samza-core/src/main/java/org/apache/samza/storage/TaskSideInputStorageManager.java x: 13 contributors (all time) y: 131 lines of code samza-core/src/main/java/org/apache/samza/storage/blobstore/index/FileIndex.java x: 2 contributors (all time) y: 67 lines of code samza-core/src/main/java/org/apache/samza/storage/blobstore/index/SnapshotIndex.java x: 2 contributors (all time) y: 75 lines of code samza-core/src/main/java/org/apache/samza/storage/blobstore/index/SnapshotMetadata.java x: 2 contributors (all time) y: 78 lines of code samza-core/src/main/java/org/apache/samza/system/SystemAdmins.java x: 10 contributors (all time) y: 46 lines of code samza-core/src/main/java/org/apache/samza/system/inmemory/InMemoryManager.java x: 14 contributors (all time) y: 137 lines of code samza-core/src/main/scala/org/apache/samza/checkpoint/CheckpointTool.scala x: 24 contributors (all time) y: 160 lines of code samza-core/src/main/scala/org/apache/samza/checkpoint/file/FileSystemCheckpointManager.scala x: 8 contributors (all time) y: 55 lines of code samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKey.java x: 4 contributors (all time) y: 63 lines of code samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKeySerde.java x: 8 contributors (all time) y: 36 lines of code samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaConsumerProxy.java x: 6 contributors (all time) y: 320 lines of code samza-kv-inmemory/src/main/java/org/apache/samza/storage/kv/inmemory/InMemoryKeyValueStorageEngineFactory.java x: 4 contributors (all time) y: 20 lines of code samza-kv/src/main/java/org/apache/samza/storage/kv/BaseKeyValueStorageEngineFactory.java x: 6 contributors (all time) y: 166 lines of code samza-core/src/main/java/org/apache/samza/config/ClusterManagerConfig.java x: 14 contributors (all time) y: 164 lines of code samza-core/src/main/java/org/apache/samza/context/InternalTaskContext.java x: 6 contributors (all time) y: 32 lines of code samza-core/src/main/java/org/apache/samza/metrics/reporter/LoggingMetricsReporter.java x: 3 contributors (all time) y: 84 lines of code samza-kv-rocksdb/src/main/java/org/apache/samza/storage/kv/descriptors/RocksDbTableDescriptor.java x: 8 contributors (all time) y: 143 lines of code samza-core/src/main/java/org/apache/samza/config/ZkConfig.java x: 3 contributors (all time) y: 32 lines of code samza-core/src/main/java/org/apache/samza/job/model/JobModelUtil.java x: 6 contributors (all time) y: 93 lines of code samza-core/src/main/java/org/apache/samza/zk/ZkKeyBuilder.java x: 5 contributors (all time) y: 45 lines of code samza-sql/src/main/java/org/apache/samza/sql/planner/Checker.java x: 7 contributors (all time) y: 139 lines of code samza-sql/src/main/java/org/apache/samza/sql/planner/QueryPlanner.java x: 11 contributors (all time) y: 189 lines of code samza-sql/src/main/java/org/apache/samza/sql/planner/RelSchemaConverter.java x: 10 contributors (all time) y: 74 lines of code samza-sql/src/main/java/org/apache/samza/sql/planner/SamzaSqlOperatorTable.java x: 9 contributors (all time) y: 109 lines of code samza-sql/src/main/java/org/apache/samza/sql/runner/SamzaSqlApplicationRunner.java x: 15 contributors (all time) y: 95 lines of code samza-sql/src/main/java/org/apache/samza/sql/translator/FilterTranslator.java x: 14 contributors (all time) y: 102 lines of code samza-sql/src/main/java/org/apache/samza/sql/translator/JoinInputNode.java x: 6 contributors (all time) y: 65 lines of code samza-sql/src/main/java/org/apache/samza/sql/translator/JoinTranslator.java x: 13 contributors (all time) y: 299 lines of code samza-sql/src/main/java/org/apache/samza/sql/translator/ProjectTranslator.java x: 15 contributors (all time) y: 143 lines of code samza-sql/src/main/java/org/apache/samza/sql/translator/SamzaSqlRemoteTableJoinFunction.java x: 6 contributors (all time) y: 50 lines of code samza-sql/src/main/java/org/apache/samza/sql/translator/ScanTranslator.java x: 16 contributors (all time) y: 158 lines of code samza-sql/src/main/java/org/apache/samza/sql/translator/TranslatorContext.java x: 11 contributors (all time) y: 131 lines of code samza-api/src/main/java/org/apache/samza/sql/SamzaSqlRelRecord.java x: 8 contributors (all time) y: 67 lines of code samza-api/src/main/java/org/apache/samza/startpoint/Startpoint.java x: 7 contributors (all time) y: 40 lines of code samza-api/src/main/java/org/apache/samza/system/WatermarkMessage.java x: 4 contributors (all time) y: 41 lines of code samza-core/src/main/java/org/apache/samza/clustermanager/container/placement/ContainerPlacementMessageObjectMapper.java x: 2 contributors (all time) y: 99 lines of code samza-core/src/main/java/org/apache/samza/container/grouper/task/TaskPartitionAssignmentManager.java x: 6 contributors (all time) y: 89 lines of code samza-core/src/main/java/org/apache/samza/execution/JobGraphJsonGenerator.java x: 14 contributors (all time) y: 202 lines of code samza-core/src/main/java/org/apache/samza/serializers/model/JsonJobModelMixIn.java x: 6 contributors (all time) y: 17 lines of code samza-core/src/main/java/org/apache/samza/serializers/model/JsonTaskModelMixIn.java x: 9 contributors (all time) y: 20 lines of code samza-core/src/main/java/org/apache/samza/startpoint/StartpointFanOutPerTask.java x: 3 contributors (all time) y: 50 lines of code samza-core/src/main/scala/org/apache/samza/serializers/MetricsSnapshotSerde.scala x: 4 contributors (all time) y: 17 lines of code samza-core/src/main/scala/org/apache/samza/serializers/MetricsSnapshotSerdeV2.java x: 4 contributors (all time) y: 44 lines of code samza-hdfs/src/main/java/org/apache/samza/system/hdfs/PartitionDescriptorUtil.java x: 2 contributors (all time) y: 57 lines of code samza-rest/src/main/java/org/apache/samza/monitor/JobsClient.java x: 5 contributors (all time) y: 70 lines of code samza-rest/src/main/java/org/apache/samza/rest/model/Job.java x: 2 contributors (all time) y: 44 lines of code samza-rest/src/main/java/org/apache/samza/rest/model/Partition.java x: 2 contributors (all time) y: 64 lines of code samza-rest/src/main/java/org/apache/samza/rest/model/Task.java x: 4 contributors (all time) y: 89 lines of code samza-rest/src/main/java/org/apache/samza/rest/model/yarn/YarnApplicationInfo.java x: 6 contributors (all time) y: 41 lines of code samza-rest/src/main/java/org/apache/samza/rest/proxy/job/YarnRestJobStatusProvider.java x: 6 contributors (all time) y: 99 lines of code samza-sql/src/main/java/org/apache/samza/sql/data/SamzaSqlRelMessage.java x: 12 contributors (all time) y: 107 lines of code samza-sql/src/main/java/org/apache/samza/sql/data/SamzaSqlRelMsgMetadata.java x: 7 contributors (all time) y: 80 lines of code samza-sql/src/main/java/org/apache/samza/sql/runner/SamzaSqlApplicationConfig.java x: 15 contributors (all time) y: 247 lines of code samza-sql/src/main/java/org/apache/samza/sql/serializers/SamzaSqlRelMessageSerdeFactory.java x: 5 contributors (all time) y: 35 lines of code samza-sql/src/main/java/org/apache/samza/sql/util/JsonUtil.java x: 6 contributors (all time) y: 44 lines of code samza-tools/src/main/java/org/apache/samza/tools/ConsoleLoggingSystemFactory.java x: 5 contributors (all time) y: 102 lines of code samza-tools/src/main/java/org/apache/samza/tools/json/JsonRelConverterFactory.java x: 5 contributors (all time) y: 64 lines of code samza-yarn/src/main/java/org/apache/samza/webapp/ApplicationMasterRestClient.java x: 5 contributors (all time) y: 61 lines of code samza-yarn/src/main/java/org/apache/samza/webapp/YarnContainerHeartbeatServlet.java x: 6 contributors (all time) y: 58 lines of code samza-yarn/src/main/scala/org/apache/samza/webapp/ApplicationMasterRestServlet.scala x: 17 contributors (all time) y: 84 lines of code samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaSystemConsumer.java x: 10 contributors (all time) y: 224 lines of code samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaSystemConsumerMetrics.scala x: 8 contributors (all time) y: 58 lines of code samza-kv-inmemory/src/main/java/org/apache/samza/storage/kv/inmemory/InMemoryKeyValueStore.java x: 4 contributors (all time) y: 122 lines of code samza-core/src/main/java/org/apache/samza/container/ContainerHeartbeatMonitor.java x: 12 contributors (all time) y: 212 lines of code samza-core/src/main/java/org/apache/samza/clustermanager/ContainerAllocator.java x: 13 contributors (all time) y: 223 lines of code samza-core/src/main/java/org/apache/samza/clustermanager/ContainerManager.java x: 7 contributors (all time) y: 368 lines of code samza-core/src/main/java/org/apache/samza/clustermanager/StandbyContainerManager.java x: 11 contributors (all time) y: 399 lines of code samza-core/src/main/java/org/apache/samza/clustermanager/SamzaApplicationState.java x: 13 contributors (all time) y: 42 lines of code samza-core/src/main/java/org/apache/samza/clustermanager/SamzaResourceRequest.java x: 8 contributors (all time) y: 97 lines of code samza-core/src/main/scala/org/apache/samza/metrics/ContainerProcessManagerMetrics.scala x: 14 contributors (all time) y: 40 lines of code samza-core/src/main/java/org/apache/samza/coordinator/stream/CoordinatorStreamValueSerde.java x: 8 contributors (all time) y: 88 lines of code samza-yarn/src/main/scala/org/apache/samza/job/yarn/SamzaYarnAppMasterLifecycle.scala x: 3 contributors (all time) y: 78 lines of code samza-yarn/src/main/scala/org/apache/samza/webapp/ApplicationMasterWebServlet.scala x: 6 contributors (all time) y: 23 lines of code samza-core/src/main/java/org/apache/samza/storage/ChangelogStreamManager.java x: 11 contributors (all time) y: 105 lines of code samza-core/src/main/java/org/apache/samza/container/ExecutionContainerIdManager.java x: 1 contributors (all time) y: 44 lines of code samza-rest/src/main/java/org/apache/samza/monitor/SamzaMonitorService.java x: 8 contributors (all time) y: 86 lines of code samza-api/src/main/java/org/apache/samza/system/SystemAdmin.java x: 19 contributors (all time) y: 53 lines of code samza-core/src/main/java/org/apache/samza/config/SystemConfig.java x: 7 contributors (all time) y: 116 lines of code samza-core/src/main/java/org/apache/samza/execution/StreamManager.java x: 14 contributors (all time) y: 101 lines of code samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaSystemAdmin.java x: 18 contributors (all time) y: 670 lines of code samza-tools/src/main/java/org/apache/samza/tools/benchmark/SystemConsumerWithSamzaBench.java x: 12 contributors (all time) y: 88 lines of code samza-core/src/main/java/org/apache/samza/container/LocalityManager.java x: 19 contributors (all time) y: 52 lines of code samza-core/src/main/java/org/apache/samza/context/JobContextImpl.java x: 5 contributors (all time) y: 39 lines of code samza-core/src/main/java/org/apache/samza/execution/LocalJobPlanner.java x: 11 contributors (all time) y: 146 lines of code samza-rest/src/main/java/org/apache/samza/rest/proxy/task/SamzaTaskProxy.java x: 15 contributors (all time) y: 101 lines of code samza-yarn/src/main/java/org/apache/samza/validation/YarnJobValidationTool.java x: 16 contributors (all time) y: 152 lines of code samza-core/src/main/java/org/apache/samza/coordinator/stream/CoordinatorStreamSystemConsumer.java x: 14 contributors (all time) y: 197 lines of code samza-core/src/main/java/org/apache/samza/storage/TaskSideInputHandler.java x: 3 contributors (all time) y: 187 lines of code samza-aws/src/main/java/org/apache/samza/system/kinesis/KinesisConfig.java x: 8 contributors (all time) y: 171 lines of code samza-aws/src/main/java/org/apache/samza/system/kinesis/KinesisSystemFactory.java x: 5 contributors (all time) y: 53 lines of code samza-aws/src/main/java/org/apache/samza/system/kinesis/consumer/KinesisSystemConsumer.java x: 7 contributors (all time) y: 157 lines of code samza-azure/src/main/java/org/apache/samza/coordinator/scheduler/LivenessCheckScheduler.java x: 4 contributors (all time) y: 71 lines of code samza-azure/src/main/java/org/apache/samza/system/eventhub/admin/EventHubSystemAdmin.java x: 11 contributors (all time) y: 236 lines of code samza-azure/src/main/java/org/apache/samza/system/eventhub/producer/AsyncSystemProducer.java x: 9 contributors (all time) y: 115 lines of code samza-azure/src/main/java/org/apache/samza/system/eventhub/producer/EventHubSystemProducer.java x: 9 contributors (all time) y: 290 lines of code samza-core/src/main/java/org/apache/samza/clustermanager/ClusterResourceManager.java x: 11 contributors (all time) y: 27 lines of code samza-core/src/main/java/org/apache/samza/clustermanager/ResourceRequestState.java x: 12 contributors (all time) y: 264 lines of code samza-core/src/main/java/org/apache/samza/container/grouper/stream/SSPGrouperProxy.java x: 8 contributors (all time) y: 152 lines of code samza-core/src/main/java/org/apache/samza/container/grouper/task/GroupByContainerIds.java x: 10 contributors (all time) y: 130 lines of code samza-core/src/main/java/org/apache/samza/container/grouper/task/TaskAssignmentManager.java x: 14 contributors (all time) y: 91 lines of code samza-core/src/main/java/org/apache/samza/coordinator/metadatastore/NamespaceAwareCoordinatorStreamStore.java x: 6 contributors (all time) y: 73 lines of code samza-core/src/main/java/org/apache/samza/execution/JobNode.java x: 16 contributors (all time) y: 125 lines of code samza-core/src/main/java/org/apache/samza/execution/JobNodeConfigurationGenerator.java x: 11 contributors (all time) y: 250 lines of code samza-core/src/main/java/org/apache/samza/execution/StreamEdge.java x: 14 contributors (all time) y: 94 lines of code samza-core/src/main/java/org/apache/samza/table/TableConfigGenerator.java x: 9 contributors (all time) y: 58 lines of code samza-core/src/main/java/org/apache/samza/util/EmbeddedTaggedRateLimiter.java x: 8 contributors (all time) y: 103 lines of code samza-core/src/main/java/org/apache/samza/util/Util.java x: 3 contributors (all time) y: 29 lines of code samza-core/src/main/java/org/apache/samza/zk/ZkBarrierForVersionUpgrade.java x: 13 contributors (all time) y: 156 lines of code samza-elasticsearch/src/main/java/org/apache/samza/system/elasticsearch/ElasticsearchSystemProducerMetrics.java x: 3 contributors (all time) y: 17 lines of code samza-hdfs/src/main/java/org/apache/samza/system/hdfs/descriptors/HdfsSystemDescriptor.java x: 6 contributors (all time) y: 112 lines of code samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaStreamSpec.java x: 12 contributors (all time) y: 84 lines of code samza-kv-rocksdb/src/main/java/org/apache/samza/storage/kv/RocksDbReadingTool.java x: 4 contributors (all time) y: 108 lines of code samza-kv/src/main/java/org/apache/samza/storage/kv/LargeMessageSafeStore.java x: 5 contributors (all time) y: 106 lines of code samza-kv/src/main/scala/org/apache/samza/storage/kv/AccessLoggedStore.scala x: 12 contributors (all time) y: 128 lines of code samza-kv/src/main/scala/org/apache/samza/storage/kv/CachedStore.scala x: 22 contributors (all time) y: 200 lines of code samza-kv/src/main/scala/org/apache/samza/storage/kv/LoggedStore.scala x: 15 contributors (all time) y: 79 lines of code samza-kv/src/main/scala/org/apache/samza/storage/kv/SerializedKeyValueStore.scala x: 20 contributors (all time) y: 159 lines of code samza-rest/src/main/java/org/apache/samza/monitor/MonitorLoader.java x: 7 contributors (all time) y: 16 lines of code samza-rest/src/main/java/org/apache/samza/rest/proxy/job/AbstractJobProxy.java x: 7 contributors (all time) y: 59 lines of code samza-rest/src/main/java/org/apache/samza/rest/proxy/job/SimpleYarnJobProxy.java x: 8 contributors (all time) y: 71 lines of code samza-sql-shell/src/main/java/org/apache/samza/sql/client/cli/CliConstants.java x: 8 contributors (all time) y: 28 lines of code samza-sql-shell/src/main/java/org/apache/samza/sql/client/cli/CliEnvironment.java x: 9 contributors (all time) y: 169 lines of code samza-sql-shell/src/main/java/org/apache/samza/sql/client/cli/CliShell.java x: 9 contributors (all time) y: 193 lines of code samza-sql-shell/src/main/java/org/apache/samza/sql/client/cli/Main.java x: 8 contributors (all time) y: 77 lines of code samza-sql-shell/src/main/java/org/apache/samza/sql/client/cli/QueryResultLogView.java x: 8 contributors (all time) y: 209 lines of code samza-sql-shell/src/main/java/org/apache/samza/sql/client/impl/CliCommandHandler.java x: 4 contributors (all time) y: 578 lines of code samza-sql-shell/src/main/java/org/apache/samza/sql/client/interfaces/EnvironmentVariableHandlerImpl.java x: 7 contributors (all time) y: 67 lines of code samza-sql-shell/src/main/java/org/apache/samza/sql/client/interfaces/ExecutionContext.java x: 7 contributors (all time) y: 3 lines of code samza-sql-shell/src/main/java/org/apache/samza/sql/client/util/Pair.java x: 6 contributors (all time) y: 21 lines of code samza-sql-shell/src/main/java/org/apache/samza/sql/client/util/RandomAccessQueue.java x: 7 contributors (all time) y: 60 lines of code samza-sql/src/main/java/org/apache/samza/sql/data/RexToJavaCompiler.java x: 6 contributors (all time) y: 116 lines of code samza-sql/src/main/java/org/apache/samza/sql/impl/ConfigBasedIOResolverFactory.java x: 10 contributors (all time) y: 84 lines of code samza-sql/src/main/java/org/apache/samza/sql/impl/ConfigBasedUdfResolver.java x: 8 contributors (all time) y: 80 lines of code samza-sql/src/main/java/org/apache/samza/sql/interfaces/UdfMetadata.java x: 9 contributors (all time) y: 63 lines of code samza-sql/src/main/java/org/apache/samza/sql/planner/SamzaSqlFilterRemoteJoinRule.java x: 2 contributors (all time) y: 159 lines of code samza-sql/src/main/java/org/apache/samza/sql/planner/SamzaSqlUdfOperatorTable.java x: 9 contributors (all time) y: 48 lines of code samza-sql/src/main/java/org/apache/samza/sql/planner/SamzaSqlValidator.java x: 6 contributors (all time) y: 273 lines of code samza-sql/src/main/java/org/apache/samza/sql/translator/LogicalAggregateTranslator.java x: 10 contributors (all time) y: 71 lines of code samza-sql/src/main/java/org/apache/samza/sql/translator/QueryTranslator.java x: 16 contributors (all time) y: 229 lines of code samza-sql/src/main/java/org/apache/samza/sql/translator/TranslatorInputMetricsMapFunction.java x: 6 contributors (all time) y: 29 lines of code samza-test/src/main/java/org/apache/samza/example/AsyncApplicationExample.java x: 5 contributors (all time) y: 86 lines of code samza-test/src/main/python/samza_job_yarn_deployer.py x: 10 contributors (all time) y: 154 lines of code samza-tools/src/main/java/org/apache/samza/tools/SamzaSqlConsole.java x: 12 contributors (all time) y: 130 lines of code samza-tools/src/main/java/org/apache/samza/tools/benchmark/AbstractSamzaBench.java x: 7 contributors (all time) y: 103 lines of code samza-tools/src/main/java/org/apache/samza/tools/benchmark/ConfigBasedSspGrouperFactory.java x: 4 contributors (all time) y: 51 lines of code samza-core/src/main/java/org/apache/samza/runtime/ApplicationRunnerMain.java x: 11 contributors (all time) y: 46 lines of code samza-core/src/main/scala/org/apache/samza/metrics/MetricsHelper.scala x: 9 contributors (all time) y: 17 lines of code samza-core/src/main/scala/org/apache/samza/job/local/ProcessJob.scala x: 11 contributors (all time) y: 100 lines of code samza-core/src/main/scala/org/apache/samza/job/JobRunner.scala x: 27 contributors (all time) y: 71 lines of code samza-core/src/main/java/org/apache/samza/util/ConfigUtil.java x: 4 contributors (all time) y: 55 lines of code samza-api/src/main/java/org/apache/samza/system/StreamSpec.java x: 14 contributors (all time) y: 114 lines of code samza-kafka/src/main/scala/org/apache/samza/checkpoint/kafka/KafkaCheckpointManagerFactory.scala x: 20 contributors (all time) y: 32 lines of code samza-sql-shell/src/main/java/org/apache/samza/sql/client/util/CliUtil.java x: 6 contributors (all time) y: 37 lines of code samza-core/src/main/java/org/apache/samza/operators/util/InternalInMemoryStore.java x: 6 contributors (all time) y: 97 lines of code samza-yarn/src/main/java/org/apache/samza/config/YarnConfig.java x: 12 contributors (all time) y: 113 lines of code samza-sql/src/main/java/org/apache/samza/sql/runner/SamzaSqlApplication.java x: 11 contributors (all time) y: 59 lines of code samza-kv/src/main/scala/org/apache/samza/storage/kv/KeyValueStorageEngineMetrics.scala x: 10 contributors (all time) y: 35 lines of code samza-core/src/main/java/org/apache/samza/execution/ExecutionPlanner.java x: 16 contributors (all time) y: 183 lines of code samza-core/src/main/java/org/apache/samza/runtime/ClusterBasedProcessorLifecycleListener.java x: 1 contributors (all time) y: 101 lines of code samza-core/src/main/java/org/apache/samza/clustermanager/ProcessorFailure.java x: 4 contributors (all time) y: 22 lines of code samza-core/src/main/java/org/apache/samza/coordinator/JobCoordinatorFactory.java x: 7 contributors (all time) y: 10 lines of code samza-sql-shell/src/main/java/org/apache/samza/sql/client/cli/CliView.java x: 6 contributors (all time) y: 6 lines of code samza-core/src/main/java/org/apache/samza/zk/ZkJobCoordinatorMetrics.java x: 4 contributors (all time) y: 26 lines of code samza-test/src/main/python/standalone_deployment.py x: 3 contributors (all time) y: 65 lines of code samza-core/src/main/scala/org/apache/samza/system/chooser/DefaultChooser.scala x: 8 contributors (all time) y: 94 lines of code samza-api/src/main/java/org/apache/samza/sql/udfs/ScalarUdf.java x: 5 contributors (all time) y: 6 lines of code samza-core/src/main/java/org/apache/samza/container/SamzaContainerListener.java x: 8 contributors (all time) y: 7 lines of code samza-core/src/main/scala/org/apache/samza/diagnostics/BoundedList.java x: 1 contributors (all time) y: 67 lines of code samza-core/src/main/java/org/apache/samza/table/utils/TableMetricsUtil.java x: 7 contributors (all time) y: 52 lines of code samza-core/src/main/java/org/apache/samza/coordinator/CoordinationUtils.java x: 4 contributors (all time) y: 10 lines of code samza-api/src/main/java/org/apache/samza/table/remote/TableReadFunction.java x: 3 contributors (all time) y: 46 lines of code samza-api/src/main/java/org/apache/samza/table/utils/SerdeUtils.java x: 5 contributors (all time) y: 57 lines of code samza-api/src/main/java/org/apache/samza/system/SystemConsumer.java x: 8 contributors (all time) y: 11 lines of code samza-core/src/main/java/org/apache/samza/container/grouper/task/GroupByContainerCount.java x: 11 contributors (all time) y: 149 lines of code samza-core/src/main/scala/org/apache/samza/serializers/SerdeManager.scala x: 12 contributors (all time) y: 105 lines of code samza-aws/src/main/java/org/apache/samza/system/kinesis/consumer/KinesisRecordProcessor.java x: 5 contributors (all time) y: 111 lines of code samza-azure/src/main/java/org/apache/samza/util/BlobUtils.java x: 5 contributors (all time) y: 175 lines of code samza-core/src/main/java/org/apache/samza/application/descriptors/ApplicationDescriptorImpl.java x: 5 contributors (all time) y: 223 lines of code samza-core/src/main/java/org/apache/samza/application/descriptors/StreamApplicationDescriptorImpl.java x: 5 contributors (all time) y: 145 lines of code samza-core/src/main/java/org/apache/samza/container/grouper/task/TaskNameGrouperProxy.java x: 3 contributors (all time) y: 68 lines of code samza-core/src/main/java/org/apache/samza/coordinator/stream/messages/CoordinatorStreamMessage.java x: 6 contributors (all time) y: 151 lines of code samza-core/src/main/java/org/apache/samza/operators/impl/OutputOperatorImpl.java x: 13 contributors (all time) y: 48 lines of code samza-core/src/main/java/org/apache/samza/operators/impl/PartialJoinOperatorImpl.java x: 10 contributors (all time) y: 69 lines of code samza-core/src/main/java/org/apache/samza/operators/impl/WindowOperatorImpl.java x: 12 contributors (all time) y: 288 lines of code samza-core/src/main/scala/org/apache/samza/system/SystemConsumersMetrics.scala x: 9 contributors (all time) y: 37 lines of code samza-elasticsearch/src/main/java/org/apache/samza/system/elasticsearch/ElasticsearchSystemProducer.java x: 5 contributors (all time) y: 134 lines of code samza-hdfs/src/main/java/org/apache/samza/system/hdfs/reader/MultiFileHdfsReader.java x: 6 contributors (all time) y: 120 lines of code samza-kafka/src/main/java/org/apache/samza/system/kafka/descriptors/KafkaInputDescriptor.java x: 5 contributors (all time) y: 38 lines of code samza-kv-couchbase/src/main/java/org/apache/samza/table/remote/couchbase/CouchbaseBucketRegistry.java x: 3 contributors (all time) y: 114 lines of code samza-sql-shell/src/main/java/org/apache/samza/sql/client/interfaces/NonQueryResult.java x: 5 contributors (all time) y: 24 lines of code samza-api/src/main/java/org/apache/samza/storage/StorageEngineFactory.java x: 9 contributors (all time) y: 27 lines of code samza-api/src/main/java/org/apache/samza/context/ExternalContext.java x: 3 contributors (all time) y: 3 lines of code samza-api/src/main/java/org/apache/samza/runtime/ApplicationRunner.java x: 10 contributors (all time) y: 16 lines of code samza-core/src/main/java/org/apache/samza/util/ThreadUtil.java x: 3 contributors (all time) y: 88 lines of code samza-core/src/main/java/org/apache/samza/coordinator/StreamRegexMonitor.java x: 3 contributors (all time) y: 125 lines of code samza-core/src/main/java/org/apache/samza/execution/OperatorSpecGraphAnalyzer.java x: 5 contributors (all time) y: 99 lines of code samza-api/src/main/java/org/apache/samza/application/StreamApplication.java x: 8 contributors (all time) y: 19 lines of code samza-core/src/main/java/org/apache/samza/operators/impl/store/TimeSeriesStoreImpl.java x: 7 contributors (all time) y: 143 lines of code samza-test/src/main/java/org/apache/samza/example/OrderShipmentJoinExample.java x: 6 contributors (all time) y: 82 lines of code samza-api/src/main/java/org/apache/samza/operators/functions/ClosableFunction.java x: 7 contributors (all time) y: 6 lines of code samza-api/src/main/java/org/apache/samza/operators/functions/InitableFunction.java x: 10 contributors (all time) y: 7 lines of code samza-core/src/main/java/org/apache/samza/operators/spec/InputOperatorSpec.java x: 11 contributors (all time) y: 45 lines of code samza-core/src/main/java/org/apache/samza/operators/spec/PartitionByOperatorSpec.java x: 8 contributors (all time) y: 40 lines of code samza-core/src/main/java/org/apache/samza/operators/spec/SinkOperatorSpec.java x: 10 contributors (all time) y: 22 lines of code samza-core/src/main/java/org/apache/samza/operators/spec/WindowOperatorSpec.java x: 12 contributors (all time) y: 92 lines of code samza-core/src/main/scala/org/apache/samza/system/chooser/BootstrappingChooser.scala x: 14 contributors (all time) y: 143 lines of code samza-core/src/main/java/org/apache/samza/executors/KeyBasedExecutorService.java x: 2 contributors (all time) y: 106 lines of code samza-azure/src/main/java/org/apache/samza/util/TableUtils.java x: 4 contributors (all time) y: 131 lines of code samza-core/src/main/java/org/apache/samza/operators/spec/StreamOperatorSpec.java x: 7 contributors (all time) y: 12 lines of code samza-core/src/main/scala/org/apache/samza/util/ExponentialSleepStrategy.scala x: 5 contributors (all time) y: 80 lines of code samza-hdfs/src/main/scala/org/apache/samza/system/hdfs/HdfsConfig.scala x: 7 contributors (all time) y: 83 lines of code samza-hdfs/src/main/scala/org/apache/samza/system/hdfs/HdfsSystemProducer.scala x: 5 contributors (all time) y: 73 lines of code samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaSystemProducer.scala x: 19 contributors (all time) y: 148 lines of code samza-yarn/src/main/scala/org/apache/samza/job/yarn/SamzaContainerSecurityManager.scala x: 3 contributors (all time) y: 71 lines of code samza-rest/src/main/java/org/apache/samza/rest/proxy/job/ScriptJobProxy.java x: 3 contributors (all time) y: 28 lines of code samza-core/src/main/java/org/apache/samza/container/disk/WatermarkDiskQuotaPolicy.java x: 2 contributors (all time) y: 126 lines of code samza-hdfs/src/main/java/org/apache/samza/system/hdfs/reader/AvroFileHdfsReader.java x: 1 contributors (all time) y: 143 lines of code samza-yarn/src/main/less/main.less x: 2 contributors (all time) y: 118 lines of code samza-test/src/main/python/samza_failure_testing.py x: 2 contributors (all time) y: 120 lines of code samza-api/src/main/java/org/apache/samza/system/SystemStreamMetadata.java x: 2 contributors (all time) y: 130 lines of code
892.0
lines of code
  min: 3.0
  average: 63.15
  25th percentile: 13.0
  median: 35.0
  75th percentile: 74.0
  max: 892.0
0 75.0
contributors (all time)
min: 1.0 | average: 5.2 | 25th percentile: 2.0 | median: 4.0 | 75th percentile: 6.0 | max: 75.0

File Size vs. Commits (30 days): 0 points

No data for "commits (30d)" vs. "lines of code".

File Size vs. Contributors (30 days): 0 points

No data for "contributors (30d)" vs. "lines of code".

File Size vs. Commits (90 days): 0 points

No data for "commits (90d)" vs. "lines of code".

File Size vs. Contributors (90 days): 0 points

No data for "contributors (90d)" vs. "lines of code".