Netflix/mantis
File Churn
File change frequency (churn) shows the distribution of file updates (days with at least one commit).
Overview
File Change Frequency Overall
  • There are 894 files with 81,656 lines of code.
    • 0 files changed more than 100 times (0 lines of code)
    • 1 file changed 51-100 times (895 lines of code)
    • 10 files changed 21-50 times (7,849 lines of code)
    • 80 files changed 6-20 times (19,849 lines of code)
    • 803 files changed 1-5 times (53,063 lines of code)
0% | 1% | 9% | 24% | 64%
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 894 files with 81,656 lines of code.
    • 0 files changed by more than 25 contributors (0 lines of code)
    • 4 files changed by 11-25 contributors (1,170 lines of code)
    • 21 files changed by 6-10 contributors (14,592 lines of code)
    • 475 files changed by 2-5 contributors (45,241 lines of code)
    • 394 files changed by 1 contributor (20,653 lines of code)
0% | 1% | 17% | 55% | 25%
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, gradle, properties, json, svg, yml, txt, xml, sh, css, jsp, bat, editorconfig, html, gitignore
File Change Frequency per Extension
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
java0% | 1% | 9% | 24% | 64%
xml0% | 0% | 0% | 0% | 100%
html0% | 0% | 0% | 0% | 100%
jsp0% | 0% | 0% | 0% | 100%
yaml0% | 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
mantis-control-plane0% | 2% | 17% | 32% | 47%
mantis-server0% | 0% | 20% | 37% | 41%
mantis-runtime0% | 0% | 0% | 21% | 78%
mantis-common0% | 0% | 0% | 21% | 78%
mantis-network0% | 0% | 0% | 27% | 72%
mantis-runtime-executor0% | 0% | 0% | 24% | 75%
mantis-connectors0% | 0% | 0% | 10% | 89%
mantis-publish0% | 0% | 0% | 12% | 87%
mantis-runtime-loader0% | 0% | 0% | 37% | 62%
mantis-client0% | 0% | 0% | 25% | 74%
mantis-remote-observable0% | 0% | 0% | 0% | 100%
mantis-runtime-autoscaler-api0% | 0% | 0% | 0% | 100%
mantis-source-jobs0% | 0% | 0% | 0% | 100%
mantis-rxcontrol0% | 0% | 0% | 0% | 100%
mantis-jm-akka0% | 0% | 0% | 0% | 100%
mantis-examples0% | 0% | 0% | 0% | 100%
.baseline0% | 0% | 0% | 0% | 100%
mantis-discovery-proto0% | 0% | 0% | 0% | 100%
mantis-common-akka0% | 0% | 0% | 0% | 100%
mantis-common-serde0% | 0% | 0% | 0% | 100%
.github0% | 0% | 0% | 0% | 100%
Most Frequently Changed Files (Top 50)

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsline
churn		first
contributor		latest
contributor
ResourceClusterActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster
 895 40 2022-04-12 2026-03-11 58 6 +2652 / -1554 me 87735571+andyz26
JobActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job
 2213 99 2020-10-02 2026-07-02 44 10 +6216 / -729 jchao 87735571+andyz26
MasterConfiguration.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/config
 281 3 2020-10-02 2026-08-13 39 12 +797 / -72 jchao ggjbetty
JobClusterActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster
 2641 134 2020-10-02 2026-04-28 39 9 +7793 / -826 jchao ggjbetty
MasterMain.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master
 254 10 2020-10-02 2026-08-13 32 12 +999 / -294 jchao ggjbetty
ResourceClustersManagerActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster
 295 11 2022-04-16 2026-03-11 25 4 +398 / -38 me 87735571+andyz26
TaskExecutor.java
in mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent
 565 40 2022-05-07 2025-09-10 25 7 +1516 / -816 cal681 ggjbetty
ResourceClusterAkkaImpl.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster
 338 20 2022-04-12 2026-02-23 24 3 +445 / -54 me 87735571+andyz26
ExecutorStateManagerImpl.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster
 664 25 2023-01-17 2026-02-25 24 6 +1109 / -166 87735571+andyz26 87735571+andyz26
ResourceCluster.java
in mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/master/resourcecluster
 118 8 2022-04-12 2026-02-23 22 3 +329 / -29 me 87735571+andyz26
ResourceClusterAwareSchedulerActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler
 480 37 2022-04-19 2026-03-24 21 4 +721 / -129 me 87735571+andyz26
MantisJobStore.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/persistence
 279 43 2020-10-02 2026-02-27 18 5 +906 / -140 jchao 87735571+andyz26
KeyValueBasedPersistenceProvider.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/persistence
 863 70 2022-11-19 2026-02-27 18 5 +1124 / -113 100323213+hmitnflx 87735571+andyz26
DataFormatAdapter.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain
 681 51 2020-10-02 2025-12-16 17 8 +1846 / -77 jchao ggjbetty
SchedulingInfo.java
in mantis-common/src/main/java/io/mantisrx/runtime/descriptor
 205 21 2020-07-09 2024-07-04 15 5 +387 / -218 cal681 100323213+hmitnflx
ParameterUtils.java
in mantis-runtime/src/main/java/io/mantisrx/runtime/parameter
 294 8 2019-10-04 2025-07-29 15 11 +137 / -77 nmahilani 87735571+andyz26
SseWorkerConnection.java
in mantis-server/mantis-server-worker-client/src/main/java/io/mantisrx/server/worker/client
 341 16 2020-03-25 2025-03-10 15 11 +148 / -93 njoshi 53982208+jpittis-stripe
WorkerConfiguration.java
in mantis-runtime-loader/src/main/java/io/mantisrx/runtime/loader/config
 128 4 2022-10-29 2024-11-07 14 5 +208 / -13 87735571+andyz26 87735571+andyz26
IcebergWriterStage.java
in mantis-connectors/mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer
 266 14 2020-10-01 2023-05-26 14 6 +1088 / -367 jchao me
ResourceClustersNonLeaderRedirectRoute.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1
 422 22 2022-05-02 2024-04-30 14 3 +609 / -50 87735571+andyz26 87735571+andyz26
ResourceClusterScalerActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster
 466 21 2022-06-02 2026-02-23 14 3 +787 / -155 87735571+andyz26 87735571+andyz26
JobClusterManagerProto.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto
 1888 231 2020-10-02 2026-04-16 14 6 +4588 / -67 jchao 24739317+james-lubin
PushServerSse.java
in mantis-network/src/main/java/io/reactivex/mantis/network/push
 262 3 2019-06-25 2025-02-11 13 7 +85 / -68 crioux 135762838+tcai-stripe
MasterApiAkkaService.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka
 297 7 2020-10-02 2026-08-13 13 9 +652 / -61 jchao ggjbetty
MantisMasterClientApi.java
in mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client
 666 32 2020-10-02 2026-06-06 13 6 +1714 / -45 jchao ggjbetty
StageScalingPolicy.java
in mantis-common/src/main/java/io/mantisrx/runtime/descriptor
 98 4 2020-01-30 2024-07-04 12 5 +52 / -175 crioux 100323213+hmitnflx
TaskExecutorState.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster
 269 32 2023-01-17 2026-02-23 12 2 +382 / -33 87735571+andyz26 87735571+andyz26
BaseRoute.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1
 366 14 2020-10-02 2026-08-13 12 4 +832 / -16 jchao ggjbetty
JobClustersManagerActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master
 962 67 2020-10-02 2026-04-16 12 6 +2356 / -92 jchao 24739317+james-lubin
WorkerPorts.java
in mantis-common/src/main/java/io/mantisrx/common
 102 12 2020-02-20 2022-05-19 11 4 +151 / -124 jchao me
StageSchedulingInfo.java
in mantis-common/src/main/java/io/mantisrx/runtime/descriptor
 131 11 2020-07-09 2023-05-09 11 4 +141 / -124 cal681 me
DefaultIcebergWriter.java
in mantis-connectors/mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer
 154 14 2020-10-01 2023-05-26 11 4 +508 / -26 jchao me
JobDefinition.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain
 341 39 2020-10-02 2024-09-13 11 6 +828 / -48 jchao kmg
IMantisPersistenceProvider.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/persistence
 81 2 2022-11-19 2025-03-17 10 5 +229 / -13 100323213+hmitnflx 87735571+andyz26
ZookeeperMasterMonitor.java
in mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core/master
 106 7 2020-10-02 2024-06-26 10 5 +314 / -51 jchao kmg
ExecuteStageRequest.java
in mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core
 109 3 2020-10-02 2024-07-17 10 5 +459 / -128 jchao 139389030+sarahwada-stripe
TaskExecutorStarter.java
in mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent
 156 16 2022-05-07 2024-07-04 10 6 +408 / -200 cal681 100323213+hmitnflx
HighAvailabilityServicesUtil.java
in mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client
 192 14 2022-03-22 2024-08-21 10 4 +281 / -33 me kmg
WorkerConfigurationWritable.java
in mantis-runtime-loader/src/main/java/io/mantisrx/runtime/loader/config
 225 41 2023-02-01 2024-09-12 10 7 +302 / -7 87735571+andyz26 131782471+timmartin-stripe
StageExecutors.java
in mantis-runtime/src/main/java/io/mantisrx/runtime/executor
 406 7 2020-07-18 2023-07-14 10 8 +154 / -110 njoshi 100323213+hmitnflx
MantisJobMetadataImpl.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job
 409 55 2020-10-02 2026-05-14 10 5 +1074 / -71 jchao 87735571+andyz26
WorkerExecutionOperationsNetworkStage.java
in mantis-runtime-executor/src/main/java/io/mantisrx/server/worker
 567 18 2024-01-29 2025-04-28 10 4 +769 / -47 87735571+andyz26 87735571+andyz26
MantisSchedulerFactoryImpl.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler
 62 3 2022-04-19 2026-02-23 9 3 +152 / -61 me 87735571+andyz26
ResourceClustersAkkaImpl.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster
 88 3 2022-04-16 2026-02-23 9 2 +143 / -26 me 87735571+andyz26
ServerSentEventRequestHandler.java
in mantis-runtime/src/main/java/io/mantisrx/runtime/sink
 283 2 2020-07-25 2023-07-09 9 6 +143 / -84 crioux jeevanrangaramaiah
JobClusterProtoAdapter.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/proto
 285 24 2020-10-02 2025-12-16 9 6 +930 / -39 jchao ggjbetty
ResourceClustersHostManagerActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster
 355 15 2022-04-26 2024-04-11 9 2 +578 / -136 87735571+andyz26 87735571+andyz26
PushServer.java
in mantis-network/src/main/java/io/reactivex/mantis/network/push
 396 11 2020-07-25 2025-04-14 9 6 +101 / -33 crioux 87735571+andyz26
TaskExecutorGateway.java
in mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/worker
 34 4 2022-03-21 2023-07-21 8 5 +115 / -21 me me
ResourceClusterGatewayAkkaImpl.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster
 116 7 2022-04-12 2023-11-22 8 2 +182 / -34 me 87735571+andyz26
Files With Most Churn (Top 50)
Based on the number of lines added and deleted across all commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsline
churn		first
contributor		latest
contributor
JobClusterActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster
 2641 134 2020-10-02 2026-04-28 39 9 +7793 / -826 jchao ggjbetty
JobActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job
 2213 99 2020-10-02 2026-07-02 44 10 +6216 / -729 jchao 87735571+andyz26
JobClusterManagerProto.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto
 1888 231 2020-10-02 2026-04-16 14 6 +4588 / -67 jchao 24739317+james-lubin
ResourceClusterActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster
 895 40 2022-04-12 2026-03-11 58 6 +2652 / -1554 me 87735571+andyz26
NamedJob.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store
 355 52 2020-10-02 2025-12-16 4 4 +2109 / -619 jchao ggjbetty
JobClustersManagerActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master
 962 67 2020-10-02 2026-04-16 12 6 +2356 / -92 jchao 24739317+james-lubin
TaskExecutor.java
in mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent
 565 40 2022-05-07 2025-09-10 25 7 +1516 / -816 cal681 ggjbetty
DataFormatAdapter.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain
 681 51 2020-10-02 2025-12-16 17 8 +1846 / -77 jchao ggjbetty
MantisMasterClientApi.java
in mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client
 666 32 2020-10-02 2026-06-06 13 6 +1714 / -45 jchao ggjbetty
JobWorker.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker
 509 25 2020-10-02 2026-03-04 8 4 +1622 / -54 jchao 87735571+andyz26
JobsRoute.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1
 505 17 2020-10-02 2026-08-13 5 4 +1522 / -138 jchao ggjbetty
JobClustersRoute.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1
 629 20 2020-10-02 2026-04-16 7 5 +1486 / -30 jchao 24739317+james-lubin
IcebergWriterStage.java
in mantis-connectors/mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer
 266 14 2020-10-01 2023-05-26 14 6 +1088 / -367 jchao me
MantisStageMetadataImpl.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job
 466 44 2020-10-02 2026-05-14 7 5 +1399 / -49 jchao 87735571+andyz26
JobClusterRoute.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v0
 506 6 2020-10-02 2025-09-10 4 4 +1275 / -116 jchao ggjbetty
ExecutorStateManagerActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster
 1143 56 2026-02-23 2026-04-22 4 1 +1342 / -21 87735571+andyz26 87735571+andyz26
MasterMain.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master
 254 10 2020-10-02 2026-08-13 32 12 +999 / -294 jchao ggjbetty
AbstractSubscriptionTracker.java
in mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish
 159 6 2020-10-02 2023-02-22 8 5 +877 / -401 jchao me
ExecutorStateManagerImpl.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster
 664 25 2023-01-17 2026-02-25 24 6 +1109 / -166 87735571+andyz26 87735571+andyz26
KeyValueBasedPersistenceProvider.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/persistence
 863 70 2022-11-19 2026-02-27 18 5 +1124 / -113 100323213+hmitnflx 87735571+andyz26
MantisJobMetadataImpl.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job
 409 55 2020-10-02 2026-05-14 10 5 +1074 / -71 jchao 87735571+andyz26
MantisJobStore.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/persistence
 279 43 2020-10-02 2026-02-27 18 5 +906 / -140 jchao 87735571+andyz26
MasterClientWrapper.java
in mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client
 300 20 2020-10-02 2023-11-10 6 5 +896 / -111 jchao 103213338+fdc-ntflx
JobClusterProtoAdapter.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/proto
 285 24 2020-10-02 2025-12-16 9 6 +930 / -39 jchao ggjbetty
JobClusterDefinitionImpl.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain
 384 45 2020-10-02 2025-12-16 7 6 +944 / -21 jchao ggjbetty
476 - 2021-09-22 2021-09-22 1 2 +952 / -0 me sananthanarayanan
ResourceClusterScalerActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster
 466 21 2022-06-02 2026-02-23 14 3 +787 / -155 87735571+andyz26 87735571+andyz26
Hardware.java
in mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent
 198 8 2022-05-07 2022-10-29 3 3 +602 / -301 cal681 87735571+andyz26
MantisWorkerMetadataImpl.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker
 315 45 2020-10-02 2024-12-13 4 3 +872 / -12 jchao 87735571+andyz26
JobDefinition.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain
 341 39 2020-10-02 2024-09-13 11 6 +828 / -48 jchao kmg
MasterConfiguration.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/config
 281 3 2020-10-02 2026-08-13 39 12 +797 / -72 jchao ggjbetty
ResourceClusterAwareSchedulerActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler
 480 37 2022-04-19 2026-03-24 21 4 +721 / -129 me 87735571+andyz26
BaseRoute.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1
 366 14 2020-10-02 2026-08-13 12 4 +832 / -16 jchao ggjbetty
SampleArchaiusMrePublishConfiguration.java
in mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/config
 340 37 2020-10-02 2021-10-06 2 2 +830 / -4 jchao me
WorkerExecutionOperationsNetworkStage.java
in mantis-runtime-executor/src/main/java/io/mantisrx/server/worker
 567 18 2024-01-29 2025-04-28 10 4 +769 / -47 87735571+andyz26 87735571+andyz26
JobRoute.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v0
 315 5 2020-10-02 2021-10-06 2 2 +787 / -12 jchao me
KafkaSource.java
in mantis-connectors/mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source
 313 7 2020-10-01 2022-04-06 3 2 +770 / -20 jchao me
ReservationRegistryActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster
 604 37 2026-02-23 2026-04-06 3 1 +760 / -3 87735571+andyz26 87735571+andyz26
LifecycleEventsProto.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/events
 224 17 2020-10-02 2023-07-14 5 3 +685 / -77 jchao 100323213+hmitnflx
MrePublishConfiguration.java
in mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/config
 47 2 2020-10-02 2021-10-06 2 2 +731 / -2 jchao me
MantisJobMetadataWritable.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store
 207 12 2020-10-02 2023-11-30 5 4 +639 / -88 jchao 87735571+andyz26
MantisWorkerMetadataWritable.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store
 283 47 2020-10-02 2022-05-10 3 2 +718 / -8 jchao me
ResourceClustersHostManagerActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster
 355 15 2022-04-26 2024-04-11 9 2 +578 / -136 87735571+andyz26 87735571+andyz26
MasterApiAkkaService.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka
 297 7 2020-10-02 2026-08-13 13 9 +652 / -61 jchao ggjbetty
MantisKafkaConsumer.java
in mantis-connectors/mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source
 250 27 2020-10-01 2021-10-06 2 2 +684 / -13 jchao me
ResourceClustersNonLeaderRedirectRoute.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1
 422 22 2022-05-02 2024-04-30 14 3 +609 / -50 87735571+andyz26 87735571+andyz26
JobDefinitionResolver.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster
 152 5 2020-10-02 2024-09-13 4 4 +632 / -23 jchao kmg
JobAutoScaler.java
in mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster
 545 20 2025-04-28 2025-12-02 2 1 +634 / -2 87735571+andyz26 87735571+andyz26
