apache / samza
File Change Frequency

File change frequency (churn) shows the distribution of file updates (days with at least one commit).

Overview
File Change Frequency Overall
  • There are 1,232 files with 77,803 lines of code.
    • 2 files changed more than 100 times (1,398 lines of code)
    • 16 files changed 51-100 times (4,898 lines of code)
    • 98 files changed 21-50 times (15,386 lines of code)
    • 389 files changed 6-20 times (30,835 lines of code)
    • 727 files changed 1-5 times (25,286 lines of code)
1% | 6% | 19% | 39% | 32%
Legend:
101+
51-100
21-50
6-20
1-5

explore: grouped by folders | grouped by update frequency | data
Contributors Count Frequency Overall
  • There are 1,232 files with 77,803 lines of code.
    • 15 files changed by more than 25 contributors (4,552 lines of code)
    • 123 files changed by 11-25 contributors (21,350 lines of code)
    • 245 files changed by 6-10 contributors (18,071 lines of code)
    • 607 files changed by 2-5 contributors (24,844 lines of code)
    • 242 files changed by 1 contributor (8,986 lines of code)
5% | 27% | 23% | 31% | 11%
Legend:
26+
11-25
6-10
2-5
1

explore: grouped by folders | grouped by contributors count | data
File Change Frequency per File Extension
java, md, scala, sh, xml, properties, html, svg, py, css, avsc, gradle, js, txt, less, json, scaml, yaml, xsl, bat, gitignore, rdf
File Change Frequency per Extension
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
scala14% | 17% | 19% | 22% | 26%
java0% | 4% | 20% | 42% | 32%
py0% | 0% | 0% | 56% | 43%
scaml0% | 0% | 0% | 42% | 57%
less0% | 0% | 0% | 0% | 100%
xml0% | 0% | 0% | 0% | 100%
xsl0% | 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 Change Frequency per Logical Decomposition
primary
primary (file change frequency)
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
samza-core3% | 9% | 18% | 38% | 29%
samza-kafka0% | 20% | 44% | 32% | 1%
samza-kv-rocksdb0% | 35% | 51% | 0% | 12%
samza-sql0% | 4% | 44% | 39% | 11%
samza-yarn0% | 0% | 46% | 19% | 34%
samza-api0% | 0% | 11% | 39% | 49%
samza-azure0% | 0% | 11% | 58% | 30%
samza-kv0% | 0% | 37% | 56% | 5%
samza-sql-shell0% | 0% | 16% | 71% | 12%
samza-log4j20% | 0% | 56% | 8% | 34%
samza-log4j0% | 0% | 44% | 6% | 49%
samza-rest0% | 0% | 5% | 46% | 47%
samza-tools0% | 0% | 6% | 45% | 48%
samza-test0% | 0% | 0% | 66% | 33%
samza-hdfs0% | 0% | 0% | 61% | 38%
samza-aws0% | 0% | 0% | 58% | 41%
samza-elasticsearch0% | 0% | 0% | 76% | 23%
samza-kv-couchbase0% | 0% | 0% | 47% | 52%
samza-kv-inmemory0% | 0% | 0% | 15% | 84%
samza-yarn30% | 0% | 0% | 0% | 100%
samza-shell0% | 0% | 0% | 0% | 100%
gradle0% | 0% | 0% | 0% | 100%
ROOT0% | 0% | 0% | 0% | 100%
Most Frequently Changed Files (Top 50)

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
SamzaContainer.scala
in samza-core/src/main/scala/org/apache/samza/container
 892 11 2013-08-20 2023-08-29 216 75 criccomini.aux@gmail.com bharathkk@apache.org
TaskInstance.scala
in samza-core/src/main/scala/org/apache/samza/container
 506 15 2013-08-28 2024-11-25 102 50 criccomi@criccomi-mn.linked... yehaolan@gmail.com
ZkJobCoordinator.java
in samza-core/src/main/java/org/apache/samza/zk
 553 39 2017-03-09 2023-01-30 84 27 bshkolni@bshkolni-ld1.linke... katiliu@linkedin.com
JobModelManager.scala
in samza-core/src/main/scala/org/apache/samza/coordinator
 63 3 2017-01-31 2021-09-29 67 28 navina@apache.org calee@linkedin.com
KafkaConfig.scala
in samza-kafka/src/main/scala/org/apache/samza/config
 247 15 2013-08-28 2022-10-10 66 36 criccomi@criccomi-mn.linked... james.demichele@redfin.com
ContainerStorageManager.java
in samza-core/src/main/scala/org/apache/samza/storage
 304 9 2018-12-01 2024-12-19 65 22 rmatharu@linkedin.com ajo.thomas24@gmail.com
LocalApplicationRunner.java
in samza-core/src/main/java/org/apache/samza/runtime
 389 31 2017-03-07 2022-08-22 63 27 xiliu@xiliu-ld.linkedin.biz ajthomas@linkedin.com
KafkaCheckpointManager.scala
in samza-kafka/src/main/scala/org/apache/samza/checkpoint/kafka
 291 13 2013-10-23 2022-08-04 62 30 criccomi@criccomi-mn.linked... mgaduputi@linkedin.com
StreamProcessor.java
in samza-core/src/main/java/org/apache/samza/processor
 372 20 2017-01-31 2022-07-29 61 23 navina@apache.org ajthomas@linkedin.com
QueryTranslator.java
in samza-sql/src/main/java/org/apache/samza/sql/translator
 229 7 2017-11-16 2020-08-04 58 16 spunuru@linkedin.com 54013208+mabelyc@users.nore...
SystemConsumers.scala
in samza-core/src/main/scala/org/apache/samza/system
 282 10 2013-08-20 2022-12-15 58 32 criccomini.aux@gmail.com 72765053+shekhars-li@users....
ThreadJobFactory.scala
in samza-core/src/main/scala/org/apache/samza/job/local
 116 2 2014-07-31 2022-07-29 56 28 chinmay.cerebro@gmail.com ajthomas@linkedin.com
StorageRecovery.java
in samza-core/src/main/java/org/apache/samza/storage
 175 6 2015-07-16 2023-06-13 54 29 yanfang724@gmail.com bharathkk@apache.org
OperatorImpl.java
in samza-core/src/main/java/org/apache/samza/operators/impl
 412 28 2017-02-16 2023-11-21 54 20 nickpan47@gmail.com bharathkk@apache.org
RocksDbKeyValueStore.scala
in samza-kv-rocksdb/src/main/scala/org/apache/samza/storage/kv
 296 22 2014-10-16 2022-05-25 52 29 naveen.at.ceg@gmail.com xrchen@uwaterloo.ca
OffsetManager.scala
in samza-core/src/main/scala/org/apache/samza/checkpoint
 406 14 2014-03-13 2022-08-04 52 30 criccomi@criccomi-ld.linked... mgaduputi@linkedin.com
ContainerProcessManager.java
in samza-core/src/main/java/org/apache/samza/clustermanager
 455 23 2016-06-02 2024-08-08 52 24 jagadish1989@gmail.com mikebarskiy@gmail.com
ClusterBasedJobCoordinator.java
in samza-core/src/main/java/org/apache/samza/clustermanager
 308 17 2016-06-02 2022-06-13 51 25 jagadish1989@gmail.com ajthomas@linkedin.com
LocalContainerRunner.java
in samza-core/src/main/java/org/apache/samza/runtime
 49 1 2017-03-24 2021-12-07 50 23 xiliu@xiliu-ld.linkedin.biz calee@linkedin.com
SamzaSqlApplicationConfig.java
in samza-sql/src/main/java/org/apache/samza/sql/runner
 247 22 2017-11-16 2021-02-11 48 15 spunuru@linkedin.com stuart.m.perks@gmail.com
ExecutionPlanner.java
in samza-core/src/main/java/org/apache/samza/execution
 183 10 2017-03-16 2019-09-26 47 16 xiliu@xiliu-ld.linkedin.biz bshkolnik@linkedin.com
ScanTranslator.java
in samza-sql/src/main/java/org/apache/samza/sql/translator
 158 9 2017-11-16 2021-03-11 46 16 spunuru@linkedin.com atoomula@linkedin.com
KafkaSystemFactory.scala
in samza-kafka/src/main/scala/org/apache/samza/system/kafka
 73 5 2013-08-28 2022-07-21 45 30 criccomi@criccomi-mn.linked... ke.wu.cs@icloud.com