StreamManager.java
in mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish
 178 13 2020-10-02 2025-05-09 6 5 +563 / -67 jchao n3ca88
JobClusterProto.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto
 182 21 2020-10-02 2023-12-11 4 2 +604 / -26 jchao me
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)		# contributorsline
churn		first
contributor		latest
contributor
MasterConfiguration.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/config
 281 3 2020-10-02 2026-08-13 39 12 +797 / -72 jchao ggjbetty
MasterMain.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master
 254 10 2020-10-02 2026-08-13 32 12 +999 / -294 jchao ggjbetty
SseWorkerConnection.java
in mantis-server/mantis-server-worker-client/src/main/java/io/mantisrx/server/worker/client
 341 16 2020-03-25 2025-03-10 15 11 +148 / -93 njoshi 53982208+jpittis-stripe
ParameterUtils.java
in mantis-runtime/src/main/java/io/mantisrx/runtime/parameter
 294 8 2019-10-04 2025-07-29 15 11 +137 / -77 nmahilani 87735571+andyz26
JobActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job
 2213 99 2020-10-02 2026-07-02 44 10 +6216 / -729 jchao 87735571+andyz26
JobClusterActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster
 2641 134 2020-10-02 2026-04-28 39 9 +7793 / -826 jchao ggjbetty
MasterApiAkkaService.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka
 297 7 2020-10-02 2026-08-13 13 9 +652 / -61 jchao ggjbetty
DataFormatAdapter.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain
 681 51 2020-10-02 2025-12-16 17 8 +1846 / -77 jchao ggjbetty
StageExecutors.java
in mantis-runtime/src/main/java/io/mantisrx/runtime/executor
 406 7 2020-07-18 2023-07-14 10 8 +154 / -110 njoshi 100323213+hmitnflx
TaskExecutor.java
in mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent
 565 40 2022-05-07 2025-09-10 25 7 +1516 / -816 cal681 ggjbetty
PushServerSse.java
in mantis-network/src/main/java/io/reactivex/mantis/network/push
 262 3 2019-06-25 2025-02-11 13 7 +85 / -68 crioux 135762838+tcai-stripe
WorkerConfigurationWritable.java
in mantis-runtime-loader/src/main/java/io/mantisrx/runtime/loader/config
 225 41 2023-02-01 2024-09-12 10 7 +302 / -7 87735571+andyz26 131782471+timmartin-stripe
ResourceClusterActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster
 895 40 2022-04-12 2026-03-11 58 6 +2652 / -1554 me 87735571+andyz26
ExecutorStateManagerImpl.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster
 664 25 2023-01-17 2026-02-25 24 6 +1109 / -166 87735571+andyz26 87735571+andyz26
JobClusterManagerProto.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto
 1888 231 2020-10-02 2026-04-16 14 6 +4588 / -67 jchao 24739317+james-lubin
IcebergWriterStage.java
in mantis-connectors/mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer
 266 14 2020-10-01 2023-05-26 14 6 +1088 / -367 jchao me
MantisMasterClientApi.java
in mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client
 666 32 2020-10-02 2026-06-06 13 6 +1714 / -45 jchao ggjbetty
JobClustersManagerActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master
 962 67 2020-10-02 2026-04-16 12 6 +2356 / -92 jchao 24739317+james-lubin
JobDefinition.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain
 341 39 2020-10-02 2024-09-13 11 6 +828 / -48 jchao kmg
TaskExecutorStarter.java
in mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent
 156 16 2022-05-07 2024-07-04 10 6 +408 / -200 cal681 100323213+hmitnflx
JobClusterProtoAdapter.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/proto
 285 24 2020-10-02 2025-12-16 9 6 +930 / -39 jchao ggjbetty
ServerSentEventRequestHandler.java
in mantis-runtime/src/main/java/io/mantisrx/runtime/sink
 283 2 2020-07-25 2023-07-09 9 6 +143 / -84 crioux jeevanrangaramaiah
PushServer.java
in mantis-network/src/main/java/io/reactivex/mantis/network/push
 396 11 2020-07-25 2025-04-14 9 6 +101 / -33 crioux 87735571+andyz26
JobClusterDefinitionImpl.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain
 384 45 2020-10-02 2025-12-16 7 6 +944 / -21 jchao ggjbetty
CreateJobDescriptorFile.java
in mantis-runtime/src/main/java/io/mantisrx/runtime/command
 116 6 2020-07-09 2023-07-14 6 6 +26 / -27 cal681 100323213+hmitnflx
KeyValueBasedPersistenceProvider.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/persistence
 863 70 2022-11-19 2026-02-27 18 5 +1124 / -113 100323213+hmitnflx 87735571+andyz26
MantisJobStore.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/persistence
 279 43 2020-10-02 2026-02-27 18 5 +906 / -140 jchao 87735571+andyz26
SchedulingInfo.java
in mantis-common/src/main/java/io/mantisrx/runtime/descriptor
 205 21 2020-07-09 2024-07-04 15 5 +387 / -218 cal681 100323213+hmitnflx
WorkerConfiguration.java
in mantis-runtime-loader/src/main/java/io/mantisrx/runtime/loader/config
 128 4 2022-10-29 2024-11-07 14 5 +208 / -13 87735571+andyz26 87735571+andyz26
StageScalingPolicy.java
in mantis-common/src/main/java/io/mantisrx/runtime/descriptor
 98 4 2020-01-30 2024-07-04 12 5 +52 / -175 crioux 100323213+hmitnflx
IMantisPersistenceProvider.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/persistence
 81 2 2022-11-19 2025-03-17 10 5 +229 / -13 100323213+hmitnflx 87735571+andyz26
MantisJobMetadataImpl.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job
 409 55 2020-10-02 2026-05-14 10 5 +1074 / -71 jchao 87735571+andyz26
ExecuteStageRequest.java
in mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core
 109 3 2020-10-02 2024-07-17 10 5 +459 / -128 jchao 139389030+sarahwada-stripe
ZookeeperMasterMonitor.java
in mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core/master
 106 7 2020-10-02 2024-06-26 10 5 +314 / -51 jchao kmg
MantisJobDefinition.java
in mantis-common/src/main/java/io/mantisrx/runtime
 289 38 2020-07-09 2026-06-06 8 5 +149 / -21 cal681 ggjbetty
CompressionUtils.java
in mantis-common/src/main/java/io/mantisrx/common/compression
 329 15 2020-07-25 2022-03-26 8 5 +205 / -72 crioux cal681
TaskExecutorGateway.java
in mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/worker
 34 4 2022-03-21 2023-07-21 8 5 +115 / -21 me me
AbstractSubscriptionTracker.java
in mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish
 159 6 2020-10-02 2023-02-22 8 5 +877 / -401 jchao me
MantisScheduler.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler
 22 2 2020-10-02 2026-02-23 7 5 +304 / -62 jchao 87735571+andyz26
MantisStageMetadataImpl.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job
 466 44 2020-10-02 2026-05-14 7 5 +1399 / -49 jchao 87735571+andyz26
HttpRequestMetrics.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1
 107 3 2020-10-02 2026-04-16 7 5 +264 / -6 jchao 24739317+james-lubin
JobClustersRoute.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1
 629 20 2020-10-02 2026-04-16 7 5 +1486 / -30 jchao 24739317+james-lubin
ServerSentEventsSink.java
in mantis-runtime/src/main/java/io/mantisrx/runtime/sink
 240 23 2021-09-22 2025-02-12 7 5 +80 / -37 sananthanarayanan 135762838+tcai-stripe
WorkerConfigurationUtils.java
in mantis-runtime-loader/src/main/java/io/mantisrx/runtime/loader/config
 57 3 2022-10-29 2024-07-04 7 5 +78 / -1 87735571+andyz26 100323213+hmitnflx
MetricsServer.java
in mantis-common/src/main/java/io/mantisrx/common/metrics
 142 4 2019-11-14 2023-09-19 6 5 +21 / -21 crioux 87735571+andyz26
MasterClientWrapper.java
in mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client
 300 20 2020-10-02 2023-11-10 6 5 +896 / -111 jchao 103213338+fdc-ntflx
CoreConfiguration.java
in mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core
 50 - 2020-10-02 2024-11-07 6 5 +164 / -8 jchao 87735571+andyz26
JobMetadata.java
in mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core/domain
 44 2 2020-10-02 2024-07-17 6 5 +187 / -36 jchao 139389030+sarahwada-stripe
StreamManager.java
in mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish
 178 13 2020-10-02 2025-05-09 6 5 +563 / -67 jchao n3ca88
HadoopFileSystemBlobStore.java
in mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent
 35 3 2022-05-07 2023-09-22 6 5 +134 / -71 cal681 103213338+fdc-ntflx
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)		# contributorsline
churn		first
contributor		latest
contributor
CompressionUtilsBenchmark.java
in mantis-common/src/jmh/java/io/reactivx/common/compression
 152 11
RxMetrics.java
in mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable
 110 26
Endpoint.java
in mantis-common/src/main/java/io/mantisrx/common/network
 106 13
FixedConnectionSet.java
in mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable
 100 3
DynamicConnection.java
in mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable
 90 3
WorkerEndpoint.java
in mantis-common/src/main/java/io/mantisrx/common/network
 81 11
GaugeCallback.java
in mantis-common/src/main/java/io/mantisrx/common/metrics/spectator
 77 17
GaugeImpl.java
in mantis-common/src/main/java/io/mantisrx/common/metrics/spectator
 68 13
SingleThreadedChunker.java
in mantis-network/src/main/java/io/reactivex/mantis/network/push
 66 4
RemoteRxEvent.java
in mantis-network/src/main/java/io/reactivex/mantis/network/push
 66 12
RemoteRxEvent.java
in mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable
 66 12
Codecs.java
in mantis-remote-observable/src/main/java/io/reactivex/netty/codec
 65 6
OperatorOnErrorResumeNextViaFunction.java
in mantis-common/src/main/java/io/reactivx/mantis/operators
 62 2
MantisNettyEventsListenerFactory.java
in mantis-common/src/main/java/io/mantisrx/common/metrics/netty
 58 6
OperatorOnErrorResumeNextViaObservable.java
in mantis-common/src/main/java/io/reactivx/mantis/operators
 57 2
DoOnRequestOperator.java
in mantis-common/src/main/java/io/reactivx/mantis/operators
 57 8
ConsistentHash.java
in mantis-common/src/main/java/io/mantisrx/common/network
 54 6
HttpRequestFactories.java
in mantis-runtime/src/main/java/io/mantisrx/runtime/source/http/impl
 47 9
GaugeCallback.java
in mantis-common/src/main/java/io/mantisrx/common/metrics
 43 12
CounterImpl.java
in mantis-common/src/main/java/io/mantisrx/common/metrics/spectator
 42 8
PortSelectorWithinRange.java
in mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable
 40 3
HashAlgorithm.java
in mantis-common/src/main/java/io/mantisrx/common/network
 39 1
RoundRobin.java
in mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/slotting
 39 6
MantisServerSentEvent.java
in mantis-common/src/main/java/io/mantisrx/common
 38 5
SlottingStrategy.java
in mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/slotting
 38 8
EndpointChange.java
in mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable
 38 6
SubscribeInfo.java
in mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable
 33 6
Metadata.java
in mantis-runtime/src/main/java/io/mantisrx/runtime
 31 5
WorkerConnectionsStatus.java
in mantis-server/mantis-server-worker-client/src/main/java/io/mantisrx/server/worker/client
 28 5
PushTrigger.java
in mantis-network/src/main/java/io/reactivex/mantis/network/push
 28 5
Check.java
in mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/reconciliator
 26 5
Outcome.java
in mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/reconciliator
 26 5
HeartbeatHandler.java
in mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable
 24 1
WorkerMap.java
in mantis-runtime/src/main/java/io/mantisrx/runtime
 23 4
RemoteRxConnection.java
in mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable
 23 4
HashFunctions.java
in mantis-common/src/main/java/io/mantisrx/common/network
 22 3
StageIn.java
in mantis-runtime/src/main/java/io/mantisrx/runtime/markers
 22 1
StageOut.java
in mantis-runtime/src/main/java/io/mantisrx/runtime/markers
 22 1
NetworkMerge.java
in mantis-runtime/src/main/java/io/mantisrx/runtime/markers
 22 1
SourceOut.java
in mantis-runtime/src/main/java/io/mantisrx/runtime/markers
 22 1
StringParameter.java
in mantis-runtime/src/main/java/io/mantisrx/runtime/parameter/type
 22 3
MantisSourceJobConstants.java
in mantis-common/src/main/java/com/mantisrx/common/utils
 21 -
Group.java
in mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable
 21 3
KeyValuePair.java
in mantis-network/src/main/java/io/reactivex/mantis/network/push
 20 3
Gauge.java
in mantis-common/src/main/java/io/mantisrx/common/metrics
 18 1
MergeCounts.java
in mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable
 17 2
MantisMarker.java
in mantis-runtime/src/main/java/io/mantisrx/runtime/markers
 16 4
DateTimeExt.java
in mantis-common/src/main/java/io/mantisrx/common/util
 15 2
MantisGroup.java
in mantis-common/src/main/java/io/mantisrx/common
 15 3
DefaultLifecycleFactory.java
in mantis-runtime/src/main/java/io/mantisrx/runtime
 15 2
Correlations

File Size vs. Number of Changes: 894 points