OperatorImplGraph.java
in samza-core/src/main/java/org/apache/samza/operators/impl
 276 14 2017-04-05 2024-08-16 45 20 pmaheshw@linkedin.com xinyuliu.us@gmail.com
AvroRelConverter.java
in samza-sql/src/main/java/org/apache/samza/sql/avro
 249 13 2017-11-16 2021-11-23 44 13 spunuru@linkedin.com hengyuj34@gmail.com
MessageStreamImpl.java
in samza-core/src/main/java/org/apache/samza/operators
 166 12 2017-02-16 2022-01-20 43 14 nickpan47@gmail.com ajothomas@users.noreply.git...
YarnClusterResourceManager.java
in samza-yarn/src/main/java/org/apache/samza/job/yarn
 509 30 2016-06-02 2023-07-18 43 24 jagadish1989@gmail.com 94939653+jia-gao@users.nore...
RemoteApplicationRunner.java
in samza-core/src/main/java/org/apache/samza/runtime
 122 9 2017-03-07 2022-04-29 42 18 xiliu@xiliu-ld.linkedin.biz xrchen@uwaterloo.ca
JobNode.java
in samza-core/src/main/java/org/apache/samza/execution
 125 20 2017-04-04 2020-08-04 41 16 xiliu@xiliu-ld.linkedin.biz 54013208+mabelyc@users.nore...
JoinTranslator.java
in samza-sql/src/main/java/org/apache/samza/sql/translator
 299 11 2018-03-22 2021-03-11 41 13 atoomula@linkedin.com atoomula@linkedin.com
StreamOperatorTask.java
in samza-core/src/main/java/org/apache/samza/task
 130 10 2017-02-16 2023-06-13 40 19 nickpan47@gmail.com bharathkk@apache.org
KafkaSystemAdmin.java
in samza-kafka/src/main/java/org/apache/samza/system/kafka
 670 39 2018-10-11 2020-09-22 40 18 jvenkatraman@linkedin.com boryas@apache.org
MessageStream.java
in samza-api/src/main/java/org/apache/samza/operators
 48 1 2016-11-22 2022-01-20 39 14 nickpan47@gmail.com ajothomas@users.noreply.git...
KeyValueStorageEngine.scala
in samza-kv/src/main/scala/org/apache/samza/storage/kv
 192 16 2013-09-20 2021-10-01 39 28 criccomi@criccomi-mn.linked... dchen@apache.org
JobRunner.scala
in samza-core/src/main/scala/org/apache/samza/job
 71 7 2014-03-20 2020-02-04 38 27 mkleppmann@linkedin.com ke.wu.cs@icloud.com
OperatorSpecs.java
in samza-core/src/main/java/org/apache/samza/operators/spec
 77 16 2017-02-16 2022-01-20 38 14 nickpan47@gmail.com ajothomas@users.noreply.git...
ContainerLaunchUtil.java
in samza-core/src/main/java/org/apache/samza/runtime
 195 8 2019-01-16 2023-09-11 38 18 xiliu@linkedin.com guanjun0215@gmail.com
ProcessJobFactory.scala
in samza-core/src/main/scala/org/apache/samza/job/local
 69 1 2014-07-31 2022-04-29 37 24 chinmay.cerebro@gmail.com xrchen@uwaterloo.ca
JobConfig.java
in samza-core/src/main/java/org/apache/samza/config
 345 57 2019-07-31 2023-11-21 37 17 calee@linkedin.com bharathkk@apache.org
CheckpointTool.scala
in samza-core/src/main/scala/org/apache/samza/checkpoint
 160 7 2014-03-20 2021-08-10 36 24 mkleppmann@linkedin.com prateekm@utexas.edu
ZkUtils.java
in samza-core/src/main/java/org/apache/samza/zk
 484 51 2017-02-13 2023-01-30 36 15 navina@apache.org katiliu@linkedin.com
RemoteTableProvider.java
in samza-core/src/main/java/org/apache/samza/table/remote
 119 5 2018-03-09 2022-01-20 34 9 pdu@linkedin.com ajothomas@users.noreply.git...
ProjectTranslator.java
in samza-sql/src/main/java/org/apache/samza/sql/translator
 143 6 2017-11-16 2021-03-11 34 15 spunuru@linkedin.com atoomula@linkedin.com
JobGraphJsonGenerator.java
in samza-core/src/main/java/org/apache/samza/execution
 202 8 2017-04-06 2021-02-11 34 14 xiliu@xiliu-ld.linkedin.biz stuart.m.perks@gmail.com
SamzaContainerMetrics.scala
in samza-core/src/main/scala/org/apache/samza/container
 38 1 2013-09-20 2023-07-28 33 21 criccomi@criccomi-mn.linked... boryas@apache.org
LocalityManager.java
in samza-core/src/main/java/org/apache/samza/container
 52 4 2015-06-02 2020-08-27 33 19 navi.trinity@gmail.com bharath.kumarasubramanian@g...
TableManager.java
in samza-core/src/main/java/org/apache/samza/table
 60 6 2017-12-05 2022-01-20 33 10 wsong@linkedin.com ajothomas@users.noreply.git...
QueryPlanner.java
in samza-sql/src/main/java/org/apache/samza/sql/planner
 189 8 2017-11-16 2021-03-11 33 11 spunuru@linkedin.com atoomula@linkedin.com
StreamAppender.java
in samza-log4j/src/main/java/org/apache/samza/logging/log4j
 252 19 2014-11-26 2021-09-29 33 18 yanfang724@gmail.com calee@linkedin.com
JobGraph.java
in samza-core/src/main/java/org/apache/samza/execution
 265 27 2017-04-04 2020-08-04 33 12 xiliu@xiliu-ld.linkedin.biz 54013208+mabelyc@users.nore...
Files With Most Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
SamzaContainer.scala
in samza-core/src/main/scala/org/apache/samza/container
 892 11 2013-08-20 2023-08-29 216 75 criccomini.aux@gmail.com bharathkk@apache.org
TaskInstance.scala
in samza-core/src/main/scala/org/apache/samza/container
 506 15 2013-08-28 2024-11-25 102 50 criccomi@criccomi-mn.linked... yehaolan@gmail.com
KafkaConfig.scala
in samza-kafka/src/main/scala/org/apache/samza/config
 247 15 2013-08-28 2022-10-10 66 36 criccomi@criccomi-mn.linked... james.demichele@redfin.com
SystemConsumers.scala
in samza-core/src/main/scala/org/apache/samza/system
 282 10 2013-08-20 2022-12-15 58 32 criccomini.aux@gmail.com 72765053+shekhars-li@users....
KafkaCheckpointManager.scala
in samza-kafka/src/main/scala/org/apache/samza/checkpoint/kafka
 291 13 2013-10-23 2022-08-04 62 30 criccomi@criccomi-mn.linked... mgaduputi@linkedin.com
OffsetManager.scala
in samza-core/src/main/scala/org/apache/samza/checkpoint
 406 14 2014-03-13 2022-08-04 52 30 criccomi@criccomi-ld.linked... mgaduputi@linkedin.com
KafkaSystemFactory.scala
in samza-kafka/src/main/scala/org/apache/samza/system/kafka
 73 5 2013-08-28 2022-07-21 45 30 criccomi@criccomi-mn.linked... ke.wu.cs@icloud.com
StorageRecovery.java
in samza-core/src/main/java/org/apache/samza/storage
 175 6 2015-07-16 2023-06-13 54 29 yanfang724@gmail.com bharathkk@apache.org
RocksDbKeyValueStore.scala
in samza-kv-rocksdb/src/main/scala/org/apache/samza/storage/kv
 296 22 2014-10-16 2022-05-25 52 29 naveen.at.ceg@gmail.com xrchen@uwaterloo.ca
JobModelManager.scala
in samza-core/src/main/scala/org/apache/samza/coordinator
 63 3 2017-01-31 2021-09-29 67 28 navina@apache.org calee@linkedin.com
ThreadJobFactory.scala
in samza-core/src/main/scala/org/apache/samza/job/local
 116 2 2014-07-31 2022-07-29 56 28 chinmay.cerebro@gmail.com ajthomas@linkedin.com