mantis-common/src/main/java/io/mantisrx/config/dynamic/DynamicProperty.java x: 55 lines of code y: 2 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/MasterApiAkkaService.java x: 297 lines of code y: 13 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/BaseRoute.java x: 366 lines of code y: 12 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobsRoute.java x: 505 lines of code y: 5 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/utils/ApiRequestRateLimiter.java x: 11 lines of code y: 1 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/utils/ApiRequestRateLimiterFactory.java x: 46 lines of code y: 1 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/MasterMain.java x: 254 lines of code y: 32 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/config/MasterConfiguration.java x: 281 lines of code y: 39 # changes mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/clutch/ClutchAutoScaler.java x: 173 lines of code y: 2 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/JobActor.java x: 2213 lines of code y: 44 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/MantisJobClusterMetadataView.java x: 230 lines of code y: 4 # changes mantis-common/src/main/java/io/mantisrx/runtime/MantisJobDefinition.java x: 289 lines of code y: 8 # changes mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/MantisMasterClientApi.java x: 666 lines of code y: 13 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/IWorkerManager.java x: 41 lines of code y: 4 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/MantisJobMetadataImpl.java x: 409 lines of code y: 10 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/MantisStageMetadataImpl.java x: 466 lines of code y: 7 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/JobClusterActor.java x: 2641 lines of code y: 39 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ExecutorStateManagerActor.java x: 1143 lines of code y: 4 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/JobClustersManagerActor.java x: 962 lines of code y: 12 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/handlers/JobClusterRouteHandler.java x: 29 lines of code y: 5 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/handlers/JobClusterRouteHandlerAkkaImpl.java x: 148 lines of code y: 5 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/HttpRequestMetrics.java x: 107 lines of code y: 7 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobClustersRoute.java x: 629 lines of code y: 7 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java x: 1888 lines of code y: 14 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ReservationRegistryActor.java x: 604 lines of code y: 3 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterActorMetrics.java x: 88 lines of code y: 7 # changes mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/master/resourcecluster/TaskExecutorAllocationRequest.java x: 25 lines of code y: 6 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/ResourceClusterAwareSchedulerActor.java x: 480 lines of code y: 21 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterActor.java x: 895 lines of code y: 58 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClustersManagerActor.java x: 295 lines of code y: 25 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker/JobWorker.java x: 509 lines of code y: 8 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/persistence/KeyValueBasedPersistenceProvider.java x: 863 lines of code y: 18 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/persistence/MantisJobStore.java x: 279 lines of code y: 18 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ExecutorStateManagerImpl.java x: 664 lines of code y: 24 # changes mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/master/resourcecluster/ResourceCluster.java x: 118 lines of code y: 22 # changes mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/master/resourcecluster/ResourceClusters.java x: 9 lines of code y: 2 # changes mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/master/resourcecluster/proto/MantisResourceClusterReservationProto.java x: 146 lines of code y: 1 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobProto.java x: 170 lines of code y: 3 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/AssignmentHandlerActor.java x: 306 lines of code y: 1 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ExecutorStateManager.java x: 55 lines of code y: 7 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterAkkaImpl.java x: 338 lines of code y: 24 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterScalerActor.java x: 466 lines of code y: 14 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClustersAkkaImpl.java x: 88 lines of code y: 9 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/TaskAssignmentManagerActor.java x: 3 lines of code y: 1 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/TaskExecutorState.java x: 269 lines of code y: 12 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/proto/GetClusterUsageResponse.java x: 25 lines of code y: 3 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/ExecuteStageRequestFactory.java x: 65 lines of code y: 6 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/MantisScheduler.java x: 22 lines of code y: 7 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/MantisSchedulerFactory.java x: 18 lines of code y: 3 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/MantisSchedulerFactoryImpl.java x: 62 lines of code y: 9 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/ResourceClusterReservationAwareScheduler.java x: 70 lines of code y: 1 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/Jackson.java x: 149 lines of code y: 6 # changes mantis-common/src/main/java/io/mantisrx/runtime/JobPrincipal.java x: 32 lines of code y: 1 # changes mantis-common/src/main/java/io/mantisrx/runtime/NamedJobDefinition.java x: 38 lines of code y: 4 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/proto/JobClusterProtoAdapter.java x: 285 lines of code y: 9 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/DataFormatAdapter.java x: 681 lines of code y: 17 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/IJobClusterDefinition.java x: 22 lines of code y: 3 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/JobClusterDefinitionImpl.java x: 384 lines of code y: 7 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/NamedJob.java x: 355 lines of code y: 4 # changes mantis-control-plane/mantis-control-plane-dynamodb/src/main/java/io/mantisrx/extensions/dynamodb/DynamoDBClientSingleton.java x: 133 lines of code y: 3 # changes mantis-control-plane/mantis-control-plane-dynamodb/src/main/java/io/mantisrx/extensions/dynamodb/DynamoDBMasterMonitorSingleton.java x: 169 lines of code y: 4 # changes mantis-common/src/main/java/io/mantisrx/common/SystemParameters.java x: 23 lines of code y: 5 # changes mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/JobAutoScaler.java x: 545 lines of code y: 2 # changes mantis-jm-akka/src/main/java/io/mantisrx/server/worker/jobmaster/akka/rules/ScalerControllerActor.java x: 236 lines of code y: 2 # changes mantis-server/mantis-server-worker-client/src/main/java/io/mantisrx/server/worker/client/MetricsClientImpl.java x: 259 lines of code y: 3 # changes mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/JobMasterService.java x: 150 lines of code y: 2 # changes mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/WorkerMetricHandler.java x: 444 lines of code y: 2 # changes mantis-runtime-executor/src/main/java/io/mantisrx/server/worker/RunningWorker.java x: 314 lines of code y: 3 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/utils/JobRouteUtils.java x: 200 lines of code y: 5 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v0/JobClusterRoute.java x: 506 lines of code y: 4 # changes mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent/TaskExecutor.java x: 565 lines of code y: 25 # changes mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/DefaultSubscriptionTracker.java x: 126 lines of code y: 6 # changes mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/EventProcessor.java x: 120 lines of code y: 4 # changes mantis-runtime/src/main/java/io/mantisrx/runtime/parameter/ParameterUtils.java x: 294 lines of code y: 15 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker/WorkerState.java x: 94 lines of code y: 3 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/DisableTaskExecutorsRequest.java x: 48 lines of code y: 5 # changes mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/EventDrainer.java x: 103 lines of code y: 4 # changes mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/StreamManager.java x: 178 lines of code y: 6 # changes mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/api/Event.java x: 106 lines of code y: 5 # changes mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/discovery/mantisapi/DefaultMantisApiClient.java x: 115 lines of code y: 5 # changes mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/mql/MQL.java x: 47 lines of code y: 3 # changes mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/mql/MQLSubscription.java x: 129 lines of code y: 5 # changes mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core/MantisAkkaRpcSystemLoader.java x: 71 lines of code y: 4 # changes mantis-jm-akka/src/main/java/io/mantisrx/server/worker/jobmaster/akka/JobMasterServiceV2.java x: 34 lines of code y: 1 # changes mantis-jm-akka/src/main/java/io/mantisrx/server/worker/jobmaster/akka/rules/CoordinatorActor.java x: 222 lines of code y: 1 # changes mantis-jm-akka/src/main/java/io/mantisrx/server/worker/jobmaster/akka/rules/CustomRuleActor.java x: 126 lines of code y: 1 # changes mantis-jm-akka/src/main/java/io/mantisrx/server/worker/jobmaster/akka/rules/PerpetualRuleActor.java x: 28 lines of code y: 1 # changes mantis-jm-akka/src/main/java/io/mantisrx/server/worker/jobmaster/akka/rules/RuleUtils.java x: 53 lines of code y: 1 # changes mantis-jm-akka/src/main/java/io/mantisrx/server/worker/jobmaster/akka/rules/ScheduleRuleActor.java x: 138 lines of code y: 1 # changes mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/AutoScaleMetricsConfig.java x: 150 lines of code y: 1 # changes mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/JobAutoscalerManager.java x: 22 lines of code y: 1 # changes mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/JobMasterStageConfig.java x: 7 lines of code y: 1 # changes mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/WorkerMetricSubscription.java x: 64 lines of code y: 1 # changes mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/clutch/ClutchConfiguration.java x: 157 lines of code y: 1 # changes mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/clutch/experimental/MantisClutchConfigurationSelector.java x: 142 lines of code y: 1 # changes mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/clutch/rps/ClutchRpsPIDConfig.java x: 76 lines of code y: 1 # changes mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/clutch/rps/RpsClutchConfigurationSelector.java x: 116 lines of code y: 1 # changes mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/control/AdaptiveAutoscalerConfig.java x: 105 lines of code y: 1 # changes mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/control/utils/Derivative.java x: 16 lines of code y: 1 # changes mantis-runtime-executor/src/main/java/io/mantisrx/server/worker/WorkerExecutionOperationsNetworkStage.java x: 567 lines of code y: 10 # changes mantis-control-plane/mantis-control-plane-dynamodb/src/main/java/io/mantisrx/extensions/dynamodb/DynamoDBLeaderElector.java x: 141 lines of code y: 3 # changes mantis-control-plane/mantis-control-plane-dynamodb/src/main/java/io/mantisrx/extensions/dynamodb/DynamoDBConfig.java x: 48 lines of code y: 3 # changes mantis-network/src/main/java/io/reactivex/mantis/network/push/ConnectionManager.java x: 155 lines of code y: 2 # changes mantis-network/src/main/java/io/reactivex/mantis/network/push/PushServer.java x: 396 lines of code y: 9 # changes mantis-network/src/main/java/io/reactivex/mantis/network/push/LegacyTcpPushServer.java x: 135 lines of code y: 3 # changes mantis-network/src/main/java/io/reactivex/mantis/network/push/Routers.java x: 88 lines of code y: 3 # changes mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/ConnectToObservable.java x: 108 lines of code y: 2 # changes mantis-runtime-executor/src/main/java/io/mantisrx/server/worker/config/StaticPropertiesConfigurationFactory.java x: 20 lines of code y: 2 # changes mantis-runtime/src/main/java/io/mantisrx/runtime/executor/WorkerConsumerRemoteObservable.java x: 72 lines of code y: 3 # changes mantis-runtime/src/main/java/io/mantisrx/runtime/executor/WorkerPublisherRemoteObservable.java x: 181 lines of code y: 5 # changes mantis-common-akka/src/main/java/io/mantisrx/common/akka/ActorSystemMetrics.java x: 40 lines of code y: 1 # changes mantis-common-akka/src/main/java/io/mantisrx/common/akka/MeteredMessageQueue.java x: 60 lines of code y: 1 # changes mantis-common/src/main/java/io/mantisrx/common/metrics/LoggingMetricsPublisher.java x: 39 lines of code y: 2 # changes mantis-common/src/main/java/io/mantisrx/runtime/descriptor/JobScalingRule.java x: 91 lines of code y: 1 # changes mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/MantisMasterGateway.java x: 62 lines of code y: 2 # changes mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/master/resourcecluster/ClusterID.java x: 10 lines of code y: 2 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/IJobClustersManager.java x: 48 lines of code y: 4 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/handlers/JobDiscoveryRouteHandlerAkkaImpl.java x: 231 lines of code y: 6 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/utils/StreamingUtils.java x: 66 lines of code y: 3 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v0/JobDiscoveryRoute.java x: 224 lines of code y: 5 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/JobHelper.java x: 81 lines of code y: 3 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/BaseResponse.java x: 38 lines of code y: 2 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterScalerRuleProto.java x: 86 lines of code y: 1 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/proto/ResourceClusterAPIProto.java x: 72 lines of code y: 4 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/proto/ResourceClusterScaleRuleProto.java x: 82 lines of code y: 5 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/proto/UpgradeClusterContainersResponse.java x: 34 lines of code y: 3 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/persistence/IMantisPersistenceProvider.java x: 81 lines of code y: 10 # changes mantis-server/mantis-server-worker-client/src/main/java/io/mantisrx/server/worker/client/SseWorkerConnection.java x: 341 lines of code y: 15 # changes mantis-runtime/src/main/java/io/mantisrx/runtime/sink/ServerSentEventsSink.java x: 240 lines of code y: 7 # changes mantis-connectors/mantis-connector-job-source/src/main/java/io/mantisrx/connector/job/source/JobSource.java x: 281 lines of code y: 2 # changes mantis-runtime/src/main/java/io/mantisrx/runtime/parameter/SourceJobParameters.java x: 191 lines of code y: 5 # changes mantis-common/src/main/java/com/mantisrx/common/utils/MantisSSEConstants.java x: 18 lines of code y: 7 # changes mantis-network/src/main/java/io/reactivex/mantis/network/push/AsyncConnection.java x: 90 lines of code y: 2 # changes mantis-network/src/main/java/io/reactivex/mantis/network/push/PushServerSse.java x: 262 lines of code y: 13 # changes mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/RemoteObservable.java x: 577 lines of code y: 2 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker/MantisWorkerMetadataImpl.java x: 315 lines of code y: 4 # changes mantis-server/mantis-server-worker-client/src/main/java/io/mantisrx/server/worker/client/MantisHttpClientImpl.java x: 96 lines of code y: 5 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/ResourceClusterAwareScheduler.java x: 50 lines of code y: 7 # changes mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/resourcecluster/ResourceClusterGatewayClient.java x: 112 lines of code y: 6 # changes mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core/CoreConfiguration.java x: 50 lines of code y: 6 # changes mantis-runtime-loader/src/main/java/io/mantisrx/runtime/loader/config/WorkerConfiguration.java x: 128 lines of code y: 14 # changes mantis-runtime/src/main/java/io/mantisrx/runtime/ScalarToGroup.java x: 89 lines of code y: 6 # changes mantis-network/src/main/java/io/reactivex/mantis/network/push/ConsistentHashingRouter.java x: 103 lines of code y: 2 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/JobDefinitionResolver.java x: 152 lines of code y: 4 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/JobClusterConfig.java x: 117 lines of code y: 3 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/JobDefinition.java x: 341 lines of code y: 11 # changes mantis-runtime-loader/src/main/java/io/mantisrx/runtime/loader/config/WorkerConfigurationWritable.java x: 225 lines of code y: 10 # changes mantis-client/src/main/java/io/mantisrx/client/MantisClient.java x: 247 lines of code y: 8 # changes mantis-connectors/mantis-connector-job-source/src/main/java/io/mantisrx/connector/job/core/MantisSourceJobConnector.java x: 158 lines of code y: 2 # changes mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/HighAvailabilityServicesUtil.java x: 192 lines of code y: 10 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/events/WorkerMetricsCollector.java x: 186 lines of code y: 6 # changes mantis-control-plane/mantis-control-plane-dynamodb/src/main/java/io/mantisrx/extensions/dynamodb/DynamoDBStore.java x: 233 lines of code y: 3 # changes mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core/ExecuteStageRequest.java x: 109 lines of code y: 10 # changes mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core/domain/JobMetadata.java x: 44 lines of code y: 6 # changes mantis-runtime-loader/src/main/java/io/mantisrx/runtime/loader/RuntimeTask.java x: 10 lines of code y: 5 # changes mantis-common/src/main/java/io/mantisrx/runtime/descriptor/SchedulingInfo.java x: 205 lines of code y: 15 # changes mantis-common/src/main/java/io/mantisrx/runtime/descriptor/StageScalingPolicy.java x: 98 lines of code y: 12 # changes mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent/TaskExecutorStarter.java x: 156 lines of code y: 10 # changes mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/TestGetMasterMonitor.java x: 61 lines of code y: 4 # changes mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core/IKeyValueStore.java x: 78 lines of code y: 1 # changes mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core/master/LocalMasterMonitor.java x: 25 lines of code y: 2 # changes mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core/master/MasterMonitor.java x: 9 lines of code y: 3 # changes mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core/zookeeper/CuratorService.java x: 79 lines of code y: 6 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/zk/LeaderElector.java x: 132 lines of code y: 4 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/ILeadershipManager.java x: 4 lines of code y: 2 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/LeaderRedirectionFilter.java x: 87 lines of code y: 4 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/LeadershipManagerLocalImpl.java x: 43 lines of code y: 2 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/persistence/FileBasedPersistenceProvider.java x: 50 lines of code y: 2 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/FileBasedStore.java x: 137 lines of code y: 2 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/KeyValueStore.java x: 107 lines of code y: 4 # changes mantis-control-plane/mantis-control-plane-store/mantis-control-plane-store-dynamodb/src/main/java/io/mantisrx/server/master/store/DynamoStore.java x: 189 lines of code y: 2 # changes mantis-runtime-executor/src/main/java/io/mantisrx/server/worker/RuntimeTaskImpl.java x: 180 lines of code y: 3 # changes mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent/ResourceManagerGatewayCxn.java x: 213 lines of code y: 6 # changes mantis-runtime-executor/src/main/java/io/mantisrx/server/worker/ResourceUsagePayloadSetter.java x: 236 lines of code y: 3 # changes mantis-rxcontrol/src/main/java/io/mantisrx/control/clutch/Clutch.java x: 51 lines of code y: 1 # changes mantis-rxcontrol/src/main/java/io/mantisrx/control/clutch/ExperimentalControlLoop.java x: 112 lines of code y: 1 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/ResourceClustersNonLeaderRedirectRoute.java x: 422 lines of code y: 14 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/ScheduleRequest.java x: 46 lines of code y: 4 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/events/WorkerRegistryV2.java x: 137 lines of code y: 5 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClustersHostManagerActor.java x: 355 lines of code y: 9 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/events/StatusEventBrokerActor.java x: 109 lines of code y: 3 # changes mantis-common/src/main/java/io/mantisrx/common/WorkerConstants.java x: 10 lines of code y: 4 # changes mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/master/resourcecluster/TaskExecutorRegistration.java x: 134 lines of code y: 7 # changes mantis-runtime-executor/src/main/java/io/mantisrx/server/worker/Heartbeat.java x: 83 lines of code y: 1 # changes mantis-runtime-executor/src/main/java/io/mantisrx/server/worker/MantisWorker.java x: 209 lines of code y: 1 # changes mantis-runtime-loader/src/main/java/io/mantisrx/runtime/loader/cgroups/ProcFileReader.java x: 130 lines of code y: 1 # changes mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/discovery/MantisJobDiscoveryStaticImpl.java x: 81 lines of code y: 4 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/CompletedJobStore.java x: 245 lines of code y: 3 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterProto.java x: 182 lines of code y: 4 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/MantisJobMetadataWritable.java x: 207 lines of code y: 5 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/MantisStageMetadataWritable.java x: 188 lines of code y: 4 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterGatewayAkkaImpl.java x: 116 lines of code y: 8 # changes mantis-common/src/main/java/io/mantisrx/common/properties/DefaultMantisPropertiesLoader.java x: 19 lines of code y: 2 # changes mantis-client/src/main/java/io/mantisrx/client/SinkClientImpl.java x: 251 lines of code y: 4 # changes mantis-common/src/main/java/io/mantisrx/runtime/MantisJobState.java x: 85 lines of code y: 2 # changes mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/MasterClientWrapper.java x: 300 lines of code y: 6 # changes mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent/AgentV2Main.java x: 130 lines of code y: 6 # changes mantis-runtime/src/main/java/io/mantisrx/runtime/command/LoadValidateCreateZip.java x: 56 lines of code y: 4 # changes mantis-runtime/src/main/java/io/mantisrx/runtime/executor/SinkPublisher.java x: 99 lines of code y: 4 # changes mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent/HadoopFileSystemBlobStore.java x: 35 lines of code y: 6 # changes mantis-common/src/main/java/io/mantisrx/common/metrics/MetricsServer.java x: 142 lines of code y: 6 # changes mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/TaskStatusUpdateHandlerImpl.java x: 38 lines of code y: 5 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/proto/DisableTaskExecutorsRequest.java x: 14 lines of code y: 3 # changes mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/worker/TaskExecutorGateway.java x: 34 lines of code y: 8 # changes mantis-runtime/src/main/java/io/mantisrx/runtime/source/http/impl/HttpSourceImpl.java x: 550 lines of code y: 4 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/FilterableMantisJobMetadataWritable.java x: 44 lines of code y: 5 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/MantisJobMetadata.java x: 33 lines of code y: 3 # changes mantis-runtime/src/main/java/io/mantisrx/runtime/command/CreateJobDescriptorFile.java x: 116 lines of code y: 6 # changes mantis-runtime/src/main/java/io/mantisrx/runtime/parameter/type/EnumParameter.java x: 25 lines of code y: 4 # changes mantis-runtime/src/main/java/io/mantisrx/runtime/Context.java x: 72 lines of code y: 2 # changes mantis-runtime/src/main/java/io/mantisrx/runtime/Job.java x: 41 lines of code y: 3 # changes mantis-runtime/src/main/java/io/mantisrx/runtime/WorkerInfo.java x: 63 lines of code y: 5 # changes mantis-runtime/src/main/java/io/mantisrx/runtime/command/ReadJobFromJar.java x: 57 lines of code y: 3 # changes mantis-runtime/src/main/java/io/mantisrx/runtime/core/MantisGraph.java x: 31 lines of code y: 2 # changes mantis-runtime/src/main/java/io/mantisrx/runtime/core/MantisStreamImpl.java x: 178 lines of code y: 2 # changes mantis-runtime/src/main/java/io/mantisrx/runtime/executor/LocalJobExecutorNetworked.java x: 339 lines of code y: 5 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/config/ConfigurationFactory.java x: 4 lines of code y: 3 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/proto/UpgradeClusterContainersRequest.java x: 16 lines of code y: 5 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobArtifactsRoute.java x: 102 lines of code y: 3 # changes mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent/BlobStoreAwareClassLoaderHandle.java x: 94 lines of code y: 4 # changes mantis-connectors/mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer/config/CommitterConfig.java x: 23 lines of code y: 4 # changes mantis-connectors/mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/DefaultIcebergWriter.java x: 154 lines of code y: 11 # changes mantis-connectors/mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/IcebergWriterStage.java x: 266 lines of code y: 14 # changes mantis-connectors/mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/pool/FixedIcebergWriterPool.java x: 89 lines of code y: 5 # changes mantis-network/src/main/java/io/reactivex/mantis/network/push/MonitoredQueue.java x: 67 lines of code y: 2 # changes mantis-common/src/main/java/io/mantisrx/runtime/descriptor/StageSchedulingInfo.java x: 131 lines of code y: 11 # changes mantis-network/src/main/java/io/reactivex/mantis/network/push/ObservableTrigger.java x: 276 lines of code y: 4 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/handlers/ResourceClusterRouteHandler.java x: 31 lines of code y: 6 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/handlers/ResourceClusterRouteHandlerAkkaImpl.java x: 98 lines of code y: 7 # changes mantis-runtime/src/main/java/io/mantisrx/runtime/core/functions/FunctionCombinator.java x: 112 lines of code y: 2 # changes mantis-connectors/mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/MantisKafkaConsumerConfig.java x: 123 lines of code y: 3 # changes mantis-examples/mantis-examples-synthetic-sourcejob/src/main/java/io/mantisrx/sourcejob/synthetic/sink/TaggedEventFilter.java x: 60 lines of code y: 3 # changes mantis-discovery-proto/src/main/java/io/mantisrx/discovery/proto/AppJobClustersMap.java x: 120 lines of code y: 1 # changes mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/AbstractSubscriptionTracker.java x: 159 lines of code y: 8 # changes mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/discovery/MantisJobDiscoveryCachingImpl.java x: 166 lines of code y: 3 # changes mantis-publish/mantis-publish-netty/src/main/java/io/mantisrx/publish/netty/transmitters/ChoiceOfTwoWorkerPool.java x: 145 lines of code y: 3 # changes mantis-publish/mantis-publish-netty/src/main/java/io/mantisrx/publish/netty/transmitters/RoundRobinEventTransmitter.java x: 69 lines of code y: 3 # changes mantis-runtime/src/main/java/io/mantisrx/runtime/source/Source.java x: 19 lines of code y: 4 # changes mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core/BaseService.java x: 128 lines of code y: 3 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/MantisJobMetadataView.java x: 152 lines of code y: 3 # changes mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent/Hardware.java x: 198 lines of code y: 3 # changes mantis-common/src/main/java/io/mantisrx/common/storage/StorageUnit.java x: 390 lines of code y: 1 # changes mantis-examples/mantis-examples-synthetic-sourcejob/src/main/java/io/mantisrx/sourcejob/synthetic/stage/TaggingStage.java x: 111 lines of code y: 3 # changes mantis-common/src/main/java/io/mantisrx/common/WorkerPorts.java x: 102 lines of code y: 11 # changes mantis-network/src/main/java/io/reactivex/mantis/network/push/PushServers.java x: 77 lines of code y: 2 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/MantisWorkerMetadataWritable.java x: 283 lines of code y: 3 # changes mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/DynamicConnectionSet.java x: 266 lines of code y: 2 # changes mantis-common/src/main/java/io/mantisrx/common/compression/CompressionUtils.java x: 329 lines of code y: 8 # changes mantis-common/src/main/java/io/mantisrx/common/metrics/netty/HttpClientListener.java x: 180 lines of code y: 1 # changes mantis-common/src/main/java/io/mantisrx/common/metrics/netty/TcpClientListener.java x: 191 lines of code y: 1 # changes mantis-common/src/main/java/io/mantisrx/common/network/ServerSlotManager.java x: 173 lines of code y: 1 # changes mantis-common/src/main/java/io/reactivx/mantis/operators/BufferOnBackPressureOperator.java x: 201 lines of code y: 1 # changes mantis-common/src/main/java/io/reactivx/mantis/operators/OnSubscribeRedo.java x: 246 lines of code y: 1 # changes mantis-common/src/main/java/io/reactivx/mantis/operators/OperatorGroupBy.java x: 252 lines of code y: 1 # changes mantis-connectors/mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/KafkaData.java x: 95 lines of code y: 2 # changes mantis-connectors/mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/MantisKafkaConsumer.java x: 250 lines of code y: 2 # changes mantis-connectors/mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/MantisKafkaSourceConfig.java x: 127 lines of code y: 2 # changes mantis-connectors/mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/TopicPartitionStateManager.java x: 97 lines of code y: 2 # changes mantis-connectors/mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/metrics/ConsumerMetrics.java x: 131 lines of code y: 2 # changes mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/ConditionalRetry.java x: 58 lines of code y: 2 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/pagination/ListObject.java x: 219 lines of code y: 2 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v0/JobRoute.java x: 315 lines of code y: 2 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v0/MasterDescriptionRoute.java x: 140 lines of code y: 2 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/AdminMasterRoute.java x: 165 lines of code y: 2 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/WorkerResubmitRateLimiter.java x: 123 lines of code y: 2 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/WorkerRequest.java x: 170 lines of code y: 2 # changes mantis-network/src/main/java/io/reactivex/mantis/network/push/ConnectionGroup.java x: 97 lines of code y: 1 # changes mantis-network/src/main/java/io/reactivex/mantis/network/push/LegacyTcpPipelineConfigurator.java x: 198 lines of code y: 1 # changes mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/config/SampleArchaiusMrePublishConfiguration.java x: 340 lines of code y: 2 # changes mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/metrics/StreamMetrics.java x: 83 lines of code y: 3 # changes mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/RemoteObservableConnectionHandler.java x: 384 lines of code y: 1 # changes .baseline/idea/intellij-java-palantir-style.xml x: 476 lines of code y: 1 # changes
58.0
# changes
  min: 1.0
  average: 3.02
  25th percentile: 1.0
  median: 2.0
  75th percentile: 3.0
  max: 58.0
0 2641.0
lines of code
min: 1.0 | average: 91.34 | 25th percentile: 19.0 | median: 45.0 | 75th percentile: 100.0 | max: 2641.0

Number of Contributors vs. Number of Changes: 894 points

mantis-common/src/main/java/io/mantisrx/config/dynamic/DynamicProperty.java x: 2 # contributors y: 2 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/MasterApiAkkaService.java x: 9 # contributors y: 13 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/BaseRoute.java x: 4 # contributors y: 12 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobsRoute.java x: 4 # contributors y: 5 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/utils/ApiRequestRateLimiter.java x: 1 # contributors y: 1 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/MasterMain.java x: 12 # contributors y: 32 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/config/MasterConfiguration.java x: 12 # contributors y: 39 # changes mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/clutch/ClutchAutoScaler.java x: 1 # contributors y: 2 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/JobActor.java x: 10 # contributors y: 44 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/MantisJobClusterMetadataView.java x: 3 # contributors y: 4 # changes mantis-common/src/main/java/io/mantisrx/runtime/MantisJobDefinition.java x: 5 # contributors y: 8 # changes mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/MantisMasterClientApi.java x: 6 # contributors y: 13 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/MantisJobMetadataImpl.java x: 5 # contributors y: 10 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/MantisStageMetadataImpl.java x: 5 # contributors y: 7 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/JobClusterActor.java x: 9 # contributors y: 39 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ExecutorStateManagerActor.java x: 1 # contributors y: 4 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/JobClustersManagerActor.java x: 6 # contributors y: 12 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java x: 6 # contributors y: 14 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ReservationRegistryActor.java x: 1 # contributors y: 3 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterActorMetrics.java x: 3 # contributors y: 7 # changes mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/master/resourcecluster/TaskExecutorAllocationRequest.java x: 2 # contributors y: 6 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/ResourceClusterAwareSchedulerActor.java x: 4 # contributors y: 21 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterActor.java x: 6 # contributors y: 58 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClustersManagerActor.java x: 4 # contributors y: 25 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker/JobWorker.java x: 4 # contributors y: 8 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/persistence/KeyValueBasedPersistenceProvider.java x: 5 # contributors y: 18 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ExecutorStateManagerImpl.java x: 6 # contributors y: 24 # changes mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/master/resourcecluster/ResourceCluster.java x: 3 # contributors y: 22 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobProto.java x: 3 # contributors y: 3 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ExecutorStateManager.java x: 2 # contributors y: 7 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterAkkaImpl.java x: 3 # contributors y: 24 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterScalerActor.java x: 3 # contributors y: 14 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClustersAkkaImpl.java x: 2 # contributors y: 9 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/TaskExecutorState.java x: 2 # contributors y: 12 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/ExecuteStageRequestFactory.java x: 4 # contributors y: 6 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/MantisSchedulerFactory.java x: 2 # contributors y: 3 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/MantisSchedulerFactoryImpl.java x: 3 # contributors y: 9 # changes mantis-common/src/main/java/io/mantisrx/runtime/NamedJobDefinition.java x: 4 # contributors y: 4 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/proto/JobClusterProtoAdapter.java x: 6 # contributors y: 9 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/DataFormatAdapter.java x: 8 # contributors y: 17 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/JobClusterDefinitionImpl.java x: 6 # contributors y: 7 # changes mantis-common/src/main/java/io/mantisrx/common/SystemParameters.java x: 2 # contributors y: 5 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/utils/JobRouteUtils.java x: 3 # contributors y: 5 # changes mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent/TaskExecutor.java x: 7 # contributors y: 25 # changes mantis-runtime/src/main/java/io/mantisrx/runtime/parameter/ParameterUtils.java x: 11 # contributors y: 15 # changes mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/StreamManager.java x: 5 # contributors y: 6 # changes mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/api/Event.java x: 5 # contributors y: 5 # changes mantis-runtime-executor/src/main/java/io/mantisrx/server/worker/WorkerExecutionOperationsNetworkStage.java x: 4 # contributors y: 10 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/handlers/JobDiscoveryRouteHandlerAkkaImpl.java x: 3 # contributors y: 6 # changes mantis-common/src/main/java/com/mantisrx/common/utils/MantisSSEConstants.java x: 4 # contributors y: 7 # changes mantis-network/src/main/java/io/reactivex/mantis/network/push/PushServerSse.java x: 7 # contributors y: 13 # changes mantis-runtime-loader/src/main/java/io/mantisrx/runtime/loader/config/WorkerConfiguration.java x: 5 # contributors y: 14 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/JobDefinition.java x: 6 # contributors y: 11 # changes mantis-runtime-loader/src/main/java/io/mantisrx/runtime/loader/config/WorkerConfigurationWritable.java x: 7 # contributors y: 10 # changes mantis-common/src/main/java/io/mantisrx/runtime/descriptor/SchedulingInfo.java x: 5 # contributors y: 15 # changes mantis-common/src/main/java/io/mantisrx/runtime/descriptor/StageScalingPolicy.java x: 5 # contributors y: 12 # changes mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent/TaskExecutorStarter.java x: 6 # contributors y: 10 # changes mantis-common/src/main/java/io/mantisrx/common/WorkerConstants.java x: 2 # contributors y: 4 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterGatewayAkkaImpl.java x: 2 # contributors y: 8 # changes mantis-runtime/src/main/java/io/mantisrx/runtime/command/CreateJobDescriptorFile.java x: 6 # contributors y: 6 # changes mantis-runtime/src/main/java/io/mantisrx/runtime/executor/StageExecutors.java x: 8 # contributors y: 10 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/proto/UpgradeClusterContainersRequest.java x: 1 # contributors y: 5 # changes mantis-connectors/mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/DefaultIcebergWriter.java x: 4 # contributors y: 11 # changes mantis-runtime/src/main/java/io/mantisrx/runtime/scheduler/MantisRxSingleThreadScheduler.java x: 4 # contributors y: 3 # changes .baseline/idea/intellij-java-palantir-style.xml x: 2 # contributors y: 1 # changes
58.0
# changes
  min: 1.0
  average: 3.02
  25th percentile: 1.0
  median: 2.0
  75th percentile: 3.0
  max: 58.0
0 12.0
# contributors
min: 1.0 | average: 2.06 | 25th percentile: 1.0 | median: 2.0 | 75th percentile: 2.0 | max: 12.0

Number of Contributors vs. File Size: 894 points