KeyValueStorageEngine.scala
in samza-kv/src/main/scala/org/apache/samza/storage/kv
 192 16 2013-09-20 2021-10-01 39 28 criccomi@criccomi-mn.linked... dchen@apache.org
ZkJobCoordinator.java
in samza-core/src/main/java/org/apache/samza/zk
 553 39 2017-03-09 2023-01-30 84 27 bshkolni@bshkolni-ld1.linke... katiliu@linkedin.com
LocalApplicationRunner.java
in samza-core/src/main/java/org/apache/samza/runtime
 389 31 2017-03-07 2022-08-22 63 27 xiliu@xiliu-ld.linkedin.biz ajthomas@linkedin.com
JobRunner.scala
in samza-core/src/main/scala/org/apache/samza/job
 71 7 2014-03-20 2020-02-04 38 27 mkleppmann@linkedin.com ke.wu.cs@icloud.com
ClusterBasedJobCoordinator.java
in samza-core/src/main/java/org/apache/samza/clustermanager
 308 17 2016-06-02 2022-06-13 51 25 jagadish1989@gmail.com ajthomas@linkedin.com
YarnJob.scala
in samza-yarn/src/main/scala/org/apache/samza/job/yarn
 137 3 2013-10-22 2022-04-20 32 25 criccomi@criccomi-mn.linked... xinyuliu.us@gmail.com
ContainerProcessManager.java
in samza-core/src/main/java/org/apache/samza/clustermanager
 455 23 2016-06-02 2024-08-08 52 24 jagadish1989@gmail.com mikebarskiy@gmail.com
YarnClusterResourceManager.java
in samza-yarn/src/main/java/org/apache/samza/job/yarn
 509 30 2016-06-02 2023-07-18 43 24 jagadish1989@gmail.com 94939653+jia-gao@users.nore...
ProcessJobFactory.scala
in samza-core/src/main/scala/org/apache/samza/job/local
 69 1 2014-07-31 2022-04-29 37 24 chinmay.cerebro@gmail.com xrchen@uwaterloo.ca
CheckpointTool.scala
in samza-core/src/main/scala/org/apache/samza/checkpoint
 160 7 2014-03-20 2021-08-10 36 24 mkleppmann@linkedin.com prateekm@utexas.edu
RunLoopFactory.java
in samza-core/src/main/java/org/apache/samza/container
 27 1 2016-07-19 2023-08-29 29 24 xiliu@linkedin.com bharathkk@apache.org
StreamProcessor.java
in samza-core/src/main/java/org/apache/samza/processor
 372 20 2017-01-31 2022-07-29 61 23 navina@apache.org ajthomas@linkedin.com
LocalContainerRunner.java
in samza-core/src/main/java/org/apache/samza/runtime
 49 1 2017-03-24 2021-12-07 50 23 xiliu@xiliu-ld.linkedin.biz calee@linkedin.com
ContainerStorageManager.java
in samza-core/src/main/scala/org/apache/samza/storage
 304 9 2018-12-01 2024-12-19 65 22 rmatharu@linkedin.com ajo.thomas24@gmail.com
CachedStore.scala
in samza-kv/src/main/scala/org/apache/samza/storage/kv
 200 16 2013-08-27 2020-08-04 30 22 criccomi@criccomi-mn.linked... 54013208+mabelyc@users.nore...
ClientHelper.scala
in samza-yarn/src/main/scala/org/apache/samza/job/yarn
 330 18 2013-10-22 2022-10-10 26 22 criccomi@criccomi-mn.linked... james.demichele@redfin.com
SamzaContainerMetrics.scala
in samza-core/src/main/scala/org/apache/samza/container
 38 1 2013-09-20 2023-07-28 33 21 criccomi@criccomi-mn.linked... boryas@apache.org
OperatorImpl.java
in samza-core/src/main/java/org/apache/samza/operators/impl
 412 28 2017-02-16 2023-11-21 54 20 nickpan47@gmail.com bharathkk@apache.org
OperatorImplGraph.java
in samza-core/src/main/java/org/apache/samza/operators/impl
 276 14 2017-04-05 2024-08-16 45 20 pmaheshw@linkedin.com xinyuliu.us@gmail.com
SerializedKeyValueStore.scala
in samza-kv/src/main/scala/org/apache/samza/storage/kv
 159 15 2013-09-20 2020-08-04 29 20 criccomi@criccomi-mn.linked... 54013208+mabelyc@users.nore...
KafkaCheckpointManagerFactory.scala
in samza-kafka/src/main/scala/org/apache/samza/checkpoint/kafka
 32 1 2013-12-13 2019-12-02 28 20 jghoman@gmail.com calee@linkedin.com
SamzaObjectMapper.java
in samza-core/src/main/java/org/apache/samza/serializers/model
 237 18 2014-10-28 2022-08-04 27 20 criccomi@criccomi-mn.linked... mgaduputi@linkedin.com
StreamOperatorTask.java
in samza-core/src/main/java/org/apache/samza/task
 130 10 2017-02-16 2023-06-13 40 19 nickpan47@gmail.com bharathkk@apache.org
LocalityManager.java
in samza-core/src/main/java/org/apache/samza/container
 52 4 2015-06-02 2020-08-27 33 19 navi.trinity@gmail.com bharath.kumarasubramanian@g...
SystemAdmin.java
in samza-api/src/main/java/org/apache/samza/system
 53 9 2013-10-04 2020-09-22 29 19 criccomi@criccomi-mn.linked... boryas@apache.org
StorageConfig.java
in samza-core/src/main/java/org/apache/samza/config
 238 33 2019-05-08 2024-08-26 27 19 37879374+cameronlee314@user... yehaolan@gmail.com
KafkaSystemProducer.scala
in samza-kafka/src/main/scala/org/apache/samza/system/kafka
 148 6 2013-08-28 2018-06-08 27 19 criccomi@criccomi-mn.linked... boryas@apache.org
RocksDbKeyValueStorageEngineFactory.scala
in samza-kv-rocksdb/src/main/scala/org/apache/samza/storage/kv
 46 1 2014-10-16 2024-08-26 23 19 naveen.at.ceg@gmail.com yehaolan@gmail.com
RemoteApplicationRunner.java
in samza-core/src/main/java/org/apache/samza/runtime
 122 9 2017-03-07 2022-04-29 42 18 xiliu@xiliu-ld.linkedin.biz xrchen@uwaterloo.ca
KafkaSystemAdmin.java
in samza-kafka/src/main/java/org/apache/samza/system/kafka
 670 39 2018-10-11 2020-09-22 40 18 jvenkatraman@linkedin.com boryas@apache.org
ContainerLaunchUtil.java
in samza-core/src/main/java/org/apache/samza/runtime
 195 8 2019-01-16 2023-09-11 38 18 xiliu@linkedin.com guanjun0215@gmail.com
StreamAppender.java
in samza-log4j/src/main/java/org/apache/samza/logging/log4j
 252 19 2014-11-26 2021-09-29 33 18 yanfang724@gmail.com calee@linkedin.com
CoordinatorStreamUtil.scala
in samza-core/src/main/scala/org/apache/samza/util
 141 11 2018-04-18 2022-08-22 29 18 pmaheshw@linkedin.com ajthomas@linkedin.com
SamzaAppMasterMetrics.scala
in samza-yarn/src/main/scala/org/apache/samza/job/yarn
 41 5 2013-09-20 2023-07-18 23 18 criccomi@criccomi-mn.linked... 94939653+jia-gao@users.nore...
JobConfig.java
in samza-core/src/main/java/org/apache/samza/config
 345 57 2019-07-31 2023-11-21 37 17 calee@linkedin.com bharathkk@apache.org
IncomingMessageEnvelope.java
in samza-api/src/main/java/org/apache/samza/system
 129 20 2015-11-24 2022-12-15 26 17 mdconference@gmail.com 72765053+shekhars-li@users....
RocksDbOptionsHelper.java
in samza-kv-rocksdb/src/main/java/org/apache/samza/storage/kv
 175 3 2015-10-26 2024-08-26 26 17 yanfang724@gmail.com yehaolan@gmail.com
ApplicationMasterRestServlet.scala
in samza-yarn/src/main/scala/org/apache/samza/webapp
 84 4 2014-05-02 2021-02-11 21 17 zshen@hortonworks.com stuart.m.perks@gmail.com
QueryTranslator.java
in samza-sql/src/main/java/org/apache/samza/sql/translator
 229 7 2017-11-16 2020-08-04 58 16 spunuru@linkedin.com 54013208+mabelyc@users.nore...
Files With Least Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
HttpInputStream.scala
in samza-yarn/src/main/scala/org/apache/samza/util/hadoop
 20 -
SamzaException.java
in samza-api/src/main/java/org/apache/samza
 16 4
Metric.java
in samza-api/src/main/java/org/apache/samza/metrics
 4 -
YarnClusterResourceManager.java
in samza-yarn3/src/main/java/org/apache/samza/job/yarn
 507 30 2022-10-10 2022-10-10 1 1 james.demichele@redfin.com james.demichele@redfin.com
ClientHelper.scala
in samza-yarn3/src/main/scala/org/apache/samza/job/yarn
 330 18 2022-10-10 2022-10-10 1 1 james.demichele@redfin.com james.demichele@redfin.com
ContainerStorageManagerRestoreUtil.java
in samza-core/src/main/scala/org/apache/samza/storage
 284 9 2023-08-10 2023-08-18 2 1 72765053+shekhars-li@users.... 72765053+shekhars-li@users....
JobCoordinatorMetadataManager.java
in samza-core/src/main/java/org/apache/samza/job/metadata
 243 24 2021-08-24 2021-08-24 1 1 calee@linkedin.com calee@linkedin.com
scaml
index.scaml
in samza-yarn3/src/main/resources/scalate/WEB-INF/views
 224 - 2022-10-10 2022-10-10 1 1 james.demichele@redfin.com james.demichele@redfin.com
StaticResourceJobCoordinator.java
in samza-core/src/main/java/org/apache/samza/coordinator/staticresource
 199 14 2021-09-28 2021-12-07 5 1 calee@linkedin.com calee@linkedin.com
MetricsSnapshotReporter.java
in samza-core/src/main/java/org/apache/samza/metrics/reporter
 179 7 2021-11-30 2021-12-07 2 1 calee@linkedin.com calee@linkedin.com
JobModelCalculator.java
in samza-core/src/main/java/org/apache/samza/coordinator
 160 6 2021-08-23 2021-08-23 1 1 calee@linkedin.com calee@linkedin.com
DrainMonitor.java
in samza-core/src/main/java/org/apache/samza/drain
 158 7 2022-06-13 2022-07-29 2 1 ajthomas@linkedin.com ajthomas@linkedin.com
xsl
rat-output-to-html.xsl
in gradle/resources
 153 - 2014-07-09 2014-07-09 1 1 dchen@linkedin.com dchen@linkedin.com
YarnJobValidationTool.java
in samza-yarn3/src/main/java/org/apache/samza/validation
 152 7 2022-10-10 2022-10-10 1 1 james.demichele@redfin.com james.demichele@redfin.com
JobModelHelper.java
in samza-core/src/main/java/org/apache/samza/coordinator
 151 6 2021-08-23 2021-08-23 1 1 calee@linkedin.com calee@linkedin.com
AvroFileHdfsReader.java
in samza-hdfs/src/main/java/org/apache/samza/system/hdfs/reader
 143 17 2016-10-05 2016-10-05 1 1 lhaiesp@gmail.com lhaiesp@gmail.com
MetricsHeader.java
in samza-core/src/main/java/org/apache/samza/metrics/reporter
 138 18 2021-11-30 2021-12-07 2 1 calee@linkedin.com calee@linkedin.com
YarnJob.scala
in samza-yarn3/src/main/scala/org/apache/samza/job/yarn
 137 3 2022-10-10 2022-10-10 1 1 james.demichele@redfin.com james.demichele@redfin.com
main.less
in samza-yarn3/src/main/less
 118 - 2022-10-10 2022-10-10 1 1 james.demichele@redfin.com james.demichele@redfin.com
YarnConfig.java
in samza-yarn3/src/main/java/org/apache/samza/config
 113 22 2022-10-10 2022-10-10 1 1 james.demichele@redfin.com james.demichele@redfin.com
MetricsSnapshotReporterFactory.java
in samza-core/src/main/java/org/apache/samza/metrics/reporter
 110 8 2021-11-30 2021-11-30 1 1 calee@linkedin.com calee@linkedin.com
OutgoingMessageEnvelope.java
in samza-api/src/main/java/org/apache/samza/system
 101 13 2014-06-19 2014-06-19 1 1 jghoman@apache.org jghoman@apache.org
ClusterBasedProcessorLifecycleListener.java
in samza-core/src/main/java/org/apache/samza/runtime
 101 10 2019-09-17 2019-09-17 1 1 ashivanna@linkedin.com ashivanna@linkedin.com
StaticResourceJobCoordinatorFactory.java
in samza-core/src/main/java/org/apache/samza/coordinator/staticresource
 87 2 2021-09-28 2021-12-07 3 1 calee@linkedin.com calee@linkedin.com
SendToTableWithUpdateOperatorImpl.java
in samza-core/src/main/java/org/apache/samza/operators/impl
 85 3 2022-01-20 2022-01-20 1 1 ajothomas@users.noreply.git... ajothomas@users.noreply.git...
ApplicationMasterRestServlet.scala
in samza-yarn3/src/main/scala/org/apache/samza/webapp
 84 4 2022-10-10 2022-10-10 1 1 james.demichele@redfin.com james.demichele@redfin.com
YarnFaultDomainManager.java
in samza-yarn/src/main/java/org/apache/samza/job/yarn
 79 5 2020-12-22 2020-12-22 1 1 pchhokra@linkedin.com pchhokra@linkedin.com
YarnFaultDomainManager.java
in samza-yarn3/src/main/java/org/apache/samza/job/yarn
 79 5 2022-10-10 2022-10-10 1 1 james.demichele@redfin.com james.demichele@redfin.com
plan.html
in samza-shell/src/main/visualizer
 79 - 2017-05-02 2017-05-11 2 1 xiliu@xiliu-ld.linkedin.biz xiliu@xiliu-ld.linkedin.biz
SamzaYarnAppMasterLifecycle.scala
in samza-yarn3/src/main/scala/org/apache/samza/job/yarn
 78 4 2022-10-10 2022-10-10 1 1 james.demichele@redfin.com james.demichele@redfin.com
ContainerPlacementMessage.java
in samza-api/src/main/java/org/apache/samza/container/placement
 76 11 2020-01-21 2020-01-21 1 1 sanil.jain15@gmail.com sanil.jain15@gmail.com
ReadWriteTableDelegate.java
in samza-core/src/main/java/org/apache/samza/table
 76 16 2022-01-21 2022-01-21 1 1 ajothomas@users.noreply.git... ajothomas@users.noreply.git...
AzureBlobSystemProducerMetrics.java
in samza-azure/src/main/java/org/apache/samza/system/azureblob/producer
 74 10 2020-01-16 2020-01-16 1 1 mgaduputi@linkedin.com mgaduputi@linkedin.com
SamzaAppMasterSecurityManager.scala
in samza-yarn3/src/main/scala/org/apache/samza/job/yarn
 74 5 2022-10-10 2022-10-10 1 1 james.demichele@redfin.com james.demichele@redfin.com
SamzaContainerSecurityManager.scala
in samza-yarn3/src/main/scala/org/apache/samza/job/yarn
 71 3 2022-10-10 2022-10-10 1 1 james.demichele@redfin.com james.demichele@redfin.com
BoundedList.java
in samza-core/src/main/scala/org/apache/samza/diagnostics
 67 9 2019-05-23 2019-05-23 1 1 rmatharu@linkedin.com rmatharu@linkedin.com
HttpFileSystem.scala
in samza-yarn3/src/main/scala/org/apache/samza/util/hadoop
 66 4 2022-10-10 2022-10-10 1 1 james.demichele@redfin.com james.demichele@redfin.com
SerializerConfig.java
in samza-core/src/main/java/org/apache/samza/config
 65 5 2019-06-10 2019-06-10 1 1 calee@linkedin.com calee@linkedin.com
LocalizerResourceMapper.java
in samza-yarn/src/main/java/org/apache/samza/job/yarn
 64 4 2017-03-27 2017-03-27 1 1 fji@linkedin.com fji@linkedin.com
LocalizerResourceMapper.java
in samza-yarn3/src/main/java/org/apache/samza/job/yarn
 64 4 2022-10-10 2022-10-10 1 1 james.demichele@redfin.com james.demichele@redfin.com