mantis-common/src/main/java/io/mantisrx/config/dynamic/DynamicProperty.java x: 2 # contributors y: 55 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/MasterApiAkkaService.java x: 9 # contributors y: 297 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/BaseRoute.java x: 4 # contributors y: 366 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobsRoute.java x: 4 # contributors y: 505 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/utils/ApiRequestRateLimiter.java x: 1 # contributors y: 11 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/utils/ApiRequestRateLimiterFactory.java x: 1 # contributors y: 46 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/MasterMain.java x: 12 # contributors y: 254 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/config/MasterConfiguration.java x: 12 # contributors y: 281 lines of code mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/clutch/ClutchAutoScaler.java x: 1 # contributors y: 173 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/JobActor.java x: 10 # contributors y: 2213 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/MantisJobClusterMetadataView.java x: 3 # contributors y: 230 lines of code mantis-common/src/main/java/io/mantisrx/runtime/MantisJobDefinition.java x: 5 # contributors y: 289 lines of code mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/MantisMasterClientApi.java x: 6 # contributors y: 666 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/IWorkerManager.java x: 3 # contributors y: 41 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/MantisJobMetadataImpl.java x: 5 # contributors y: 409 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/MantisStageMetadataImpl.java x: 5 # contributors y: 466 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/JobClusterActor.java x: 9 # contributors y: 2641 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ExecutorStateManagerActor.java x: 1 # contributors y: 1143 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/JobClustersManagerActor.java x: 6 # contributors y: 962 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/handlers/JobClusterRouteHandler.java x: 4 # contributors y: 29 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/handlers/JobClusterRouteHandlerAkkaImpl.java x: 4 # contributors y: 148 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/HttpRequestMetrics.java x: 5 # contributors y: 107 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobClustersRoute.java x: 5 # contributors y: 629 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java x: 6 # contributors y: 1888 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ReservationRegistryActor.java x: 1 # contributors y: 604 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterActorMetrics.java x: 3 # contributors y: 88 lines of code mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/master/resourcecluster/TaskExecutorAllocationRequest.java x: 2 # contributors y: 25 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/ResourceClusterAwareSchedulerActor.java x: 4 # contributors y: 480 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterActor.java x: 6 # contributors y: 895 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClustersManagerActor.java x: 4 # contributors y: 295 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/persistence/KeyValueBasedPersistenceProvider.java x: 5 # contributors y: 863 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/persistence/MantisJobStore.java x: 5 # contributors y: 279 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ExecutorStateManagerImpl.java x: 6 # contributors y: 664 lines of code mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/master/resourcecluster/ResourceCluster.java x: 3 # contributors y: 118 lines of code mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/master/resourcecluster/ResourceClusters.java x: 2 # contributors y: 9 lines of code mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/master/resourcecluster/proto/MantisResourceClusterReservationProto.java x: 1 # contributors y: 146 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobProto.java x: 3 # contributors y: 170 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/AssignmentHandlerActor.java x: 1 # contributors y: 306 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterAkkaImpl.java x: 3 # contributors y: 338 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterScalerActor.java x: 3 # contributors y: 466 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClustersAkkaImpl.java x: 2 # contributors y: 88 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/TaskAssignmentManagerActor.java x: 1 # contributors y: 3 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/TaskExecutorState.java x: 2 # contributors y: 269 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/proto/GetClusterUsageResponse.java x: 1 # contributors y: 25 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/ExecuteStageRequestFactory.java x: 4 # contributors y: 65 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/MantisScheduler.java x: 5 # contributors y: 22 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/MantisSchedulerFactory.java x: 2 # contributors y: 18 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/MantisSchedulerFactoryImpl.java x: 3 # contributors y: 62 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/ResourceClusterReservationAwareScheduler.java x: 1 # contributors y: 70 lines of code mantis-common/src/main/java/io/mantisrx/runtime/JobPrincipal.java x: 1 # contributors y: 32 lines of code mantis-common/src/main/java/io/mantisrx/runtime/NamedJobDefinition.java x: 4 # contributors y: 38 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/proto/JobClusterProtoAdapter.java x: 6 # contributors y: 285 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/DataFormatAdapter.java x: 8 # contributors y: 681 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/IJobClusterDefinition.java x: 3 # contributors y: 22 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/JobClusterDefinitionImpl.java x: 6 # contributors y: 384 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/NamedJob.java x: 4 # contributors y: 355 lines of code mantis-control-plane/mantis-control-plane-dynamodb/src/main/java/io/mantisrx/extensions/dynamodb/DynamoDBClientSingleton.java x: 3 # contributors y: 133 lines of code mantis-control-plane/mantis-control-plane-dynamodb/src/main/java/io/mantisrx/extensions/dynamodb/DynamoDBMasterMonitorSingleton.java x: 4 # contributors y: 169 lines of code mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/JobAutoScaler.java x: 1 # contributors y: 545 lines of code mantis-jm-akka/src/main/java/io/mantisrx/server/worker/jobmaster/akka/rules/ScalerControllerActor.java x: 1 # contributors y: 236 lines of code mantis-server/mantis-server-worker-client/src/main/java/io/mantisrx/server/worker/client/MetricsClientImpl.java x: 3 # contributors y: 259 lines of code mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/WorkerMetricHandler.java x: 1 # contributors y: 444 lines of code mantis-runtime-executor/src/main/java/io/mantisrx/server/worker/RunningWorker.java x: 2 # contributors y: 314 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/utils/JobRouteUtils.java x: 3 # contributors y: 200 lines of code mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent/TaskExecutor.java x: 7 # contributors y: 565 lines of code mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/DefaultSubscriptionTracker.java x: 4 # contributors y: 126 lines of code mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/EventProcessor.java x: 4 # contributors y: 120 lines of code mantis-runtime/src/main/java/io/mantisrx/runtime/parameter/ParameterUtils.java x: 11 # contributors y: 294 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker/WorkerState.java x: 3 # contributors y: 94 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/DisableTaskExecutorsRequest.java x: 3 # contributors y: 48 lines of code mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/EventDrainer.java x: 4 # contributors y: 103 lines of code mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/StreamManager.java x: 5 # contributors y: 178 lines of code mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core/MantisAkkaRpcSystemLoader.java x: 3 # contributors y: 71 lines of code mantis-jm-akka/src/main/java/io/mantisrx/server/worker/jobmaster/akka/rules/CoordinatorActor.java x: 1 # contributors y: 222 lines of code mantis-jm-akka/src/main/java/io/mantisrx/server/worker/jobmaster/akka/rules/CustomRuleActor.java x: 1 # contributors y: 126 lines of code mantis-jm-akka/src/main/java/io/mantisrx/server/worker/jobmaster/akka/rules/RuleUtils.java x: 1 # contributors y: 53 lines of code mantis-jm-akka/src/main/java/io/mantisrx/server/worker/jobmaster/akka/rules/ScheduleRuleActor.java x: 1 # contributors y: 138 lines of code mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/clutch/ClutchConfiguration.java x: 1 # contributors y: 157 lines of code mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/clutch/rps/ClutchRpsPIDConfig.java x: 1 # contributors y: 76 lines of code mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/clutch/rps/RpsClutchConfigurationSelector.java x: 1 # contributors y: 116 lines of code mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/control/AdaptiveAutoscalerConfig.java x: 1 # contributors y: 105 lines of code mantis-runtime-executor/src/main/java/io/mantisrx/server/worker/WorkerExecutionOperationsNetworkStage.java x: 4 # contributors y: 567 lines of code mantis-control-plane/mantis-control-plane-dynamodb/src/main/java/io/mantisrx/extensions/dynamodb/DynamoDBLeaderElector.java x: 3 # contributors y: 141 lines of code mantis-network/src/main/java/io/reactivex/mantis/network/push/ConnectionManager.java x: 2 # contributors y: 155 lines of code mantis-network/src/main/java/io/reactivex/mantis/network/push/PushServer.java x: 6 # contributors y: 396 lines of code mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/ConnectToObservable.java x: 2 # contributors y: 108 lines of code mantis-runtime/src/main/java/io/mantisrx/runtime/executor/WorkerPublisherRemoteObservable.java x: 4 # contributors y: 181 lines of code mantis-common/src/main/java/io/mantisrx/runtime/descriptor/JobScalingRule.java x: 1 # contributors y: 91 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/handlers/JobDiscoveryRouteHandler.java x: 3 # contributors y: 15 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v0/JobDiscoveryRoute.java x: 3 # contributors y: 224 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/JobHelper.java x: 3 # contributors y: 81 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/BaseResponse.java x: 2 # contributors y: 38 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/proto/ResourceClusterScaleRuleProto.java x: 2 # contributors y: 82 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/persistence/IMantisPersistenceProvider.java x: 5 # contributors y: 81 lines of code mantis-server/mantis-server-worker-client/src/main/java/io/mantisrx/server/worker/client/SseWorkerConnection.java x: 11 # contributors y: 341 lines of code mantis-runtime/src/main/java/io/mantisrx/runtime/sink/ServerSentEventsSink.java x: 5 # contributors y: 240 lines of code mantis-connectors/mantis-connector-job-source/src/main/java/io/mantisrx/connector/job/core/AbstractSourceJobSource.java x: 2 # contributors y: 64 lines of code mantis-connectors/mantis-connector-job-source/src/main/java/io/mantisrx/connector/job/source/JobSource.java x: 2 # contributors y: 281 lines of code mantis-runtime/src/main/java/io/mantisrx/runtime/parameter/SourceJobParameters.java x: 5 # contributors y: 191 lines of code mantis-common/src/main/java/com/mantisrx/common/utils/MantisSSEConstants.java x: 4 # contributors y: 18 lines of code mantis-network/src/main/java/io/reactivex/mantis/network/push/PushServerSse.java x: 7 # contributors y: 262 lines of code mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/RemoteObservable.java x: 2 # contributors y: 577 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker/MantisWorkerMetadataImpl.java x: 3 # contributors y: 315 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/ResourceClusterAwareScheduler.java x: 4 # contributors y: 50 lines of code mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/resourcecluster/ResourceClusterGatewayClient.java x: 4 # contributors y: 112 lines of code mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core/CoreConfiguration.java x: 5 # contributors y: 50 lines of code mantis-runtime-loader/src/main/java/io/mantisrx/runtime/loader/config/WorkerConfiguration.java x: 5 # contributors y: 128 lines of code mantis-runtime/src/main/java/io/mantisrx/runtime/ScalarToGroup.java x: 5 # contributors y: 89 lines of code mantis-network/src/main/java/io/reactivex/mantis/network/push/ConsistentHashingRouter.java x: 2 # contributors y: 103 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/JobDefinition.java x: 6 # contributors y: 341 lines of code mantis-runtime-loader/src/main/java/io/mantisrx/runtime/loader/config/WorkerConfigurationWritable.java x: 7 # contributors y: 225 lines of code mantis-client/src/main/java/io/mantisrx/client/MantisClient.java x: 4 # contributors y: 247 lines of code mantis-connectors/mantis-connector-job-source/src/main/java/io/mantisrx/connector/job/core/MantisSourceJobConnector.java x: 2 # contributors y: 158 lines of code mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/HighAvailabilityServicesUtil.java x: 4 # contributors y: 192 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/events/WorkerMetricsCollector.java x: 2 # contributors y: 186 lines of code mantis-control-plane/mantis-control-plane-dynamodb/src/main/java/io/mantisrx/extensions/dynamodb/DynamoDBStore.java x: 2 # contributors y: 233 lines of code mantis-runtime-loader/src/main/java/io/mantisrx/runtime/loader/RuntimeTask.java x: 3 # contributors y: 10 lines of code mantis-common/src/main/java/io/mantisrx/runtime/descriptor/SchedulingInfo.java x: 5 # contributors y: 205 lines of code mantis-common/src/main/java/io/mantisrx/runtime/descriptor/StageScalingPolicy.java x: 5 # contributors y: 98 lines of code mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent/TaskExecutorStarter.java x: 6 # contributors y: 156 lines of code mantis-runtime-loader/src/main/java/io/mantisrx/runtime/loader/config/WorkerConfigurationUtils.java x: 5 # contributors y: 57 lines of code mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core/zookeeper/CuratorService.java x: 4 # contributors y: 79 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/LeadershipManagerLocalImpl.java x: 2 # contributors y: 43 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/FileBasedStore.java x: 2 # contributors y: 137 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/KeyValueStore.java x: 3 # contributors y: 107 lines of code mantis-control-plane/mantis-control-plane-store/mantis-control-plane-store-dynamodb/src/main/java/io/mantisrx/server/master/store/DynamoStore.java x: 2 # contributors y: 189 lines of code mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent/ResourceManagerGatewayCxn.java x: 3 # contributors y: 213 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/ResourceClustersNonLeaderRedirectRoute.java x: 3 # contributors y: 422 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClustersHostManagerActor.java x: 2 # contributors y: 355 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/MantisMasterRoute.java x: 4 # contributors y: 90 lines of code mantis-runtime-executor/src/main/java/io/mantisrx/server/worker/MantisWorker.java x: 1 # contributors y: 209 lines of code mantis-runtime-executor/src/main/java/io/mantisrx/server/worker/scheduling/JobSchedulingTracker.java x: 1 # contributors y: 95 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/CompletedJobStore.java x: 1 # contributors y: 245 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/MantisJobMetadataWritable.java x: 4 # contributors y: 207 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/MantisStageMetadataWritable.java x: 3 # contributors y: 188 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterGatewayAkkaImpl.java x: 2 # contributors y: 116 lines of code mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/MasterClientWrapper.java x: 5 # contributors y: 300 lines of code mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent/HadoopFileSystemBlobStore.java x: 5 # contributors y: 35 lines of code mantis-common/src/main/java/io/mantisrx/common/metrics/MetricsServer.java x: 5 # contributors y: 142 lines of code mantis-runtime/src/main/java/io/mantisrx/runtime/source/http/impl/HttpSourceImpl.java x: 2 # contributors y: 550 lines of code mantis-runtime/src/main/java/io/mantisrx/runtime/command/CreateJobDescriptorFile.java x: 6 # contributors y: 116 lines of code mantis-runtime/src/main/java/io/mantisrx/runtime/executor/StageExecutors.java x: 8 # contributors y: 406 lines of code mantis-runtime/src/main/java/io/mantisrx/runtime/executor/LocalJobExecutorNetworked.java x: 5 # contributors y: 339 lines of code mantis-connectors/mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/IcebergWriterStage.java x: 6 # contributors y: 266 lines of code mantis-network/src/main/java/io/reactivex/mantis/network/push/ObservableTrigger.java x: 3 # contributors y: 276 lines of code mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/AbstractSubscriptionTracker.java x: 5 # contributors y: 159 lines of code mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core/BaseService.java x: 2 # contributors y: 128 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/MantisJobMetadataView.java x: 3 # contributors y: 152 lines of code mantis-common/src/main/java/io/mantisrx/common/storage/StorageUnit.java x: 1 # contributors y: 390 lines of code mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/DynamicConnectionSet.java x: 1 # contributors y: 266 lines of code mantis-common/src/main/java/io/mantisrx/common/compression/CompressionUtils.java x: 5 # contributors y: 329 lines of code mantis-common/src/main/java/io/mantisrx/common/metrics/netty/HttpClientListener.java x: 1 # contributors y: 180 lines of code mantis-common/src/main/java/io/mantisrx/common/metrics/netty/TcpClientListener.java x: 1 # contributors y: 191 lines of code mantis-common/src/main/java/io/reactivx/mantis/operators/BufferOnBackPressureOperator.java x: 1 # contributors y: 201 lines of code mantis-common/src/main/java/io/reactivx/mantis/operators/OperatorGroupBy.java x: 1 # contributors y: 252 lines of code mantis-connectors/mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/MantisKafkaConsumer.java x: 2 # contributors y: 250 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/pagination/ListObject.java x: 2 # contributors y: 219 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/WorkerRequest.java x: 2 # contributors y: 170 lines of code mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/config/SampleArchaiusMrePublishConfiguration.java x: 2 # contributors y: 340 lines of code mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/RemoteObservableConnectionHandler.java x: 1 # contributors y: 384 lines of code .baseline/idea/intellij-java-palantir-style.xml x: 2 # contributors y: 476 lines of code
2641.0
lines of code
  min: 1.0
  average: 91.34
  25th percentile: 19.0
  median: 45.0
  75th percentile: 100.0
  max: 2641.0
0 12.0
# contributors
min: 1.0 | average: 2.06 | 25th percentile: 1.0 | median: 2.0 | 75th percentile: 2.0 | max: 12.0

Number of Changes vs. Line Churn: 3239 points

AGENTS.md x: 1 # changes y: 159 line churn mantis-common/src/main/java/io/mantisrx/config/dynamic/DynamicProperty.java x: 2 # changes y: 108 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/MasterApiAkkaService.java x: 13 # changes y: 713 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/BaseRoute.java x: 12 # changes y: 848 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobsRoute.java x: 5 # changes y: 1660 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/MasterMain.java x: 32 # changes y: 1293 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/config/MasterConfiguration.java x: 39 # changes y: 869 line churn mantis-control-plane/mantis-control-plane-server/src/test/java/io/mantisrx/master/api/akka/route/v0/JobRouteTest.java x: 12 # changes y: 1804 line churn mantis-control-plane/mantis-control-plane-server/src/test/java/io/mantisrx/master/api/akka/route/v1/JobsRouteTest.java x: 16 # changes y: 1590 line churn mantis-control-plane/mantis-control-plane-server/src/test/java/io/mantisrx/master/resourcecluster/TaskExecutorReconnectionIntegrationTest.java x: 5 # changes y: 374 line churn mantis-examples/mantis-examples-sine-function/dependencies.lock x: 12 # changes y: 2131 line churn mantis-runtime-autoscaler-api/build.gradle x: 3 # changes y: 45 line churn mantis-runtime-autoscaler-api/dependencies.lock x: 2 # changes y: 948 line churn mantis-runtime-executor/build.gradle x: 6 # changes y: 98 line churn mantis-runtime-executor/dependencies.lock x: 7 # changes y: 1665 line churn mantis-server/mantis-server-agent/dependencies.lock x: 18 # changes y: 2923 line churn mantis-source-jobs/mantis-source-job-publish/dependencies.lock x: 18 # changes y: 2483 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/JobActor.java x: 44 # changes y: 6945 line churn mantis-control-plane/mantis-control-plane-server/src/test/java/io/mantisrx/master/jobcluster/job/JobScaleUpDownTests.java x: 9 # changes y: 2321 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/MantisJobClusterMetadataView.java x: 4 # changes y: 569 line churn mantis-control-plane/mantis-control-plane-server/src/test/java/io/mantisrx/master/resourcecluster/ResourceClusterActorTest.java x: 37 # changes y: 1341 line churn mantis-common/src/main/java/io/mantisrx/runtime/MantisJobDefinition.java x: 8 # changes y: 170 line churn mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/MantisMasterClientApi.java x: 13 # changes y: 1759 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/IWorkerManager.java x: 4 # changes y: 245 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/MantisJobMetadataImpl.java x: 10 # changes y: 1145 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/MantisStageMetadataImpl.java x: 7 # changes y: 1448 line churn mantis-control-plane/mantis-control-plane-server/src/test/java/io/mantisrx/master/jobcluster/job/JobTestLifecycle.java x: 17 # changes y: 3156 line churn build.gradle x: 66 # changes y: 789 line churn mantis-discovery-proto/build.gradle x: 7 # changes y: 35 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/JobClusterActor.java x: 39 # changes y: 8619 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ExecutorStateManagerActor.java x: 4 # changes y: 1363 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java x: 14 # changes y: 4655 line churn mantis-control-plane/mantis-control-plane-server/src/test/java/io/mantisrx/master/api/akka/route/v1/JobClustersRouteTest.java x: 11 # changes y: 1885 line churn mantis-control-plane/mantis-control-plane-server/src/test/java/io/mantisrx/master/jobcluster/JobClusterAkkaTest.java x: 11 # changes y: 3712 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ReservationRegistryActor.java x: 3 # changes y: 763 line churn mantis-control-plane/mantis-control-plane-server/src/test/java/io/mantisrx/master/resourcecluster/ReservationRegistryActorIntegrationTest.java x: 2 # changes y: 501 line churn mantis-control-plane/mantis-control-plane-server/src/test/java/io/mantisrx/master/resourcecluster/ResourceClusterActorClusterUsageAkkaTest.java x: 7 # changes y: 521 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/ResourceClusterAwareSchedulerActor.java x: 21 # changes y: 850 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterActor.java x: 58 # changes y: 4206 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClustersManagerActor.java x: 25 # changes y: 436 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker/JobWorker.java x: 8 # changes y: 1676 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/persistence/KeyValueBasedPersistenceProvider.java x: 18 # changes y: 1237 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/persistence/MantisJobStore.java x: 18 # changes y: 1046 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ExecutorStateManagerImpl.java x: 24 # changes y: 1275 line churn .github/workflows/nebula-snapshot.yml x: 21 # changes y: 265 line churn .github/workflows/push-docker-image.yml x: 11 # changes y: 162 line churn context/archive/reservation/plan-reservation-scheduler-integration.md x: 1 # changes y: 983 line churn mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/master/resourcecluster/ResourceCluster.java x: 22 # changes y: 358 line churn mantis-control-plane/mantis-control-plane-server/build.gradle x: 31 # changes y: 297 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterAkkaImpl.java x: 24 # changes y: 499 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterScalerActor.java x: 14 # changes y: 942 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClustersAkkaImpl.java x: 9 # changes y: 169 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/TaskExecutorState.java x: 12 # changes y: 415 line churn mantis-control-plane/mantis-control-plane-server/src/test/java/io/mantisrx/master/events/WorkerRegistryV2Test.java x: 7 # changes y: 1094 line churn mantis-control-plane/mantis-control-plane-server/src/test/java/io/mantisrx/master/jobcluster/job/JobTestHelper.java x: 11 # changes y: 993 line churn mantis-control-plane/mantis-control-plane-server/src/test/java/io/mantisrx/master/jobcluster/job/JobTestMigrationTests.java x: 8 # changes y: 620 line churn mantis-control-plane/mantis-control-plane-server/src/test/java/io/mantisrx/master/resourcecluster/ExecutorStateManagerReservationUsageTests.java x: 1 # changes y: 509 line churn mantis-testcontainers/dependencies.lock x: 8 # changes y: 834 line churn .github/workflows/nebula-ci.yml x: 17 # changes y: 321 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/proto/JobClusterProtoAdapter.java x: 9 # changes y: 969 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/DataFormatAdapter.java x: 17 # changes y: 1923 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/NamedJob.java x: 4 # changes y: 2728 line churn .github/CODEOWNERS x: 19 # changes y: 56 line churn mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent/TaskExecutor.java x: 25 # changes y: 2332 line churn mantis-examples/mantis-examples-mantis-publish-sample/dependencies.lock x: 17 # changes y: 1055 line churn mantis-publish/mantis-publish-netty-guice/dependencies.lock x: 16 # changes y: 883 line churn mantis-examples/mantis-examples-mantis-publish-sample/build.gradle x: 13 # changes y: 253 line churn docs/mkdocs.yml x: 22 # changes y: 513 line churn mantis-runtime/src/main/java/io/mantisrx/runtime/parameter/ParameterUtils.java x: 15 # changes y: 214 line churn mantis-control-plane/mantis-control-plane-server/src/test/java/com/netflix/mantis/master/scheduler/TestHelpers.java x: 15 # changes y: 473 line churn gradlew x: 4 # changes y: 1031 line churn mantis-client/dependencies.lock x: 15 # changes y: 1651 line churn mantis-connectors/mantis-connector-job-source/dependencies.lock x: 3 # changes y: 1369 line churn mantis-connectors/mantis-connector-publish/dependencies.lock x: 17 # changes y: 1525 line churn mantis-control-plane/mantis-control-plane-client/build.gradle x: 10 # changes y: 92 line churn mantis-control-plane/mantis-control-plane-client/dependencies.lock x: 15 # changes y: 1249 line churn mantis-control-plane/mantis-control-plane-core/build.gradle x: 16 # changes y: 141 line churn mantis-control-plane/mantis-control-plane-server/dependencies.lock x: 16 # changes y: 1944 line churn mantis-examples/mantis-examples-jobconnector-sample/dependencies.lock x: 11 # changes y: 2389 line churn mantis-network/dependencies.lock x: 10 # changes y: 604 line churn mantis-publish/mantis-publish-core/src/test/java/io/mantisrx/publish/internal/discovery/MantisJobDiscoveryTest.java x: 5 # changes y: 434 line churn mantis-server/mantis-server-agent/build.gradle x: 24 # changes y: 183 line churn mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/StreamManager.java x: 6 # changes y: 630 line churn mantis-runtime-executor/src/main/java/io/mantisrx/server/worker/jobmaster/JobAutoScaler.java x: 10 # changes y: 1600 line churn mantis-runtime-executor/src/main/java/io/mantisrx/server/worker/jobmaster/WorkerMetricHandler.java x: 6 # changes y: 1112 line churn settings.gradle x: 30 # changes y: 323 line churn mantis-control-plane/mantis-control-plane-server/src/main/resources/application.conf x: 3 # changes y: 3602 line churn mantis-control-plane/mantis-control-plane-server/src/test/java/io/mantisrx/master/api/akka/route/v1/ResourceClusterNonLeaderRedirectRouteTest.java x: 14 # changes y: 546 line churn mantis-runtime-loader/src/main/java/io/mantisrx/runtime/loader/config/WorkerConfiguration.java x: 14 # changes y: 221 line churn mantis-connectors/mantis-connector-job/dependencies.lock x: 16 # changes y: 2684 line churn mantis-examples/mantis-examples-jobconnector-sample/build.gradle x: 12 # changes y: 88 line churn docs/docs/faq.md x: 8 # changes y: 1405 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClustersHostManagerActor.java x: 9 # changes y: 714 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/vm/AgentClusterOperationsImpl.java x: 5 # changes y: 972 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/SchedulingService.java x: 6 # changes y: 2118 line churn mantis-control-plane/mantis-control-plane-server/src/test/java/io/mantisrx/master/scheduler/AgentsErrorMonitorTest.java x: 3 # changes y: 989 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/mesos/VirtualMachineMasterServiceMesosImpl.java x: 11 # changes y: 1562 line churn mantis-server/mantis-server-worker/build.gradle x: 34 # changes y: 317 line churn mantis-server/mantis-server-worker/dependencies.lock x: 14 # changes y: 3212 line churn mantis-server/mantis-server-worker/src/main/java/io/mantisrx/server/worker/MantisWorker.java x: 18 # changes y: 712 line churn mantis-server/mantis-server-worker/src/main/java/io/mantisrx/server/worker/WorkerExecutionOperationsNetworkStage.java x: 23 # changes y: 1115 line churn mantis-server/mantis-server-worker/src/main/java/io/mantisrx/server/worker/jobmaster/JobAutoScaler.java x: 26 # changes y: 1230 line churn mantis-server/mantis-server-worker/src/main/java/io/mantisrx/server/worker/jobmaster/WorkerMetricHandler.java x: 17 # changes y: 664 line churn mantis-server/mantis-server-worker/src/test/java/io/mantisrx/server/worker/jobmaster/JobAutoScalerTest.java x: 11 # changes y: 798 line churn mantis-control-plane/mantis-control-plane-server/src/test/java/io/mantisrx/master/jobcluster/JobClusterTest.java x: 18 # changes y: 9395 line churn mantis-control-plane/mantis-control-plane-server/src/test/java/io/mantisrx/master/jobcluster/job/JobClusterManagerTest.java x: 12 # changes y: 4798 line churn mantis-connectors/mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/IcebergWriterStage.java x: 14 # changes y: 1455 line churn docs/docs/glossary.md x: 6 # changes y: 1707 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/persistence/SimpleCachedFileStorageProvider.java x: 5 # changes y: 2301 line churn mantis-server/mantis-server-worker/src/main/java/io/mantisrx/server/worker/TaskExecutor.java x: 11 # changes y: 2658 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/MantisJobMgr.java x: 2 # changes y: 4971 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/NamedJobs.java x: 2 # changes y: 1812 line churn mantis-publish/mantis-publish-core/src/test/java/io/mantisrx/publish/AbstractSubscriptionTrackerTest.java x: 6 # changes y: 1558 line churn temp-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/config/SampleArchaiusMrePublishConfiguration.java x: 1 # changes y: 1242 line churn temp-control-plane/client/src/main/java/io/mantisrx/server/master/client/MantisMasterClientApi.java x: 1 # changes y: 2307 line churn temp-control-plane/server/src/main/java/io/mantisrx/master/JobClustersManagerActor.java x: 1 # changes y: 3141 line churn temp-control-plane/server/src/main/java/io/mantisrx/master/api/akka/route/v0/JobClusterRoute.java x: 1 # changes y: 1830 line churn temp-control-plane/server/src/main/java/io/mantisrx/master/jobcluster/JobClusterActor.java x: 1 # changes y: 9834 line churn temp-control-plane/server/src/main/java/io/mantisrx/master/jobcluster/job/JobActor.java x: 1 # changes y: 7107 line churn temp-control-plane/server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java x: 1 # changes y: 6438 line churn temp-control-plane/server/src/main/java/io/mantisrx/server/master/MantisJobMgr.java x: 1 # changes y: 4971 line churn temp-control-plane/server/src/main/java/io/mantisrx/server/master/domain/DataFormatAdapter.java x: 1 # changes y: 2604 line churn temp-control-plane/server/src/main/resources/application.conf x: 1 # changes y: 5391 line churn temp-control-plane/server/src/test/java/io/mantisrx/master/jobcluster/JobClusterTest.java x: 1 # changes y: 7920 line churn temp-control-plane/server/src/test/java/io/mantisrx/master/jobcluster/job/JobClusterManagerTest.java x: 1 # changes y: 4560 line churn server/src/main/java/io/mantisrx/master/jobcluster/JobClusterActor.java x: 10 # changes y: 3534 line churn server/src/main/java/io/mantisrx/master/jobcluster/job/JobActor.java x: 9 # changes y: 2817 line churn server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java x: 4 # changes y: 2266 line churn server/src/test/java/io/mantisrx/master/jobcluster/JobClusterTest.java x: 8 # changes y: 3034 line churn server/src/test/java/io/mantisrx/master/jobcluster/job/JobClusterManagerTest.java x: 7 # changes y: 2139 line churn mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/IcebergWriterStage.java x: 23 # changes y: 2394 line churn mantis-examples/mantis-examples-wordcount/src/main/resources/illiad.txt x: 1 # changes y: 52350 line churn mantis-examples/mantis-publish-web-sample/src/main/java/com/netflix/mantis/examples/mantispublishsample/web/filter/CaptureRequestEventFilter.java x: 2 # changes y: 1296 line churn mantis-examples/wordcount/src/main/resources/illiad.txt x: 2 # changes y: 104700 line churn docs/docs/developing/api/index.md x: 3 # changes y: 8408 line churn docs/docs/reference/api.md x: 2 # changes y: 4480 line churn mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/BaseIcebergWriter.java x: 13 # changes y: 830 line churn docs/docs/MQL/operators.md x: 3 # changes y: 2148 line churn docs/docs/autoscaling.md x: 4 # changes y: 1974 line churn docs/docs/capacity.md x: 3 # changes y: 1736 line churn docs/docs/mantisapi/index.md x: 5 # changes y: 9372 line churn docs/docs/gettingstarted.md x: 5 # changes y: 1543 line churn docs/mantisapi/index.md x: 1 # changes y: 6648 line churn
104700.0
line churn
  min: 1.0
  average: 378.83
  25th percentile: 64.0
  median: 153.0
  75th percentile: 351.0
  max: 104700.0