ApplicationMasterRestClient.java
in samza-yarn3/src/main/java/org/apache/samza/webapp
 61 7 2022-10-10 2022-10-10 1 1 james.demichele@redfin.com james.demichele@redfin.com
DrainStates.java
in samza-core/src/main/java/org/apache/samza/operators/impl
 60 7 2022-07-29 2022-07-29 1 1 ajthomas@linkedin.com ajthomas@linkedin.com
YarnJobUtil.scala
in samza-yarn/src/main/scala/org/apache/samza/job/yarn
 60 4 2016-06-09 2016-06-09 1 1 chens_cs@hotmail.com chens_cs@hotmail.com
YarnJobUtil.scala
in samza-yarn3/src/main/scala/org/apache/samza/job/yarn
 60 4 2022-10-10 2022-10-10 1 1 james.demichele@redfin.com james.demichele@redfin.com
JmxMetricsAccessor.java
in samza-core/src/main/java/org/apache/samza/metrics
 59 7 2016-03-29 2016-03-29 1 1 xiliu@linkedin.com xiliu@linkedin.com
ContainerPlacementResponseMessage.java
in samza-api/src/main/java/org/apache/samza/container/placement
 58 7 2020-01-21 2020-02-18 2 1 sanil.jain15@gmail.com sanil.jain15@gmail.com
SamzaYarnAppMasterService.scala
in samza-yarn3/src/main/scala/org/apache/samza/job/yarn
 58 2 2022-10-10 2022-10-10 1 1 james.demichele@redfin.com james.demichele@redfin.com
YarnContainerHeartbeatServlet.java
in samza-yarn3/src/main/java/org/apache/samza/webapp
 58 2 2022-10-10 2022-10-10 1 1 james.demichele@redfin.com james.demichele@redfin.com
LocalizerResourceConfig.java
in samza-yarn3/src/main/java/org/apache/samza/job/yarn
 54 6 2022-10-10 2022-10-10 1 1 james.demichele@redfin.com james.demichele@redfin.com
JmxAppender.java
in samza-log4j/src/main/java/org/apache/samza/logging/log4j
 53 7 2014-08-05 2014-08-08 2 1 criccomi@criccomi-mn.linked... criccomi@criccomi-mn.linked...
Correlations

File Size vs. Number of Changes: 1232 points

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

Number of Contributors vs. Number of Changes: 1232 points