0 66.0
# changes
min: 1.0 | average: 2.7 | 25th percentile: 1.0 | median: 2.0 | 75th percentile: 3.0 | max: 66.0

Number of Contributors vs. Line Churn: 894 points

mantis-common/src/main/java/io/mantisrx/config/dynamic/DynamicProperty.java x: 2 # contributors y: 108 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/MasterApiAkkaService.java x: 9 # contributors y: 713 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/BaseRoute.java x: 4 # contributors y: 848 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobsRoute.java x: 4 # contributors y: 1660 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/utils/ApiRequestRateLimiter.java x: 1 # contributors y: 81 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/utils/ApiRequestRateLimiterFactory.java x: 1 # contributors y: 104 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/MasterMain.java x: 12 # contributors y: 1293 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/config/MasterConfiguration.java x: 12 # contributors y: 869 line churn mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/clutch/ClutchAutoScaler.java x: 1 # contributors y: 274 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/JobActor.java x: 10 # contributors y: 6945 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/MantisJobClusterMetadataView.java x: 3 # contributors y: 569 line churn mantis-common/src/main/java/io/mantisrx/runtime/MantisJobDefinition.java x: 5 # contributors y: 170 line churn mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/MantisMasterClientApi.java x: 6 # contributors y: 1759 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/IWorkerManager.java x: 3 # contributors y: 245 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/MantisJobMetadataImpl.java x: 5 # contributors y: 1145 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/MantisStageMetadataImpl.java x: 5 # contributors y: 1448 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/JobClusterActor.java x: 9 # contributors y: 8619 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ExecutorStateManagerActor.java x: 1 # contributors y: 1363 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/JobClustersManagerActor.java x: 6 # contributors y: 2448 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/handlers/JobClusterRouteHandler.java x: 4 # contributors y: 118 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/handlers/JobClusterRouteHandlerAkkaImpl.java x: 4 # contributors y: 343 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/HttpRequestMetrics.java x: 5 # contributors y: 270 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobClustersRoute.java x: 5 # contributors y: 1516 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java x: 6 # contributors y: 4655 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ReservationRegistryActor.java x: 1 # contributors y: 763 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterActorMetrics.java x: 3 # contributors y: 180 line churn mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/master/resourcecluster/TaskExecutorAllocationRequest.java x: 2 # contributors y: 79 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/ResourceClusterAwareSchedulerActor.java x: 4 # contributors y: 850 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterActor.java x: 6 # contributors y: 4206 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClustersManagerActor.java x: 4 # contributors y: 436 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker/JobWorker.java x: 4 # contributors y: 1676 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/persistence/KeyValueBasedPersistenceProvider.java x: 5 # contributors y: 1237 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/persistence/MantisJobStore.java x: 5 # contributors y: 1046 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ExecutorStateManagerImpl.java x: 6 # contributors y: 1275 line churn mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/master/resourcecluster/ResourceCluster.java x: 3 # contributors y: 358 line churn mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/master/resourcecluster/ResourceClusters.java x: 2 # contributors y: 39 line churn mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/master/resourcecluster/proto/MantisResourceClusterReservationProto.java x: 1 # contributors y: 219 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/AssignmentHandlerActor.java x: 1 # contributors y: 361 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ExecutorStateManager.java x: 2 # contributors y: 146 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterAkkaImpl.java x: 3 # contributors y: 499 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterScalerActor.java x: 3 # contributors y: 942 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/TaskAssignmentManagerActor.java x: 1 # contributors y: 20 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/TaskExecutorState.java x: 2 # contributors y: 415 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/proto/GetClusterUsageResponse.java x: 1 # contributors y: 59 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/ExecuteStageRequestFactory.java x: 4 # contributors y: 96 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/MantisScheduler.java x: 5 # contributors y: 366 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/MantisSchedulerFactoryImpl.java x: 3 # contributors y: 213 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/Jackson.java x: 4 # contributors y: 397 line churn mantis-common/src/main/java/io/mantisrx/runtime/NamedJobDefinition.java x: 4 # contributors y: 27 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/proto/JobClusterProtoAdapter.java x: 6 # contributors y: 969 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/DataFormatAdapter.java x: 8 # contributors y: 1923 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/IJobClusterDefinition.java x: 3 # contributors y: 111 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/NamedJob.java x: 4 # contributors y: 2728 line churn mantis-control-plane/mantis-control-plane-dynamodb/src/main/java/io/mantisrx/extensions/dynamodb/DynamoDBMasterMonitorSingleton.java x: 4 # contributors y: 226 line churn mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/JobAutoScaler.java x: 1 # contributors y: 636 line churn mantis-server/mantis-server-worker-client/src/main/java/io/mantisrx/server/worker/client/MetricsClientImpl.java x: 3 # contributors y: 29 line churn mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/WorkerMetricHandler.java x: 1 # contributors y: 551 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/utils/JobRouteUtils.java x: 3 # contributors y: 381 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v0/JobClusterRoute.java x: 4 # contributors y: 1391 line churn mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent/TaskExecutor.java x: 7 # contributors y: 2332 line churn mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/EventProcessor.java x: 4 # contributors y: 468 line churn mantis-runtime/src/main/java/io/mantisrx/runtime/parameter/ParameterUtils.java x: 11 # contributors y: 214 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/DisableTaskExecutorsRequest.java x: 3 # contributors y: 86 line churn mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/EventDrainer.java x: 4 # contributors y: 296 line churn mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/StreamManager.java x: 5 # contributors y: 630 line churn mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/api/Event.java x: 5 # contributors y: 308 line churn mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/mql/MQL.java x: 3 # contributors y: 160 line churn mantis-jm-akka/src/main/java/io/mantisrx/server/worker/jobmaster/akka/rules/CustomRuleActor.java x: 1 # contributors y: 156 line churn mantis-jm-akka/src/main/java/io/mantisrx/server/worker/jobmaster/akka/rules/ScheduleRuleActor.java x: 1 # contributors y: 198 line churn mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/clutch/experimental/MantisClutchConfigurationSelector.java x: 1 # contributors y: 242 line churn mantis-network/src/main/java/io/reactivex/mantis/network/push/ConnectionManager.java x: 2 # contributors y: 13 line churn mantis-network/src/main/java/io/reactivex/mantis/network/push/PushServer.java x: 6 # contributors y: 134 line churn mantis-runtime/src/main/java/io/mantisrx/runtime/executor/WorkerConsumerRemoteObservable.java x: 3 # contributors y: 43 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/handlers/JobDiscoveryRouteHandlerAkkaImpl.java x: 3 # contributors y: 535 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/JobHelper.java x: 3 # contributors y: 298 line churn mantis-server/mantis-server-worker-client/src/main/java/io/mantisrx/server/worker/client/SseWorkerConnection.java x: 11 # contributors y: 241 line churn mantis-runtime/src/main/java/io/mantisrx/runtime/sink/ServerSentEventsSink.java x: 5 # contributors y: 117 line churn mantis-connectors/mantis-connector-job-source/src/main/java/io/mantisrx/connector/job/source/JobSource.java x: 2 # contributors y: 385 line churn mantis-network/src/main/java/io/reactivex/mantis/network/push/PushServerSse.java x: 7 # contributors y: 153 line churn mantis-control-plane/mantis-control-plane-dynamodb/src/main/java/io/mantisrx/extensions/dynamodb/DynamoDBMasterMonitor.java x: 3 # contributors y: 415 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker/IMantisWorkerMetadata.java x: 3 # contributors y: 466 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker/MantisWorkerMetadataImpl.java x: 3 # contributors y: 884 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/ResourceClusterAwareScheduler.java x: 4 # contributors y: 178 line churn mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/resourcecluster/ResourceClusterGatewayClient.java x: 4 # contributors y: 167 line churn mantis-runtime-loader/src/main/java/io/mantisrx/runtime/loader/config/WorkerConfiguration.java x: 5 # contributors y: 221 line churn mantis-runtime/src/main/java/io/mantisrx/runtime/GroupToScalar.java x: 5 # contributors y: 86 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/SLAEnforcer.java x: 3 # contributors y: 310 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/JobDefinitionResolver.java x: 4 # contributors y: 655 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/JobDefinition.java x: 6 # contributors y: 876 line churn mantis-runtime-loader/src/main/java/io/mantisrx/runtime/loader/config/WorkerConfigurationWritable.java x: 7 # contributors y: 309 line churn mantis-connectors/mantis-connector-job-source/src/main/java/io/mantisrx/connector/job/core/MantisSourceJobConnector.java x: 2 # contributors y: 220 line churn mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/HighAvailabilityServicesUtil.java x: 4 # contributors y: 314 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/events/WorkerMetricsCollector.java x: 2 # contributors y: 247 line churn mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core/ExecuteStageRequest.java x: 5 # contributors y: 587 line churn mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent/TaskExecutorStarter.java x: 6 # contributors y: 608 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/FileBasedStore.java x: 2 # contributors y: 182 line churn mantis-control-plane/mantis-control-plane-store/mantis-control-plane-store-dynamodb/src/main/java/io/mantisrx/server/master/store/DynamoStore.java x: 2 # contributors y: 285 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/ResourceClustersNonLeaderRedirectRoute.java x: 3 # contributors y: 659 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/ScheduleRequest.java x: 4 # contributors y: 617 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClustersHostManagerActor.java x: 2 # contributors y: 714 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/CompletedJobStore.java x: 1 # contributors y: 391 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterProto.java x: 2 # contributors y: 630 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/MantisJobMetadataWritable.java x: 4 # contributors y: 727 line churn mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/MasterClientWrapper.java x: 5 # contributors y: 1007 line churn mantis-common/src/main/java/io/mantisrx/common/metrics/MetricsServer.java x: 5 # contributors y: 42 line churn mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/TaskStatusUpdateHandlerImpl.java x: 4 # contributors y: 266 line churn mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/worker/TaskExecutorGateway.java x: 5 # contributors y: 136 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/events/LifecycleEventsProto.java x: 3 # contributors y: 762 line churn mantis-runtime/src/main/java/io/mantisrx/runtime/command/CreateJobDescriptorFile.java x: 6 # contributors y: 53 line churn mantis-runtime/src/main/java/io/mantisrx/runtime/executor/StageExecutors.java x: 8 # contributors y: 264 line churn mantis-runtime/src/main/java/io/mantisrx/runtime/ScalarToScalar.java x: 4 # contributors y: 62 line churn mantis-runtime/src/main/java/io/mantisrx/runtime/descriptor/JobInfo.java x: 5 # contributors y: 25 line churn mantis-runtime/src/main/java/io/mantisrx/runtime/sink/ServerSentEventRequestHandler.java x: 6 # contributors y: 227 line churn mantis-connectors/mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/DefaultIcebergWriter.java x: 4 # contributors y: 534 line churn mantis-connectors/mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/IcebergWriterStage.java x: 6 # contributors y: 1455 line churn mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/AbstractSubscriptionTracker.java x: 5 # contributors y: 1278 line churn mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/discovery/MantisJobDiscoveryCachingImpl.java x: 2 # contributors y: 451 line churn mantis-publish/mantis-publish-netty/src/main/java/io/mantisrx/publish/netty/pipeline/HttpEventChannel.java x: 2 # contributors y: 323 line churn mantis-publish/mantis-publish-netty/src/main/java/io/mantisrx/publish/netty/transmitters/ChoiceOfTwoWorkerPool.java x: 2 # contributors y: 579 line churn mantis-common/src/main/java/io/mantisrx/common/storage/StorageUnit.java x: 1 # contributors y: 529 line churn mantis-connectors/mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/KafkaSource.java x: 2 # contributors y: 790 line churn mantis-common/src/main/java/io/mantisrx/common/compression/CompressionUtils.java x: 5 # contributors y: 277 line churn mantis-connectors/mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/MantisKafkaConsumer.java x: 2 # contributors y: 697 line churn mantis-connectors/mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/MantisKafkaSourceConfig.java x: 2 # contributors y: 347 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/JobListHelperActor.java x: 2 # contributors y: 558 line churn mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/config/SampleArchaiusMrePublishConfiguration.java x: 2 # contributors y: 834 line churn mantis-publish/mantis-publish-netty/src/main/java/io/mantisrx/publish/netty/pipeline/MantisEventAggregator.java x: 2 # contributors y: 525 line churn .baseline/idea/intellij-java-palantir-style.xml x: 2 # contributors y: 952 line churn
8619.0
line churn
  min: 1.0
  average: 205.24
  25th percentile: 36.0
  median: 93.0
  75th percentile: 212.25
  max: 8619.0