samza-core/src/main/scala/org/apache/samza/storage/ContainerStorageManager.java x: 22 # contributors y: 65 # changes samza-core/src/main/java/org/apache/samza/config/TaskConfig.java x: 13 # contributors y: 22 # changes samza-core/src/main/scala/org/apache/samza/container/TaskInstance.scala x: 50 # contributors y: 102 # changes samza-core/src/main/scala/org/apache/samza/container/TaskInstanceMetrics.scala x: 12 # contributors y: 14 # changes samza-core/src/main/java/org/apache/samza/storage/blobstore/util/BlobStoreUtil.java x: 4 # contributors y: 13 # changes samza-core/src/main/java/org/apache/samza/config/StorageConfig.java x: 19 # contributors y: 27 # changes samza-kv-rocksdb/src/main/java/org/apache/samza/storage/kv/RocksDbKeyValueReader.java x: 13 # contributors y: 21 # changes samza-kv-rocksdb/src/main/java/org/apache/samza/storage/kv/RocksDbOptionsHelper.java x: 17 # contributors y: 26 # changes samza-kv-rocksdb/src/main/scala/org/apache/samza/storage/kv/RocksDbKeyValueStorageEngineFactory.scala x: 19 # contributors y: 23 # changes samza-azure/src/main/java/org/apache/samza/system/azureblob/AzureBlobClientBuilder.java x: 4 # contributors y: 5 # changes samza-azure/src/main/java/org/apache/samza/system/azureblob/AzureBlobClientBuilderFactory.java x: 1 # contributors y: 1 # changes samza-azure/src/main/java/org/apache/samza/system/azureblob/AzureBlobConfig.java x: 6 # contributors y: 9 # changes samza-azure/src/main/java/org/apache/samza/system/azureblob/producer/AzureBlobSystemProducer.java x: 7 # contributors y: 11 # changes samza-core/src/main/java/org/apache/samza/operators/impl/WatermarkMetrics.java x: 6 # contributors y: 5 # changes samza-core/src/main/java/org/apache/samza/operators/impl/WatermarkStates.java x: 7 # contributors y: 10 # changes samza-core/src/main/java/org/apache/samza/operators/impl/OperatorImplGraph.java x: 20 # contributors y: 45 # changes samza-core/src/main/java/org/apache/samza/clustermanager/ContainerProcessManager.java x: 24 # contributors y: 52 # changes samza-core/src/main/scala/org/apache/samza/storage/ContainerStorageManagerUtil.java x: 3 # contributors y: 5 # changes samza-core/src/main/scala/org/apache/samza/storage/SideInputsManager.java x: 4 # contributors y: 6 # changes samza-core/src/main/java/org/apache/samza/storage/blobstore/BlobStoreBackupManager.java x: 6 # contributors y: 13 # changes samza-core/src/main/java/org/apache/samza/storage/blobstore/util/DirDiffUtil.java x: 4 # contributors y: 7 # changes samza-core/src/main/java/org/apache/samza/coordinator/stream/CoordinatorStreamSystemProducer.java x: 10 # contributors y: 11 # changes samza-core/src/main/java/org/apache/samza/coordinator/stream/CoordinatorStreamWriter.java x: 12 # contributors y: 12 # changes samza-core/src/main/java/org/apache/samza/config/JobConfig.java x: 17 # contributors y: 37 # changes samza-core/src/main/java/org/apache/samza/operators/impl/OperatorImpl.java x: 20 # contributors y: 54 # changes samza-core/src/main/java/org/apache/samza/config/ShellCommandConfig.java x: 6 # contributors y: 7 # changes samza-core/src/main/java/org/apache/samza/task/DefaultTaskExecutorFactory.java x: 2 # contributors y: 4 # changes samza-core/src/main/java/org/apache/samza/runtime/ContainerLaunchUtil.java x: 18 # contributors y: 38 # changes samza-core/src/main/java/org/apache/samza/config/ApplicationConfig.java x: 15 # contributors y: 18 # changes samza-core/src/main/java/org/apache/samza/container/RunLoop.java x: 11 # contributors y: 20 # changes samza-core/src/main/java/org/apache/samza/task/TaskCallbackManager.java x: 13 # contributors y: 13 # changes samza-core/src/main/java/org/apache/samza/application/ApplicationUtil.java x: 9 # contributors y: 9 # changes samza-core/src/main/java/org/apache/samza/container/RunLoopFactory.java x: 24 # contributors y: 29 # changes samza-core/src/main/scala/org/apache/samza/container/SamzaContainer.scala x: 75 # contributors y: 216 # changes samza-core/src/main/java/org/apache/samza/config/BlobStoreConfig.java x: 3 # contributors y: 7 # changes samza-core/src/main/java/org/apache/samza/storage/blobstore/BlobStoreRestoreManager.java x: 6 # contributors y: 17 # changes samza-core/src/main/scala/org/apache/samza/storage/ContainerStorageManagerRestoreUtil.java x: 1 # contributors y: 2 # changes samza-api/src/main/java/org/apache/samza/storage/blobstore/BlobStoreManager.java x: 2 # contributors y: 3 # changes samza-core/src/main/java/org/apache/samza/execution/IntermediateStreamManager.java x: 7 # contributors y: 6 # changes samza-core/src/main/scala/org/apache/samza/container/SamzaContainerMetrics.scala x: 21 # contributors y: 33 # changes samza-yarn/src/main/java/org/apache/samza/job/yarn/YarnClusterResourceManager.java x: 24 # contributors y: 43 # changes samza-yarn/src/main/scala/org/apache/samza/job/yarn/SamzaAppMasterMetrics.scala x: 18 # contributors y: 23 # changes samza-azure/src/main/java/org/apache/samza/system/azureblob/avro/AzureBlobAvroWriter.java x: 5 # contributors y: 8 # changes samza-azure/src/main/java/org/apache/samza/system/azureblob/avro/AzureBlobAvroWriterFactory.java x: 3 # contributors y: 4 # changes samza-azure/src/main/java/org/apache/samza/system/eventhub/consumer/EventHubSystemConsumer.java x: 14 # contributors y: 27 # changes samza-api/src/main/java/org/apache/samza/context/TaskContext.java x: 7 # contributors y: 14 # changes samza-api/src/main/java/org/apache/samza/task/TaskExecutorFactory.java x: 2 # contributors y: 2 # changes samza-core/src/main/java/org/apache/samza/context/TaskContextImpl.java x: 9 # contributors y: 17 # changes samza-api/src/main/java/org/apache/samza/context/ContainerContext.java x: 6 # contributors y: 10 # changes samza-core/src/main/java/org/apache/samza/context/ContainerContextImpl.java x: 5 # contributors y: 4 # changes samza-core/src/main/java/org/apache/samza/storage/StorageRecovery.java x: 29 # contributors y: 54 # changes samza-core/src/main/java/org/apache/samza/task/StreamOperatorTask.java x: 19 # contributors y: 40 # changes samza-core/src/main/java/org/apache/samza/task/TaskFactoryUtil.java x: 13 # contributors y: 23 # changes samza-azure/src/main/java/org/apache/samza/system/eventhub/EventHubConfig.java x: 11 # contributors y: 21 # changes samza-core/src/main/java/org/apache/samza/coordinator/metadatastore/CoordinatorStreamStore.java x: 11 # contributors y: 22 # changes samza-core/src/main/java/org/apache/samza/execution/JobPlanner.java x: 13 # contributors y: 26 # changes samza-core/src/main/scala/org/apache/samza/metrics/JmxServer.scala x: 7 # contributors y: 9 # changes samza-core/src/main/scala/org/apache/samza/util/Logging.scala x: 4 # contributors y: 4 # changes samza-core/src/main/java/org/apache/samza/storage/NonTransactionalStateTaskRestoreManager.java x: 10 # contributors y: 18 # changes samza-core/src/main/java/org/apache/samza/storage/SideInputTask.java x: 3 # contributors y: 3 # changes samza-core/src/main/java/org/apache/samza/storage/StorageManagerUtil.java x: 14 # contributors y: 32 # changes samza-log4j2/src/main/java/org/apache/samza/logging/log4j2/StreamAppender.java x: 16 # contributors y: 26 # changes samza-core/src/main/java/org/apache/samza/util/RetryPolicyConfig.java x: 2 # contributors y: 1 # changes samza-core/src/main/java/org/apache/samza/zk/ZkJobCoordinator.java x: 27 # contributors y: 84 # changes samza-core/src/main/java/org/apache/samza/zk/ZkJobCoordinatorFactory.java x: 16 # contributors y: 31 # changes samza-core/src/main/java/org/apache/samza/zk/ZkLeaderElector.java x: 8 # contributors y: 16 # changes samza-core/src/main/java/org/apache/samza/zk/ZkMetadataStore.java x: 5 # contributors y: 6 # changes samza-core/src/main/java/org/apache/samza/zk/ZkUtils.java x: 15 # contributors y: 36 # changes samza-sql-shell/src/main/java/org/apache/samza/sql/client/impl/SamzaExecutor.java x: 14 # contributors y: 26 # changes samza-core/src/main/java/org/apache/samza/container/host/StatisticsMonitorImpl.java x: 5 # contributors y: 5 # changes samza-core/src/main/java/org/apache/samza/drain/DrainUtils.java x: 2 # contributors y: 5 # changes samza-core/src/main/java/org/apache/samza/operators/impl/ControlMessageSender.java x: 8 # contributors y: 9 # changes samza-core/src/main/scala/org/apache/samza/system/SystemConsumers.scala x: 32 # contributors y: 58 # changes samza-core/src/main/java/org/apache/samza/storage/KafkaChangelogStateBackendFactory.java x: 5 # contributors y: 10 # changes samza-hdfs/src/main/java/org/apache/samza/system/hdfs/HdfsSystemAdmin.java x: 9 # contributors y: 12 # changes samza-hdfs/src/main/java/org/apache/samza/system/hdfs/HdfsSystemConsumer.java x: 11 # contributors y: 11 # changes samza-hdfs/src/main/java/org/apache/samza/system/hdfs/partitioner/DirectoryPartitioner.java x: 6 # contributors y: 6 # changes samza-kafka/src/main/scala/org/apache/samza/config/KafkaConfig.scala x: 36 # contributors y: 66 # changes samza-rest/src/main/java/org/apache/samza/rest/resources/TasksResource.java x: 6 # contributors y: 8 # changes samza-yarn/src/main/scala/org/apache/samza/job/yarn/ClientHelper.scala x: 22 # contributors y: 26 # changes samza-core/src/main/scala/org/apache/samza/diagnostics/DiagnosticsManager.java x: 7 # contributors y: 12 # changes samza-core/src/main/java/org/apache/samza/runtime/LocalApplicationRunner.java x: 27 # contributors y: 63 # changes samza-core/src/main/scala/org/apache/samza/util/CoordinatorStreamUtil.scala x: 18 # contributors y: 29 # changes samza-core/src/main/java/org/apache/samza/container/grouper/stream/GroupByPartition.java x: 10 # contributors y: 12 # changes samza-core/src/main/java/org/apache/samza/container/grouper/stream/GroupBySystemStreamPartition.java x: 9 # contributors y: 11 # changes samza-core/src/main/java/org/apache/samza/serializers/model/SamzaObjectMapper.java x: 20 # contributors y: 27 # changes samza-core/src/main/scala/org/apache/samza/checkpoint/OffsetManager.scala x: 30 # contributors y: 52 # changes samza-kafka/src/main/scala/org/apache/samza/checkpoint/kafka/KafkaCheckpointManager.scala x: 30 # contributors y: 62 # changes samza-core/src/main/java/org/apache/samza/processor/StreamProcessor.java x: 23 # contributors y: 61 # changes samza-core/src/main/java/org/apache/samza/serializers/IntermediateMessageSerde.java x: 9 # contributors y: 10 # changes samza-core/src/main/scala/org/apache/samza/job/local/ThreadJobFactory.scala x: 28 # contributors y: 56 # changes samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaSystemFactory.scala x: 30 # contributors y: 45 # changes samza-core/src/main/java/org/apache/samza/startpoint/StartpointManager.java x: 11 # contributors y: 15 # changes samza-core/src/main/java/org/apache/samza/clustermanager/ClusterBasedJobCoordinator.java x: 25 # contributors y: 51 # changes samza-kv-rocksdb/src/main/scala/org/apache/samza/storage/kv/RocksDbKeyValueStore.scala x: 29 # contributors y: 52 # changes samza-core/src/main/java/org/apache/samza/util/DiagnosticsUtil.java x: 10 # contributors y: 24 # changes samza-rest/src/main/java/org/apache/samza/rest/SamzaRestService.java x: 13 # contributors y: 17 # changes samza-core/src/main/java/org/apache/samza/runtime/RemoteApplicationRunner.java x: 18 # contributors y: 42 # changes samza-core/src/main/scala/org/apache/samza/job/local/ProcessJobFactory.scala x: 24 # contributors y: 37 # changes samza-yarn/src/main/scala/org/apache/samza/job/yarn/YarnJob.scala x: 25 # contributors y: 32 # changes samza-core/src/main/java/org/apache/samza/config/JobCoordinatorConfig.java x: 11 # contributors y: 17 # changes samza-core/src/main/scala/org/apache/samza/util/FileUtil.scala x: 10 # contributors y: 13 # changes samza-api/src/main/java/org/apache/samza/system/SystemStreamPartition.java x: 7 # contributors y: 8 # changes samza-api/src/main/java/org/apache/samza/table/remote/TableWriteFunction.java x: 4 # contributors y: 12 # changes samza-api/src/main/java/org/apache/samza/operators/MessageStream.java x: 14 # contributors y: 39 # changes samza-api/src/main/java/org/apache/samza/table/ReadWriteTable.java x: 6 # contributors y: 15 # changes samza-api/src/main/java/org/apache/samza/table/TableProvider.java x: 8 # contributors y: 23 # changes samza-api/src/main/java/org/apache/samza/table/descriptors/RemoteTableDescriptor.java x: 10 # contributors y: 28 # changes samza-api/src/main/java/org/apache/samza/table/descriptors/TableDescriptor.java x: 5 # contributors y: 17 # changes samza-core/src/main/java/org/apache/samza/operators/MessageStreamImpl.java x: 14 # contributors y: 43 # changes samza-core/src/main/java/org/apache/samza/operators/impl/SendToTableOperatorImpl.java x: 8 # contributors y: 19 # changes samza-core/src/main/java/org/apache/samza/operators/impl/StreamTableJoinOperatorImpl.java x: 8 # contributors y: 18 # changes samza-core/src/main/java/org/apache/samza/operators/spec/OperatorSpec.java x: 14 # contributors y: 29 # changes samza-core/src/main/java/org/apache/samza/operators/spec/OperatorSpecs.java x: 14 # contributors y: 38 # changes samza-core/src/main/java/org/apache/samza/operators/spec/SendToTableOperatorSpec.java x: 9 # contributors y: 16 # changes samza-core/src/main/java/org/apache/samza/table/TableManager.java x: 10 # contributors y: 33 # changes samza-core/src/main/java/org/apache/samza/table/caching/CachingTable.java x: 10 # contributors y: 26 # changes samza-core/src/main/java/org/apache/samza/table/caching/CachingTableProvider.java x: 8 # contributors y: 25 # changes samza-core/src/main/java/org/apache/samza/table/caching/guava/GuavaCacheTable.java x: 9 # contributors y: 23 # changes samza-core/src/main/java/org/apache/samza/table/caching/guava/GuavaCacheTableProvider.java x: 8 # contributors y: 22 # changes samza-core/src/main/java/org/apache/samza/table/ratelimit/AsyncRateLimitedTable.java x: 5 # contributors y: 7 # changes samza-core/src/main/java/org/apache/samza/table/remote/RemoteTable.java x: 9 # contributors y: 14 # changes samza-core/src/main/java/org/apache/samza/table/remote/RemoteTableProvider.java x: 9 # contributors y: 34 # changes samza-kv-couchbase/src/main/java/org/apache/samza/table/remote/couchbase/CouchbaseTableWriteFunction.java x: 5 # contributors y: 9 # changes samza-kv/src/main/java/org/apache/samza/storage/kv/LocalTable.java x: 5 # contributors y: 16 # changes samza-kv/src/main/java/org/apache/samza/storage/kv/LocalTableProvider.java x: 4 # contributors y: 14 # changes samza-api/src/main/java/org/apache/samza/storage/TaskRestoreManager.java x: 3 # contributors y: 6 # changes samza-core/src/main/java/org/apache/samza/coordinator/staticresource/StaticResourceJobCoordinator.java x: 1 # contributors y: 5 # changes samza-core/src/main/java/org/apache/samza/coordinator/staticresource/StaticResourceJobCoordinatorFactory.java x: 1 # contributors y: 3 # changes samza-core/src/main/java/org/apache/samza/runtime/LocalContainerRunner.java x: 23 # contributors y: 50 # changes samza-sql/src/main/java/org/apache/samza/sql/avro/AvroRelConverter.java x: 13 # contributors y: 44 # changes samza-core/src/main/java/org/apache/samza/clustermanager/JobCoordinatorLaunchUtil.java x: 4 # contributors y: 8 # changes samza-test/src/main/python/stream_processor.py x: 10 # contributors y: 9 # changes samza-api/src/main/java/org/apache/samza/job/model/TaskMode.java x: 4 # contributors y: 3 # changes samza-api/src/main/java/org/apache/samza/util/BlockingEnvelopeMap.java x: 16 # contributors y: 21 # changes samza-api/src/main/java/org/apache/samza/storage/kv/KeyValueStore.java x: 10 # contributors y: 16 # changes samza-kv/src/main/scala/org/apache/samza/storage/kv/KeyValueStorageEngine.scala x: 28 # contributors y: 39 # changes samza-core/src/main/scala/org/apache/samza/coordinator/JobModelManager.scala x: 28 # contributors y: 67 # changes samza-log4j/src/main/java/org/apache/samza/logging/log4j/StreamAppender.java x: 18 # contributors y: 33 # changes samza-yarn/src/main/resources/scalate/WEB-INF/views/index.scaml x: 15 # contributors y: 20 # changes samza-test/src/main/java/org/apache/samza/system/mock/MockSystemConsumer.java x: 7 # contributors y: 7 # changes samza-azure/src/main/java/org/apache/samza/coordinator/AzureJobCoordinator.java x: 14 # contributors y: 19 # changes samza-core/src/main/java/org/apache/samza/standalone/PassthroughJobCoordinator.java x: 16 # contributors y: 28 # changes samza-core/src/main/java/org/apache/samza/system/inmemory/InMemoryManager.java x: 14 # contributors y: 24 # changes samza-core/src/main/scala/org/apache/samza/checkpoint/CheckpointTool.scala x: 24 # contributors y: 36 # changes samza-core/src/main/scala/org/apache/samza/checkpoint/file/FileSystemCheckpointManager.scala x: 8 # contributors y: 10 # changes samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKey.java x: 4 # contributors y: 9 # changes samza-kafka/src/main/java/org/apache/samza/checkpoint/kafka/KafkaCheckpointLogKeySerde.java x: 8 # contributors y: 12 # changes samza-core/src/main/java/org/apache/samza/config/ClusterManagerConfig.java x: 14 # contributors y: 15 # changes samza-kv-rocksdb/src/main/java/org/apache/samza/storage/kv/descriptors/RocksDbTableDescriptor.java x: 8 # contributors y: 21 # changes samza-core/src/main/java/org/apache/samza/zk/ZkKeyBuilder.java x: 5 # contributors y: 11 # changes samza-sql/src/main/java/org/apache/samza/sql/avro/AvroTypeFactoryImpl.java x: 10 # contributors y: 22 # changes samza-sql/src/main/java/org/apache/samza/sql/planner/QueryPlanner.java x: 11 # contributors y: 33 # changes samza-sql/src/main/java/org/apache/samza/sql/planner/RelSchemaConverter.java x: 10 # contributors y: 15 # changes samza-sql/src/main/java/org/apache/samza/sql/planner/SamzaSqlOperatorTable.java x: 9 # contributors y: 13 # changes samza-sql/src/main/java/org/apache/samza/sql/runner/SamzaSqlApplicationRunner.java x: 15 # contributors y: 32 # changes samza-sql/src/main/java/org/apache/samza/sql/translator/FilterTranslator.java x: 14 # contributors y: 25 # changes samza-sql/src/main/java/org/apache/samza/sql/translator/JoinTranslator.java x: 13 # contributors y: 41 # changes samza-sql/src/main/java/org/apache/samza/sql/translator/ProjectTranslator.java x: 15 # contributors y: 34 # changes samza-sql/src/main/java/org/apache/samza/sql/translator/SamzaSqlRemoteTableJoinFunction.java x: 6 # contributors y: 11 # changes samza-sql/src/main/java/org/apache/samza/sql/translator/SamzaSqlTableJoinFunction.java x: 7 # contributors y: 15 # changes samza-sql/src/main/java/org/apache/samza/sql/translator/ScanTranslator.java x: 16 # contributors y: 46 # changes samza-sql/src/main/java/org/apache/samza/sql/translator/TranslatorContext.java x: 11 # contributors y: 23 # changes samza-core/src/main/java/org/apache/samza/execution/JobGraphJsonGenerator.java x: 14 # contributors y: 34 # changes samza-core/src/main/java/org/apache/samza/serializers/model/JsonTaskModelMixIn.java x: 9 # contributors y: 8 # changes samza-core/src/main/java/org/apache/samza/startpoint/StartpointFanOutPerTask.java x: 3 # contributors y: 2 # changes samza-sql/src/main/java/org/apache/samza/sql/data/SamzaSqlRelMessage.java x: 12 # contributors y: 31 # changes samza-sql/src/main/java/org/apache/samza/sql/data/SamzaSqlRelMsgMetadata.java x: 7 # contributors y: 13 # changes samza-sql/src/main/java/org/apache/samza/sql/runner/SamzaSqlApplicationConfig.java x: 15 # contributors y: 48 # changes samza-yarn/src/main/scala/org/apache/samza/webapp/ApplicationMasterRestServlet.scala x: 17 # contributors y: 21 # changes samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaSystemConsumerMetrics.scala x: 8 # contributors y: 11 # changes samza-core/src/main/java/org/apache/samza/container/ContainerHeartbeatMonitor.java x: 12 # contributors y: 15 # changes samza-core/src/main/java/org/apache/samza/clustermanager/ContainerAllocator.java x: 13 # contributors y: 25 # changes samza-core/src/main/java/org/apache/samza/clustermanager/ContainerManager.java x: 7 # contributors y: 17 # changes samza-core/src/main/java/org/apache/samza/clustermanager/StandbyContainerManager.java x: 11 # contributors y: 14 # changes samza-core/src/main/java/org/apache/samza/clustermanager/SamzaApplicationState.java x: 13 # contributors y: 20 # changes samza-core/src/main/scala/org/apache/samza/metrics/ContainerProcessManagerMetrics.scala x: 14 # contributors y: 18 # changes samza-api/src/main/java/org/apache/samza/system/SystemAdmin.java x: 19 # contributors y: 29 # changes samza-core/src/main/java/org/apache/samza/execution/StreamManager.java x: 14 # contributors y: 23 # changes samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaSystemAdmin.java x: 18 # contributors y: 40 # changes samza-tools/src/main/java/org/apache/samza/tools/benchmark/SystemConsumerWithSamzaBench.java x: 12 # contributors y: 21 # changes samza-core/src/main/java/org/apache/samza/container/LocalityManager.java x: 19 # contributors y: 33 # changes samza-core/src/main/java/org/apache/samza/execution/LocalJobPlanner.java x: 11 # contributors y: 18 # changes samza-rest/src/main/java/org/apache/samza/rest/proxy/task/SamzaTaskProxy.java x: 15 # contributors y: 25 # changes samza-azure/src/main/java/org/apache/samza/system/eventhub/admin/EventHubSystemAdmin.java x: 11 # contributors y: 19 # changes samza-azure/src/main/java/org/apache/samza/system/eventhub/producer/EventHubSystemProducer.java x: 9 # contributors y: 18 # changes samza-core/src/main/java/org/apache/samza/clustermanager/ClusterResourceManager.java x: 11 # contributors y: 12 # changes samza-core/src/main/java/org/apache/samza/container/grouper/stream/SSPGrouperProxy.java x: 8 # contributors y: 13 # changes samza-core/src/main/java/org/apache/samza/container/grouper/task/TaskAssignmentManager.java x: 14 # contributors y: 31 # changes samza-core/src/main/java/org/apache/samza/execution/JobGraph.java x: 12 # contributors y: 33 # changes samza-core/src/main/java/org/apache/samza/execution/JobNode.java x: 16 # contributors y: 41 # changes samza-core/src/main/java/org/apache/samza/execution/JobNodeConfigurationGenerator.java x: 11 # contributors y: 29 # changes samza-core/src/main/java/org/apache/samza/table/TableConfigGenerator.java x: 9 # contributors y: 25 # changes samza-kafka/src/main/java/org/apache/samza/config/KafkaConsumerConfig.java x: 9 # contributors y: 19 # changes samza-kafka/src/main/java/org/apache/samza/system/kafka/KafkaStreamSpec.java x: 12 # contributors y: 20 # changes samza-kv/src/main/scala/org/apache/samza/storage/kv/CachedStore.scala x: 22 # contributors y: 30 # changes samza-kv/src/main/scala/org/apache/samza/storage/kv/LoggedStore.scala x: 15 # contributors y: 19 # changes samza-kv/src/main/scala/org/apache/samza/storage/kv/NullSafeKeyValueStore.scala x: 14 # contributors y: 17 # changes samza-kv/src/main/scala/org/apache/samza/storage/kv/SerializedKeyValueStore.scala x: 20 # contributors y: 29 # changes samza-sql/src/main/java/org/apache/samza/sql/fn/BuildOutputRecordUdf.java x: 6 # contributors y: 12 # changes samza-sql/src/main/java/org/apache/samza/sql/impl/ConfigBasedIOResolverFactory.java x: 10 # contributors y: 23 # changes samza-sql/src/main/java/org/apache/samza/sql/impl/ConfigBasedUdfResolver.java x: 8 # contributors y: 14 # changes samza-sql/src/main/java/org/apache/samza/sql/planner/SamzaSqlValidator.java x: 6 # contributors y: 14 # changes samza-sql/src/main/java/org/apache/samza/sql/translator/QueryTranslator.java x: 16 # contributors y: 58 # changes samza-test/src/main/python/samza_job_yarn_deployer.py x: 10 # contributors y: 10 # changes samza-tools/src/main/java/org/apache/samza/tools/SamzaSqlConsole.java x: 12 # contributors y: 16 # changes samza-core/src/main/scala/org/apache/samza/job/JobRunner.scala x: 27 # contributors y: 38 # changes samza-api/src/main/java/org/apache/samza/system/StreamSpec.java x: 14 # contributors y: 21 # changes samza-kafka/src/main/scala/org/apache/samza/checkpoint/kafka/KafkaCheckpointManagerFactory.scala x: 20 # contributors y: 28 # changes samza-yarn/src/main/java/org/apache/samza/config/YarnConfig.java x: 12 # contributors y: 13 # changes samza-sql/src/main/java/org/apache/samza/sql/runner/SamzaSqlApplication.java x: 11 # contributors y: 25 # changes samza-log4j/src/main/java/org/apache/samza/config/Log4jSystemConfig.java x: 12 # contributors y: 17 # changes samza-core/src/main/java/org/apache/samza/execution/ExecutionPlanner.java x: 16 # contributors y: 47 # changes samza-sql/src/main/java/org/apache/samza/sql/fn/FlattenUdf.java x: 5 # contributors y: 12 # changes samza-azure/src/main/java/org/apache/samza/coordinator/AzureLock.java x: 8 # contributors y: 8 # changes samza-api/src/main/java/org/apache/samza/table/remote/TableRateLimiter.java x: 3 # contributors y: 14 # changes samza-api/src/main/java/org/apache/samza/table/remote/TableReadFunction.java x: 3 # contributors y: 10 # changes samza-api/src/main/java/org/apache/samza/table/utils/SerdeUtils.java x: 5 # contributors y: 15 # changes samza-core/src/main/java/org/apache/samza/container/grouper/task/GroupByContainerCount.java x: 11 # contributors y: 16 # changes samza-api/src/main/java/org/apache/samza/table/retry/TableRetryPolicy.java x: 4 # contributors y: 10 # changes samza-core/src/main/java/org/apache/samza/operators/impl/InputOperatorImpl.java x: 10 # contributors y: 19 # changes samza-core/src/main/java/org/apache/samza/operators/impl/OutputOperatorImpl.java x: 13 # contributors y: 18 # changes samza-core/src/main/java/org/apache/samza/operators/impl/PartialJoinOperatorImpl.java x: 10 # contributors y: 17 # changes samza-core/src/main/java/org/apache/samza/operators/impl/WindowOperatorImpl.java x: 12 # contributors y: 27 # changes samza-api/src/main/java/org/apache/samza/table/descriptors/BaseTableDescriptor.java x: 3 # contributors y: 12 # changes samza-api/src/main/java/org/apache/samza/table/TableProviderFactory.java x: 4 # contributors y: 11 # changes samza-api/src/main/java/org/apache/samza/table/descriptors/CachingTableDescriptor.java x: 3 # contributors y: 8 # changes samza-core/src/main/java/org/apache/samza/table/BaseTableProvider.java x: 3 # contributors y: 9 # changes samza-api/src/main/java/org/apache/samza/task/InitableTask.java x: 4 # contributors y: 2 # changes samza-core/src/main/java/org/apache/samza/task/AsyncStreamTaskAdapter.java x: 8 # contributors y: 6 # changes samza-core/src/main/java/org/apache/samza/operators/spec/WindowOperatorSpec.java x: 12 # contributors y: 18 # changes samza-core/src/main/scala/org/apache/samza/system/chooser/BootstrappingChooser.scala x: 14 # contributors y: 20 # changes
216.0
# changes
  min: 1.0
  average: 8.13
  25th percentile: 2.0
  median: 4.0
  75th percentile: 10.0
  max: 216.0
0 75.0
# contributors
min: 1.0 | average: 5.2 | 25th percentile: 2.0 | median: 4.0 | 75th percentile: 6.0 | max: 75.0

Number of Contributors vs. File Size: 1232 points

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