0 12.0
# contributors
min: 1.0 | average: 2.06 | 25th percentile: 1.0 | median: 2.0 | 75th percentile: 2.0 | max: 12.0

File Size vs. Line Churn: 894 points

mantis-common/src/main/java/io/mantisrx/config/dynamic/DynamicProperty.java x: 55 lines of code y: 108 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/MasterApiAkkaService.java x: 297 lines of code y: 713 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/BaseRoute.java x: 366 lines of code y: 848 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobsRoute.java x: 505 lines of code y: 1660 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/utils/ApiRequestRateLimiter.java x: 11 lines of code y: 81 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/utils/ApiRequestRateLimiterFactory.java x: 46 lines of code y: 104 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/MasterMain.java x: 254 lines of code y: 1293 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/config/MasterConfiguration.java x: 281 lines of code y: 869 line churn mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/clutch/ClutchAutoScaler.java x: 173 lines of code y: 274 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/JobActor.java x: 2213 lines of code y: 6945 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/MantisJobClusterMetadataView.java x: 230 lines of code y: 569 line churn mantis-common/src/main/java/io/mantisrx/runtime/MantisJobDefinition.java x: 289 lines of code y: 170 line churn mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/MantisMasterClientApi.java x: 666 lines of code y: 1759 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/IWorkerManager.java x: 41 lines of code y: 245 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/MantisJobMetadataImpl.java x: 409 lines of code y: 1145 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/MantisStageMetadataImpl.java x: 466 lines of code y: 1448 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/JobClusterActor.java x: 2641 lines of code y: 8619 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ExecutorStateManagerActor.java x: 1143 lines of code y: 1363 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/JobClustersManagerActor.java x: 962 lines of code y: 2448 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/handlers/JobClusterRouteHandler.java x: 29 lines of code y: 118 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/handlers/JobClusterRouteHandlerAkkaImpl.java x: 148 lines of code y: 343 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/HttpRequestMetrics.java x: 107 lines of code y: 270 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobClustersRoute.java x: 629 lines of code y: 1516 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java x: 1888 lines of code y: 4655 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ReservationRegistryActor.java x: 604 lines of code y: 763 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterActorMetrics.java x: 88 lines of code y: 180 line churn mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/master/resourcecluster/TaskExecutorAllocationRequest.java x: 25 lines of code y: 79 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/ResourceClusterAwareSchedulerActor.java x: 480 lines of code y: 850 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterActor.java x: 895 lines of code y: 4206 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClustersManagerActor.java x: 295 lines of code y: 436 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker/JobWorker.java x: 509 lines of code y: 1676 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/persistence/KeyValueBasedPersistenceProvider.java x: 863 lines of code y: 1237 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/persistence/MantisJobStore.java x: 279 lines of code y: 1046 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ExecutorStateManagerImpl.java x: 664 lines of code y: 1275 line churn mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/master/resourcecluster/ResourceCluster.java x: 118 lines of code y: 358 line churn mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/master/resourcecluster/ResourceClusters.java x: 9 lines of code y: 39 line churn mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/master/resourcecluster/proto/MantisResourceClusterReservationProto.java x: 146 lines of code y: 219 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobProto.java x: 170 lines of code y: 364 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/AssignmentHandlerActor.java x: 306 lines of code y: 361 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ExecutorStateManager.java x: 55 lines of code y: 146 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterAkkaImpl.java x: 338 lines of code y: 499 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterScalerActor.java x: 466 lines of code y: 942 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClustersAkkaImpl.java x: 88 lines of code y: 169 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/TaskAssignmentManagerActor.java x: 3 lines of code y: 20 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/TaskExecutorState.java x: 269 lines of code y: 415 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/proto/GetClusterUsageResponse.java x: 25 lines of code y: 59 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/ExecuteStageRequestFactory.java x: 65 lines of code y: 96 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/MantisScheduler.java x: 22 lines of code y: 366 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/MantisSchedulerFactory.java x: 18 lines of code y: 56 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/MantisSchedulerFactoryImpl.java x: 62 lines of code y: 213 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/ResourceClusterReservationAwareScheduler.java x: 70 lines of code y: 119 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/Jackson.java x: 149 lines of code y: 397 line churn mantis-common/src/main/java/io/mantisrx/runtime/JobPrincipal.java x: 32 lines of code y: 57 line churn mantis-common/src/main/java/io/mantisrx/runtime/NamedJobDefinition.java x: 38 lines of code y: 27 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/proto/JobClusterProtoAdapter.java x: 285 lines of code y: 969 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/DataFormatAdapter.java x: 681 lines of code y: 1923 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/IJobClusterDefinition.java x: 22 lines of code y: 111 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/JobClusterDefinitionImpl.java x: 384 lines of code y: 965 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/NamedJob.java x: 355 lines of code y: 2728 line churn mantis-control-plane/mantis-control-plane-dynamodb/src/main/java/io/mantisrx/extensions/dynamodb/DynamoDBClientSingleton.java x: 133 lines of code y: 173 line churn mantis-control-plane/mantis-control-plane-dynamodb/src/main/java/io/mantisrx/extensions/dynamodb/DynamoDBMasterMonitorSingleton.java x: 169 lines of code y: 226 line churn mantis-common/src/main/java/io/mantisrx/common/SystemParameters.java x: 23 lines of code y: 48 line churn mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/JobAutoScaler.java x: 545 lines of code y: 636 line churn mantis-jm-akka/src/main/java/io/mantisrx/server/worker/jobmaster/akka/rules/ScalerControllerActor.java x: 236 lines of code y: 278 line churn mantis-server/mantis-server-worker-client/src/main/java/io/mantisrx/server/worker/client/MetricsClientImpl.java x: 259 lines of code y: 29 line churn mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/JobMasterService.java x: 150 lines of code y: 207 line churn mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/WorkerMetricHandler.java x: 444 lines of code y: 551 line churn mantis-runtime-executor/src/main/java/io/mantisrx/server/worker/RunningWorker.java x: 314 lines of code y: 420 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/utils/JobRouteUtils.java x: 200 lines of code y: 381 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v0/JobClusterRoute.java x: 506 lines of code y: 1391 line churn mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent/TaskExecutor.java x: 565 lines of code y: 2332 line churn mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/DefaultSubscriptionTracker.java x: 126 lines of code y: 363 line churn mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/EventProcessor.java x: 120 lines of code y: 468 line churn mantis-runtime/src/main/java/io/mantisrx/runtime/parameter/ParameterUtils.java x: 294 lines of code y: 214 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker/WorkerState.java x: 94 lines of code y: 405 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/DisableTaskExecutorsRequest.java x: 48 lines of code y: 86 line churn mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/EventDrainer.java x: 103 lines of code y: 296 line churn mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/StreamManager.java x: 178 lines of code y: 630 line churn mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/api/Event.java x: 106 lines of code y: 308 line churn mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/discovery/mantisapi/DefaultMantisApiClient.java x: 115 lines of code y: 412 line churn mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/mql/MQL.java x: 47 lines of code y: 160 line churn mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/mql/MQLSubscription.java x: 129 lines of code y: 436 line churn mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core/MantisAkkaRpcSystemLoader.java x: 71 lines of code y: 191 line churn mantis-jm-akka/src/main/java/io/mantisrx/server/worker/jobmaster/akka/JobMasterServiceV2.java x: 34 lines of code y: 59 line churn mantis-jm-akka/src/main/java/io/mantisrx/server/worker/jobmaster/akka/rules/CoordinatorActor.java x: 222 lines of code y: 282 line churn mantis-jm-akka/src/main/java/io/mantisrx/server/worker/jobmaster/akka/rules/CustomRuleActor.java x: 126 lines of code y: 156 line churn mantis-jm-akka/src/main/java/io/mantisrx/server/worker/jobmaster/akka/rules/RuleUtils.java x: 53 lines of code y: 63 line churn mantis-jm-akka/src/main/java/io/mantisrx/server/worker/jobmaster/akka/rules/ScheduleRuleActor.java x: 138 lines of code y: 198 line churn mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/JobMasterStageConfig.java x: 7 lines of code y: 27 line churn mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/MetricAggregator.java x: 55 lines of code y: 84 line churn mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/clutch/ClutchConfiguration.java x: 157 lines of code y: 196 line churn mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/clutch/ClutchControllerOutput.java x: 10 lines of code y: 31 line churn mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/clutch/experimental/MantisClutchConfigurationSelector.java x: 142 lines of code y: 242 line churn mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/clutch/rps/ClutchRpsPIDConfig.java x: 76 lines of code y: 132 line churn mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/clutch/rps/RpsClutchConfigurationSelector.java x: 116 lines of code y: 157 line churn mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/control/AdaptiveAutoscalerConfig.java x: 105 lines of code y: 144 line churn mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/control/controllers/PIDController.java x: 38 lines of code y: 87 line churn mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/control/utils/TransformerWrapper.java x: 12 lines of code y: 38 line churn mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/rules/CustomRuleTriggerHandler.java x: 19 lines of code y: 28 line churn mantis-runtime-executor/src/main/java/io/mantisrx/server/worker/WorkerExecutionOperationsNetworkStage.java x: 567 lines of code y: 816 line churn mantis-control-plane/mantis-control-plane-dynamodb/src/main/java/io/mantisrx/extensions/dynamodb/DynamoDBLeaderElector.java x: 141 lines of code y: 189 line churn mantis-network/src/main/java/io/reactivex/mantis/network/push/ConnectionManager.java x: 155 lines of code y: 13 line churn mantis-network/src/main/java/io/reactivex/mantis/network/push/PushServer.java x: 396 lines of code y: 134 line churn mantis-network/src/main/java/io/reactivex/mantis/network/push/LegacyTcpPushServer.java x: 135 lines of code y: 27 line churn mantis-network/src/main/java/io/reactivex/mantis/network/push/Routers.java x: 88 lines of code y: 17 line churn mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/ConnectToObservable.java x: 108 lines of code y: 8 line churn mantis-runtime/src/main/java/io/mantisrx/runtime/executor/WorkerConsumerRemoteObservable.java x: 72 lines of code y: 43 line churn mantis-runtime/src/main/java/io/mantisrx/runtime/executor/WorkerPublisherRemoteObservable.java x: 181 lines of code y: 305 line churn mantis-common-akka/src/main/java/io/mantisrx/common/akka/ActorSystemMetrics.java x: 40 lines of code y: 81 line churn mantis-common-akka/src/main/java/io/mantisrx/common/akka/DeadLetterActor.java x: 44 lines of code y: 66 line churn mantis-common-akka/src/main/java/io/mantisrx/common/akka/MeteredMessageQueue.java x: 60 lines of code y: 131 line churn mantis-common/src/main/java/io/mantisrx/common/metrics/LoggingMetricsPublisher.java x: 39 lines of code y: 67 line churn mantis-common/src/main/java/io/mantisrx/runtime/descriptor/JobScalingRule.java x: 91 lines of code y: 122 line churn mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/MantisMasterGateway.java x: 62 lines of code y: 117 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/IJobClustersManager.java x: 48 lines of code y: 209 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/handlers/JobDiscoveryRouteHandler.java x: 15 lines of code y: 73 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/handlers/JobDiscoveryRouteHandlerAkkaImpl.java x: 231 lines of code y: 535 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/utils/StreamingUtils.java x: 66 lines of code y: 189 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v0/JobDiscoveryRoute.java x: 224 lines of code y: 478 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/JobHelper.java x: 81 lines of code y: 298 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/BaseResponse.java x: 38 lines of code y: 127 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterScalerRuleProto.java x: 86 lines of code y: 102 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/scaler/JobClusterScalerRuleDataImplWritable.java x: 67 lines of code y: 82 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/proto/ResourceClusterAPIProto.java x: 72 lines of code y: 146 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/proto/ResourceClusterScaleRuleProto.java x: 82 lines of code y: 135 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/persistence/IMantisPersistenceProvider.java x: 81 lines of code y: 242 line churn mantis-runtime/src/main/java/io/mantisrx/runtime/lifecycle/LifecycleNoOp.java x: 20 lines of code y: 5 line churn mantis-runtime/src/main/java/io/mantisrx/runtime/source/Index.java x: 28 lines of code y: 30 line churn mantis-server/mantis-server-worker-client/src/main/java/io/mantisrx/server/worker/client/SseWorkerConnection.java x: 341 lines of code y: 241 line churn mantis-runtime/src/main/java/io/mantisrx/runtime/sink/ServerSentEventsSink.java x: 240 lines of code y: 117 line churn mantis-connectors/mantis-connector-job-source/src/main/java/io/mantisrx/connector/job/source/JobSource.java x: 281 lines of code y: 385 line churn mantis-runtime/src/main/java/io/mantisrx/runtime/parameter/SourceJobParameters.java x: 191 lines of code y: 270 line churn mantis-network/src/main/java/io/reactivex/mantis/network/push/PushServerSse.java x: 262 lines of code y: 153 line churn mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/RemoteObservable.java x: 577 lines of code y: 42 line churn mantis-control-plane/mantis-control-plane-dynamodb/src/main/java/io/mantisrx/extensions/dynamodb/DynamoDBMasterMonitor.java x: 25 lines of code y: 415 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker/IMantisWorkerMetadata.java x: 51 lines of code y: 466 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker/MantisWorkerMetadataImpl.java x: 315 lines of code y: 884 line churn mantis-server/mantis-server-worker-client/src/main/java/io/mantisrx/server/worker/client/MantisHttpClientImpl.java x: 96 lines of code y: 148 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/ResourceClusterAwareScheduler.java x: 50 lines of code y: 178 line churn mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/resourcecluster/ResourceClusterGatewayClient.java x: 112 lines of code y: 167 line churn mantis-runtime-loader/src/main/java/io/mantisrx/runtime/loader/config/WorkerConfiguration.java x: 128 lines of code y: 221 line churn mantis-runtime/src/main/java/io/mantisrx/runtime/GroupToScalar.java x: 82 lines of code y: 86 line churn mantis-runtime/src/main/java/io/mantisrx/runtime/ScalarToGroup.java x: 89 lines of code y: 97 line churn mantis-network/src/main/java/io/reactivex/mantis/network/push/ConsistentHashingRouter.java x: 103 lines of code y: 9 line churn mantis-network/src/main/java/io/reactivex/mantis/network/push/HashFunctions.java x: 33 lines of code y: 5 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/SLAEnforcer.java x: 91 lines of code y: 310 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/JobDefinitionResolver.java x: 152 lines of code y: 655 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/JobClusterConfig.java x: 117 lines of code y: 327 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/JobDefinition.java x: 341 lines of code y: 876 line churn mantis-runtime-loader/src/main/java/io/mantisrx/runtime/loader/config/WorkerConfigurationWritable.java x: 225 lines of code y: 309 line churn mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent/BlobStore.java x: 149 lines of code y: 462 line churn mantis-client/src/main/java/io/mantisrx/client/MantisClient.java x: 247 lines of code y: 91 line churn mantis-client/src/main/java/io/mantisrx/client/MantisSSEJob.java x: 231 lines of code y: 60 line churn mantis-connectors/mantis-connector-job-source/src/main/java/io/mantisrx/connector/job/core/MantisSourceJobConnector.java x: 158 lines of code y: 220 line churn mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/HighAvailabilityServicesUtil.java x: 192 lines of code y: 314 line churn mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core/master/MasterDescription.java x: 88 lines of code y: 378 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/events/WorkerMetricsCollector.java x: 186 lines of code y: 247 line churn mantis-control-plane/mantis-control-plane-dynamodb/src/main/java/io/mantisrx/extensions/dynamodb/DynamoDBStore.java x: 233 lines of code y: 395 line churn mantis-connectors/mantis-connector-job-source/src/main/java/io/mantisrx/connector/job/core/MultiSinkConnectionStatusObserver.java x: 91 lines of code y: 145 line churn mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core/ExecuteStageRequest.java x: 109 lines of code y: 587 line churn mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core/domain/JobMetadata.java x: 44 lines of code y: 223 line churn mantis-common/src/main/java/io/mantisrx/runtime/descriptor/SchedulingInfo.java x: 205 lines of code y: 605 line churn mantis-common/src/main/java/io/mantisrx/runtime/descriptor/StageScalingPolicy.java x: 98 lines of code y: 227 line churn mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent/TaskExecutorStarter.java x: 156 lines of code y: 608 line churn mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/TestGetMasterMonitor.java x: 61 lines of code y: 190 line churn mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core/IKeyValueStore.java x: 78 lines of code y: 224 line churn mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core/master/LocalMasterMonitor.java x: 25 lines of code y: 103 line churn mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core/master/MasterMonitor.java x: 9 lines of code y: 69 line churn mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core/master/ZookeeperMasterMonitor.java x: 106 lines of code y: 365 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/zk/LeaderElector.java x: 132 lines of code y: 388 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/ILeadershipManager.java x: 4 lines of code y: 108 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/LeaderRedirectionFilter.java x: 87 lines of code y: 213 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/KeyValueStore.java x: 107 lines of code y: 560 line churn mantis-control-plane/mantis-control-plane-store/mantis-control-plane-store-dynamodb/src/main/java/io/mantisrx/server/master/store/DynamoStore.java x: 189 lines of code y: 285 line churn mantis-runtime-executor/src/main/java/io/mantisrx/server/worker/RuntimeTaskImpl.java x: 180 lines of code y: 252 line churn mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent/ResourceManagerGatewayCxn.java x: 213 lines of code y: 368 line churn mantis-rxcontrol/src/main/java/io/mantisrx/control/IController.java x: 31 lines of code y: 71 line churn mantis-rxcontrol/src/main/java/io/mantisrx/control/clutch/ClutchConfigurator.java x: 151 lines of code y: 244 line churn mantis-rxcontrol/src/main/java/io/mantisrx/control/clutch/ClutchExperimental.java x: 79 lines of code y: 126 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/ResourceClustersNonLeaderRedirectRoute.java x: 422 lines of code y: 659 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/ScheduleRequest.java x: 46 lines of code y: 617 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/events/WorkerRegistryV2.java x: 137 lines of code y: 464 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClustersHostManagerActor.java x: 355 lines of code y: 714 line churn mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/master/resourcecluster/TaskExecutorRegistration.java x: 134 lines of code y: 211 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/IMantisStageMetadata.java x: 35 lines of code y: 282 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/proto/MantisResourceClusterSpec.java x: 105 lines of code y: 191 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/MantisMasterRoute.java x: 90 lines of code y: 273 line churn mantis-runtime-executor/src/main/java/io/mantisrx/server/worker/MantisWorker.java x: 209 lines of code y: 294 line churn mantis-runtime-loader/src/main/java/io/mantisrx/runtime/loader/cgroups/CpuAcctsSubsystemProcess.java x: 58 lines of code y: 89 line churn mantis-runtime-loader/src/main/java/io/mantisrx/runtime/loader/cgroups/MemorySubsystemProcess.java x: 46 lines of code y: 74 line churn mantis-runtime-loader/src/main/java/io/mantisrx/runtime/loader/cgroups/ProcFileReader.java x: 130 lines of code y: 220 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/CompletedJobStore.java x: 245 lines of code y: 391 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/JobClustersManagerService.java x: 72 lines of code y: 202 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterProto.java x: 182 lines of code y: 630 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/IJobClusterManager.java x: 63 lines of code y: 244 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/MantisJobMetadataWritable.java x: 207 lines of code y: 727 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/MantisStageMetadataWritable.java x: 188 lines of code y: 552 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterGatewayAkkaImpl.java x: 116 lines of code y: 216 line churn mantis-client/src/main/java/io/mantisrx/client/SinkClientImpl.java x: 251 lines of code y: 38 line churn mantis-common/src/main/java/io/mantisrx/runtime/MantisJobState.java x: 85 lines of code y: 7 line churn mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/MasterClientWrapper.java x: 300 lines of code y: 1007 line churn mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent/utils/ExponentialBackoffAbstractScheduledService.java x: 50 lines of code y: 117 line churn mantis-runtime/src/main/java/io/mantisrx/runtime/command/LoadValidateCreateZip.java x: 56 lines of code y: 23 line churn mantis-runtime/src/main/java/io/mantisrx/runtime/executor/SinkPublisher.java x: 99 lines of code y: 85 line churn mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent/HadoopFileSystemBlobStore.java x: 35 lines of code y: 205 line churn mantis-common/src/main/java/io/mantisrx/common/metrics/MetricsServer.java x: 142 lines of code y: 42 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/MasterApiMetrics.java x: 52 lines of code y: 144 line churn mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/TaskStatusUpdateHandlerImpl.java x: 38 lines of code y: 266 line churn mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/worker/TaskExecutorGateway.java x: 34 lines of code y: 136 line churn mantis-runtime/src/main/java/io/mantisrx/runtime/source/http/impl/HttpSourceImpl.java x: 550 lines of code y: 299 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/events/LifecycleEventsProto.java x: 224 lines of code y: 762 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/IMantisJobMetadata.java x: 43 lines of code y: 392 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/MantisJobMetadata.java x: 33 lines of code y: 154 line churn mantis-runtime/src/main/java/io/mantisrx/runtime/command/CreateJobDescriptorFile.java x: 116 lines of code y: 53 line churn mantis-runtime/src/main/java/io/mantisrx/runtime/executor/StageExecutors.java x: 406 lines of code y: 264 line churn mantis-source-jobs/mantis-source-job-kafka/src/main/java/io/mantisrx/sourcejob/kafka/CustomizedAutoAckTaggingStage.java x: 138 lines of code y: 385 line churn mantis-runtime/src/main/java/io/mantisrx/runtime/Config.java x: 50 lines of code y: 26 line churn mantis-runtime/src/main/java/io/mantisrx/runtime/Context.java x: 72 lines of code y: 21 line churn mantis-runtime/src/main/java/io/mantisrx/runtime/GroupToGroup.java x: 79 lines of code y: 93 line churn mantis-runtime/src/main/java/io/mantisrx/runtime/Job.java x: 41 lines of code y: 23 line churn mantis-runtime/src/main/java/io/mantisrx/runtime/ScalarToScalar.java x: 82 lines of code y: 62 line churn mantis-runtime/src/main/java/io/mantisrx/runtime/SourceHolder.java x: 46 lines of code y: 20 line churn mantis-runtime/src/main/java/io/mantisrx/runtime/WorkerInfo.java x: 63 lines of code y: 19 line churn mantis-runtime/src/main/java/io/mantisrx/runtime/command/CreateZipFile.java x: 67 lines of code y: 16 line churn mantis-runtime/src/main/java/io/mantisrx/runtime/core/MantisStreamImpl.java x: 178 lines of code y: 233 line churn mantis-runtime/src/main/java/io/mantisrx/runtime/executor/LocalJobExecutorNetworked.java x: 339 lines of code y: 56 line churn mantis-runtime/src/main/java/io/mantisrx/runtime/sink/ServerSentEventRequestHandler.java x: 283 lines of code y: 227 line churn mantis-runtime/src/main/java/io/mantisrx/runtime/source/http/impl/OperatorResumeOnCompleted.java x: 60 lines of code y: 2 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/config/ConfigurationFactory.java x: 4 lines of code y: 64 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/config/StaticPropertiesConfigurationFactory.java x: 47 lines of code y: 203 line churn mantis-connectors/mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer/IcebergCommitterStage.java x: 135 lines of code y: 421 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobArtifactsRoute.java x: 102 lines of code y: 150 line churn mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent/BlobStoreAwareClassLoaderHandle.java x: 94 lines of code y: 364 line churn mantis-connectors/mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/codecs/IcebergCodecs.java x: 119 lines of code y: 288 line churn mantis-connectors/mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/DefaultIcebergWriter.java x: 154 lines of code y: 534 line churn mantis-connectors/mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/IcebergWriterStage.java x: 266 lines of code y: 1455 line churn mantis-connectors/mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/pool/IcebergWriterPool.java x: 17 lines of code y: 113 line churn mantis-network/src/main/java/io/reactivex/mantis/network/push/TimedChunker.java x: 91 lines of code y: 170 line churn mantis-common/src/main/java/io/mantisrx/common/metrics/Metrics.java x: 205 lines of code y: 129 line churn mantis-common/src/main/java/io/mantisrx/runtime/descriptor/StageSchedulingInfo.java x: 131 lines of code y: 265 line churn mantis-network/src/main/java/io/reactivex/mantis/network/push/ObservableTrigger.java x: 276 lines of code y: 156 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/handlers/ResourceClusterRouteHandlerAkkaImpl.java x: 98 lines of code y: 182 line churn mantis-runtime/src/main/java/io/mantisrx/runtime/core/KeyedMantisStream.java x: 12 lines of code y: 106 line churn mantis-runtime/src/main/java/io/mantisrx/runtime/core/WindowSpec.java x: 40 lines of code y: 104 line churn mantis-connectors/mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/MantisKafkaConsumerConfig.java x: 123 lines of code y: 352 line churn mantis-source-jobs/mantis-source-job-publish/src/main/java/io/mantisrx/sourcejobs/publish/core/Utils.java x: 21 lines of code y: 95 line churn mantis-discovery-proto/src/main/java/io/mantisrx/discovery/proto/AppJobClustersMap.java x: 120 lines of code y: 166 line churn mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/AbstractSubscriptionTracker.java x: 159 lines of code y: 1278 line churn mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/ConsoleEventChannel.java x: 23 lines of code y: 143 line churn mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/discovery/MantisJobDiscoveryCachingImpl.java x: 166 lines of code y: 451 line churn mantis-publish/mantis-publish-netty/src/main/java/io/mantisrx/publish/netty/transmitters/ChoiceOfTwoWorkerPool.java x: 145 lines of code y: 579 line churn mantis-common/src/main/java/io/mantisrx/common/codec/Codecs.java x: 109 lines of code y: 35 line churn mantis-runtime/src/main/java/io/mantisrx/runtime/core/MantisJobBuilder.java x: 107 lines of code y: 135 line churn mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core/BaseService.java x: 128 lines of code y: 334 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/MantisJobMetadataView.java x: 152 lines of code y: 435 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker/WorkerHeartbeat.java x: 59 lines of code y: 242 line churn mantis-common/src/main/java/io/mantisrx/runtime/parameter/SinkParameter.java x: 58 lines of code y: 300 line churn mantis-common/src/main/java/io/mantisrx/runtime/parameter/SinkParameters.java x: 77 lines of code y: 381 line churn mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/TaskStatusUpdateHandler.java x: 8 lines of code y: 105 line churn mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent/FileSystemInitializer.java x: 34 lines of code y: 180 line churn mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent/Hardware.java x: 198 lines of code y: 903 line churn mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent/JvmUtils.java x: 33 lines of code y: 201 line churn mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/MantisEventPublisher.java x: 68 lines of code y: 237 line churn mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/api/EventPublisher.java x: 13 lines of code y: 170 line churn mantis-common/src/main/java/io/mantisrx/common/storage/StorageUnit.java x: 390 lines of code y: 529 line churn mantis-examples/mantis-examples-synthetic-sourcejob/src/main/java/io/mantisrx/sourcejob/synthetic/stage/TaggingStage.java x: 111 lines of code y: 330 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/MantisWorkerMetadataWritable.java x: 283 lines of code y: 726 line churn mantis-common/src/main/java/com/mantisrx/common/utils/ListenerCallQueue.java x: 120 lines of code y: 206 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/LabelManager.java x: 74 lines of code y: 230 line churn mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/DynamicConnectionSet.java x: 266 lines of code y: 18 line churn mantis-control-plane/mantis-control-plane-core/src/testFixtures/java/io/mantisrx/server/core/TestingRpcService.java x: 154 lines of code y: 243 line churn mantis-connectors/mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/KafkaSource.java x: 313 lines of code y: 790 line churn mantis-runtime/src/main/java/io/mantisrx/runtime/sink/Sinks.java x: 130 lines of code y: 128 line churn mantis-source-jobs/mantis-source-job-kafka/src/main/java/io/mantisrx/sourcejob/kafka/sink/TaggedDataSourceSink.java x: 61 lines of code y: 205 line churn mantis-common/src/main/java/io/mantisrx/common/compression/CompressionUtils.java x: 329 lines of code y: 277 line churn mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core/WorkerHost.java x: 57 lines of code y: 291 line churn mantis-client/src/main/java/io/mantisrx/client/SseSinkConnectionFunction.java x: 110 lines of code y: 31 line churn mantis-common/src/main/java/io/mantisrx/common/metrics/netty/HttpClientListener.java x: 180 lines of code y: 5 line churn mantis-common/src/main/java/io/mantisrx/common/metrics/netty/HttpServerListener.java x: 140 lines of code y: 3 line churn mantis-common/src/main/java/io/mantisrx/common/metrics/netty/TcpClientListener.java x: 191 lines of code y: 5 line churn mantis-common/src/main/java/io/mantisrx/common/metrics/netty/TcpServerListener.java x: 148 lines of code y: 3 line churn mantis-common/src/main/java/io/mantisrx/common/network/ServerSlotManager.java x: 173 lines of code y: 8 line churn mantis-common/src/main/java/io/mantisrx/common/network/WritableEndpoint.java x: 81 lines of code y: 3 line churn mantis-common/src/main/java/io/mantisrx/runtime/JobSla.java x: 129 lines of code y: 25 line churn mantis-common/src/main/java/io/mantisrx/runtime/codec/JacksonCodecs.java x: 81 lines of code y: 35 line churn mantis-common/src/main/java/io/reactivx/mantis/operators/BufferOnBackPressureOperator.java x: 201 lines of code y: 9 line churn mantis-common/src/main/java/io/reactivx/mantis/operators/BufferUntilSubscriber.java x: 128 lines of code y: 1 line churn mantis-common/src/main/java/io/reactivx/mantis/operators/DropOperator.java x: 102 lines of code y: 46 line churn mantis-common/src/main/java/io/reactivx/mantis/operators/OnSubscribeRedo.java x: 246 lines of code y: 2 line churn mantis-common/src/main/java/io/reactivx/mantis/operators/OperatorGroupBy.java x: 252 lines of code y: 1 line churn mantis-connectors/mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer/metrics/CommitterMetrics.java x: 86 lines of code y: 261 line churn mantis-connectors/mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/metrics/WriterMetrics.java x: 105 lines of code y: 274 line churn mantis-connectors/mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/KafkaData.java x: 95 lines of code y: 265 line churn mantis-connectors/mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/sink/MantisKafkaProducerConfig.java x: 85 lines of code y: 257 line churn mantis-connectors/mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/MantisKafkaConsumer.java x: 250 lines of code y: 697 line churn mantis-connectors/mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/TopicPartitionStateManager.java x: 97 lines of code y: 325 line churn mantis-connectors/mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy/CheckpointStrategy.java x: 14 lines of code y: 144 line churn mantis-connectors/mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/metrics/ConsumerMetrics.java x: 131 lines of code y: 349 line churn mantis-connectors/mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/core/QueryMap.java x: 100 lines of code y: 299 line churn mantis-connectors/mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http/NettyExceptionHandler.java x: 85 lines of code y: 305 line churn mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/HttpUtility.java x: 97 lines of code y: 253 line churn mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/MantisProtoAdapter.java x: 1 lines of code y: 321 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/handlers/JobRouteHandlerAkkaImpl.java x: 84 lines of code y: 235 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/pagination/ListObject.java x: 219 lines of code y: 583 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v0/JobRoute.java x: 315 lines of code y: 799 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v0/MasterDescriptionRoute.java x: 140 lines of code y: 383 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/JobClusterMetadataImpl.java x: 75 lines of code y: 419 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/JobListHelper.java x: 43 lines of code y: 274 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/WorkerRequest.java x: 170 lines of code y: 453 line churn mantis-examples/mantis-examples-synthetic-sourcejob/src/main/java/io/mantisrx/sourcejob/synthetic/core/MQL.java x: 127 lines of code y: 554 line churn mantis-examples/mantis-examples-synthetic-sourcejob/src/main/java/io/mantisrx/sourcejob/synthetic/sink/QueryRequestPreProcessor.java x: 39 lines of code y: 163 line churn mantis-network/src/main/java/io/reactivex/mantis/network/push/ConnectionGroup.java x: 97 lines of code y: 11 line churn mantis-network/src/main/java/io/reactivex/mantis/network/push/LegacyTcpPipelineConfigurator.java x: 198 lines of code y: 11 line churn mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/MrePublishClientInitializer.java x: 95 lines of code y: 300 line churn mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/config/MrePublishConfiguration.java x: 47 lines of code y: 733 line churn mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/config/SampleArchaiusMrePublishConfiguration.java x: 340 lines of code y: 834 line churn mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/proto/MantisServerSubscription.java x: 54 lines of code y: 175 line churn mantis-publish/mantis-publish-netty/src/main/java/io/mantisrx/publish/netty/pipeline/HttpEventChannelHandler.java x: 55 lines of code y: 212 line churn mantis-publish/mantis-publish-netty/src/main/java/io/mantisrx/publish/netty/pipeline/HttpEventChannelManager.java x: 108 lines of code y: 375 line churn mantis-publish/mantis-publish-netty/src/main/java/io/mantisrx/publish/netty/pipeline/MantisEventAggregator.java x: 180 lines of code y: 525 line churn mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/BatchedRxEventPipelineConfigurator.java x: 207 lines of code y: 11 line churn mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/ConnectToGroupedObservable.java x: 115 lines of code y: 3 line churn mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/RemoteObservableConnectionHandler.java x: 384 lines of code y: 11 line churn mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/ServeGroupedObservable.java x: 221 lines of code y: 13 line churn mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/ServeNestedObservable.java x: 93 lines of code y: 3 line churn .baseline/idea/intellij-java-palantir-style.xml x: 476 lines of code y: 952 line churn mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/api/PublishStatus.java x: 28 lines of code y: 192 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/IMantisJobManager.java x: 33 lines of code y: 360 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker/WorkerTerminate.java x: 70 lines of code y: 238 line churn mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/scheduler/ConstraintsEvaluators.java x: 1 lines of code y: 200 line churn
8619.0
line churn
  min: 1.0
  average: 205.24
  25th percentile: 36.0
  median: 93.0
  75th percentile: 212.25
  max: 8619.0
0 2641.0
lines of code
min: 1.0 | average: 91.34 | 25th percentile: 19.0 | median: 45.0 | 75th percentile: 100.0 | max: 2641.0