netflix / mantis
File Change Frequency

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

Overview
File Change Frequency Overall
  • There are 882 files with 77,389 lines of code.
    • 0 files changed more than 100 times (0 lines of code)
    • 1 file changed 51-100 times (1,135 lines of code)
    • 8 files changed 21-50 times (6,051 lines of code)
    • 71 files changed 6-20 times (18,138 lines of code)
    • 802 files changed 1-5 times (52,065 lines of code)
0% | 1% | 7% | 23% | 67%
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 882 files with 77,389 lines of code.
    • 0 files changed by more than 25 contributors (0 lines of code)
    • 4 files changed by 11-25 contributors (1,145 lines of code)
    • 12 files changed by 6-10 contributors (7,590 lines of code)
    • 480 files changed by 2-5 contributors (50,082 lines of code)
    • 386 files changed by 1 contributor (18,572 lines of code)
0% | 1% | 9% | 64% | 23%
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, yaml, xml, txt, 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% | 7% | 23% | 67%
xml0% | 0% | 0% | 0% | 100%
html0% | 0% | 0% | 0% | 100%
jsp0% | 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% | 3% | 14% | 33% | 48%
mantis-server0% | 0% | 20% | 30% | 48%
mantis-runtime0% | 0% | 0% | 21% | 78%
mantis-common0% | 0% | 0% | 17% | 82%
mantis-network0% | 0% | 0% | 27% | 72%
mantis-runtime-executor0% | 0% | 0% | 24% | 75%
mantis-connectors0% | 0% | 0% | 10% | 89%
mantis-runtime-loader0% | 0% | 0% | 37% | 62%
mantis-client0% | 0% | 0% | 25% | 74%
mantis-publish0% | 0% | 0% | 4% | 95%
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%
mantis-discovery-proto0% | 0% | 0% | 0% | 100%
mantis-common-akka0% | 0% | 0% | 0% | 100%
mantis-common-serde0% | 0% | 0% | 0% | 100%
Most Frequently Changed Files (Top 50)

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
ResourceClusterActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster
 1135 69 2022-04-11 2025-02-25 51 5 me@sundaram.io 84794668+andresgalindo-stri...
JobClusterActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster
 2569 133 2020-10-02 2025-03-17 35 7 jchao@netflix.com 87735571+andyz26@users.nore...
MasterConfiguration.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/config
 265 3 2020-10-02 2025-02-20 34 11 jchao@netflix.com 84794668+andresgalindo-stri...
JobActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job
 1798 83 2020-10-02 2025-04-02 33 9 jchao@netflix.com 87735571+andyz26@users.nore...
MasterMain.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master
 245 9 2020-10-02 2025-03-17 31 11 jchao@netflix.com 87735571+andyz26@users.nore...
ResourceClusterAkkaImpl.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster
 292 16 2022-04-11 2024-06-12 23 3 me@sundaram.io 87735571+andyz26@users.nore...
TaskExecutor.java
in mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent
 568 40 2022-05-06 2024-07-04 23 5 cal681@gmail.com 100323213+hmitnflx@users.no...
ResourceClustersManagerActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster
 219 10 2022-04-15 2025-03-17 22 4 me@sundaram.io 87735571+andyz26@users.nore...
ResourceCluster.java
in mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/master/resourcecluster
 95 3 2022-04-11 2024-06-12 21 3 me@sundaram.io 87735571+andyz26@users.nore...
ResourceClusterAwareSchedulerActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler
 480 37 2022-04-19 2024-11-14 19 4 me@sundaram.io 87735571+andyz26@users.nore...
ExecutorStateManagerImpl.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster
 517 21 2023-01-17 2025-02-25 18 4 87735571+andyz26@users.nore... 84794668+andresgalindo-stri...
MantisJobStore.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/persistence
 288 44 2020-10-02 2025-03-17 17 5 jchao@netflix.com 87735571+andyz26@users.nore...
KeyValueBasedPersistenceProvider.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/persistence
 813 68 2022-11-18 2025-03-17 17 5 100323213+hmitnflx@users.no... 87735571+andyz26@users.nore...
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 16 11 njoshi@netflix.com 53982208+jpittis-stripe@use...
DataFormatAdapter.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain
 679 51 2020-10-02 2025-03-17 16 7 jchao@netflix.com 87735571+andyz26@users.nore...
SchedulingInfo.java
in mantis-common/src/main/java/io/mantisrx/runtime/descriptor
 205 21 2020-07-09 2024-07-04 15 5 cal681@gmail.com 100323213+hmitnflx@users.no...
ParameterUtils.java
in mantis-runtime/src/main/java/io/mantisrx/runtime/parameter
 294 8 2019-10-04 2025-04-28 15 11 nmahilani@netflix.com 87735571+andyz26@users.nore...
WorkerConfiguration.java
in mantis-runtime-loader/src/main/java/io/mantisrx/runtime/loader/config
 128 4 2022-10-28 2024-11-07 14 5 87735571+andyz26@users.nore... 87735571+andyz26@users.nore...
PushServerSse.java
in mantis-network/src/main/java/io/reactivex/mantis/network/push
 262 3 2019-06-25 2025-02-11 14 7 crioux@netflix.com 135762838+tcai-stripe@users...
IcebergWriterStage.java
in mantis-connectors/mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer
 266 14 2020-10-01 2023-05-25 14 6 jchao@netflix.com me@sundaram.io
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 87735571+andyz26@users.nore... 87735571+andyz26@users.nore...
StageScalingPolicy.java
in mantis-common/src/main/java/io/mantisrx/runtime/descriptor
 98 4 2020-01-29 2024-07-04 12 5 crioux@netflix.com 100323213+hmitnflx@users.no...
MasterApiAkkaService.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka
 249 6 2020-10-02 2024-06-26 12 8 jchao@netflix.com kmg@stripe.com
ResourceClusterScalerActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster
 416 20 2022-06-02 2024-04-20 12 3 87735571+andyz26@users.nore... 87735571+andyz26@users.nore...
MantisMasterClientApi.java
in mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client
 660 32 2020-10-02 2025-03-17 12 5 jchao@netflix.com 87735571+andyz26@users.nore...
JobClusterManagerProto.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto
 1841 226 2020-10-02 2025-01-09 12 5 jchao@netflix.com 87735571+andyz26@users.nore...
WorkerPorts.java
in mantis-common/src/main/java/io/mantisrx/common
 102 12 2020-02-20 2022-05-19 11 4 jchao@netflix.com me@sundaram.io
StageSchedulingInfo.java
in mantis-common/src/main/java/io/mantisrx/runtime/descriptor
 131 11 2020-07-09 2023-05-09 11 4 cal681@gmail.com me@sundaram.io
DefaultIcebergWriter.java
in mantis-connectors/mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer
 154 14 2020-10-01 2023-05-25 11 4 jchao@netflix.com me@sundaram.io
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 jchao@netflix.com kmg@stripe.com
IMantisPersistenceProvider.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/persistence
 81 2 2022-11-18 2025-03-17 10 5 100323213+hmitnflx@users.no... 87735571+andyz26@users.nore...
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 jchao@netflix.com kmg@stripe.com
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 jchao@netflix.com 139389030+sarahwada-stripe@...
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 me@sundaram.io kmg@stripe.com
WorkerConfigurationWritable.java
in mantis-runtime-loader/src/main/java/io/mantisrx/runtime/loader/config
 225 41 2023-02-01 2024-09-12 10 7 87735571+andyz26@users.nore... 131782471+timmartin-stripe@...
TaskExecutorState.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster
 247 30 2023-01-17 2024-12-17 10 2 87735571+andyz26@users.nore... 87735571+andyz26@users.nore...
ServerSentEventRequestHandler.java
in mantis-runtime/src/main/java/io/mantisrx/runtime/sink
 283 2 2020-07-24 2023-07-09 10 6 crioux@netflix.com jeevanrangaramaiah@gmail.com
BaseRoute.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1
 303 11 2020-10-02 2024-06-12 10 3 jchao@netflix.com 87735571+andyz26@users.nore...
StageExecutors.java
in mantis-runtime/src/main/java/io/mantisrx/runtime/executor
 406 7 2020-07-18 2023-07-14 10 8 njoshi@netflix.com 100323213+hmitnflx@users.no...
WorkerExecutionOperationsNetworkStage.java
in mantis-runtime-executor/src/main/java/io/mantisrx/server/worker
 567 18 2024-01-29 2025-04-28 10 4 87735571+andyz26@users.nore... 87735571+andyz26@users.nore...
TaskExecutorStarter.java
in mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent
 156 16 2022-05-06 2024-07-04 9 5 cal681@gmail.com 100323213+hmitnflx@users.no...
AbstractSubscriptionTracker.java
in mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish
 159 6 2020-10-02 2023-02-22 9 5 jchao@netflix.com me@sundaram.io
CompressionUtils.java
in mantis-common/src/main/java/io/mantisrx/common/compression
 329 15 2020-07-24 2022-03-25 9 5 crioux@netflix.com cal681@gmail.com
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 87735571+andyz26@users.nore... 87735571+andyz26@users.nore...
MantisJobMetadataImpl.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job
 385 54 2020-10-02 2024-09-13 9 4 jchao@netflix.com kmg@stripe.com
PushServer.java
in mantis-network/src/main/java/io/reactivex/mantis/network/push
 396 11 2020-07-24 2025-04-14 9 6 crioux@netflix.com 87735571+andyz26@users.nore...
JobClustersManagerActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master
 918 66 2020-10-02 2025-03-17 9 5 jchao@netflix.com 87735571+andyz26@users.nore...
MantisSSEConstants.java
in mantis-common/src/main/java/com/mantisrx/common/utils
 18 - 2020-07-24 2025-02-11 8 4 crioux@netflix.com 135762838+tcai-stripe@users...
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 me@sundaram.io me@sundaram.io
ResourceClustersAkkaImpl.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster
 78 2 2022-04-15 2023-11-22 8 2 me@sundaram.io 87735571+andyz26@users.nore...
Files With Most Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
MasterConfiguration.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/config
 265 3 2020-10-02 2025-02-20 34 11 jchao@netflix.com 84794668+andresgalindo-stri...
MasterMain.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master
 245 9 2020-10-02 2025-03-17 31 11 jchao@netflix.com 87735571+andyz26@users.nore...
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 16 11 njoshi@netflix.com 53982208+jpittis-stripe@use...
ParameterUtils.java
in mantis-runtime/src/main/java/io/mantisrx/runtime/parameter
 294 8 2019-10-04 2025-04-28 15 11 nmahilani@netflix.com 87735571+andyz26@users.nore...
JobActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job
 1798 83 2020-10-02 2025-04-02 33 9 jchao@netflix.com 87735571+andyz26@users.nore...
MasterApiAkkaService.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka
 249 6 2020-10-02 2024-06-26 12 8 jchao@netflix.com kmg@stripe.com
StageExecutors.java
in mantis-runtime/src/main/java/io/mantisrx/runtime/executor
 406 7 2020-07-18 2023-07-14 10 8 njoshi@netflix.com 100323213+hmitnflx@users.no...
JobClusterActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster
 2569 133 2020-10-02 2025-03-17 35 7 jchao@netflix.com 87735571+andyz26@users.nore...
DataFormatAdapter.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain
 679 51 2020-10-02 2025-03-17 16 7 jchao@netflix.com 87735571+andyz26@users.nore...
PushServerSse.java
in mantis-network/src/main/java/io/reactivex/mantis/network/push
 262 3 2019-06-25 2025-02-11 14 7 crioux@netflix.com 135762838+tcai-stripe@users...
WorkerConfigurationWritable.java
in mantis-runtime-loader/src/main/java/io/mantisrx/runtime/loader/config
 225 41 2023-02-01 2024-09-12 10 7 87735571+andyz26@users.nore... 131782471+timmartin-stripe@...
IcebergWriterStage.java
in mantis-connectors/mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer
 266 14 2020-10-01 2023-05-25 14 6 jchao@netflix.com me@sundaram.io
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 jchao@netflix.com kmg@stripe.com
ServerSentEventRequestHandler.java
in mantis-runtime/src/main/java/io/mantisrx/runtime/sink
 283 2 2020-07-24 2023-07-09 10 6 crioux@netflix.com jeevanrangaramaiah@gmail.com
PushServer.java
in mantis-network/src/main/java/io/reactivex/mantis/network/push
 396 11 2020-07-24 2025-04-14 9 6 crioux@netflix.com 87735571+andyz26@users.nore...
CreateJobDescriptorFile.java
in mantis-runtime/src/main/java/io/mantisrx/runtime/command
 116 6 2020-07-09 2023-07-14 6 6 cal681@gmail.com 100323213+hmitnflx@users.no...
ResourceClusterActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster
 1135 69 2022-04-11 2025-02-25 51 5 me@sundaram.io 84794668+andresgalindo-stri...
TaskExecutor.java
in mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent
 568 40 2022-05-06 2024-07-04 23 5 cal681@gmail.com 100323213+hmitnflx@users.no...
KeyValueBasedPersistenceProvider.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/persistence
 813 68 2022-11-18 2025-03-17 17 5 100323213+hmitnflx@users.no... 87735571+andyz26@users.nore...
MantisJobStore.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/persistence
 288 44 2020-10-02 2025-03-17 17 5 jchao@netflix.com 87735571+andyz26@users.nore...
SchedulingInfo.java
in mantis-common/src/main/java/io/mantisrx/runtime/descriptor
 205 21 2020-07-09 2024-07-04 15 5 cal681@gmail.com 100323213+hmitnflx@users.no...
WorkerConfiguration.java
in mantis-runtime-loader/src/main/java/io/mantisrx/runtime/loader/config
 128 4 2022-10-28 2024-11-07 14 5 87735571+andyz26@users.nore... 87735571+andyz26@users.nore...
JobClusterManagerProto.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto
 1841 226 2020-10-02 2025-01-09 12 5 jchao@netflix.com 87735571+andyz26@users.nore...
MantisMasterClientApi.java
in mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client
 660 32 2020-10-02 2025-03-17 12 5 jchao@netflix.com 87735571+andyz26@users.nore...
StageScalingPolicy.java
in mantis-common/src/main/java/io/mantisrx/runtime/descriptor
 98 4 2020-01-29 2024-07-04 12 5 crioux@netflix.com 100323213+hmitnflx@users.no...
IMantisPersistenceProvider.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/persistence
 81 2 2022-11-18 2025-03-17 10 5 100323213+hmitnflx@users.no... 87735571+andyz26@users.nore...
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 jchao@netflix.com kmg@stripe.com
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 jchao@netflix.com 139389030+sarahwada-stripe@...
JobClustersManagerActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master
 918 66 2020-10-02 2025-03-17 9 5 jchao@netflix.com 87735571+andyz26@users.nore...
TaskExecutorStarter.java
in mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent
 156 16 2022-05-06 2024-07-04 9 5 cal681@gmail.com 100323213+hmitnflx@users.no...
AbstractSubscriptionTracker.java
in mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish
 159 6 2020-10-02 2023-02-22 9 5 jchao@netflix.com me@sundaram.io
CompressionUtils.java
in mantis-common/src/main/java/io/mantisrx/common/compression
 329 15 2020-07-24 2022-03-25 9 5 crioux@netflix.com cal681@gmail.com
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 me@sundaram.io me@sundaram.io
JobClusterProtoAdapter.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/proto
 283 24 2020-10-02 2024-09-13 7 5 jchao@netflix.com kmg@stripe.com
WorkerConfigurationUtils.java
in mantis-runtime-loader/src/main/java/io/mantisrx/runtime/loader/config
 57 3 2022-10-28 2024-07-04 7 5 87735571+andyz26@users.nore... 100323213+hmitnflx@users.no...
ServerSentEventsSink.java
in mantis-runtime/src/main/java/io/mantisrx/runtime/sink
 240 23 2021-09-22 2025-02-12 7 5 sananthanarayanan@netflix.com 135762838+tcai-stripe@users...
MantisScheduler.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler
 12 - 2020-10-02 2024-11-13 6 5 jchao@netflix.com kmg@stripe.com
JobClusterDefinitionImpl.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain
 366 43 2020-10-02 2025-01-16 6 5 jchao@netflix.com 43889268+dtrager02@users.no...
MantisStageMetadataImpl.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job
 406 42 2020-10-02 2024-02-27 6 5 jchao@netflix.com 103213338+fdc-ntflx@users.n...
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 jchao@netflix.com 103213338+fdc-ntflx@users.n...
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 jchao@netflix.com 139389030+sarahwada-stripe@...
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 jchao@netflix.com 87735571+andyz26@users.nore...
ScalarToGroup.java
in mantis-runtime/src/main/java/io/mantisrx/runtime
 89 17 2021-09-22 2024-10-11 6 5 sananthanarayanan@netflix.com 115596126+crioux-stripe@use...
MetricsServer.java
in mantis-common/src/main/java/io/mantisrx/common/metrics
 142 4 2019-11-14 2023-09-18 6 5 crioux@netflix.com 87735571+andyz26@users.nore...
GroupToScalar.java
in mantis-runtime/src/main/java/io/mantisrx/runtime
 82 13 2021-09-22 2024-10-11 5 5 sananthanarayanan@netflix.com 115596126+crioux-stripe@use...
JobInfo.java
in mantis-runtime/src/main/java/io/mantisrx/runtime/descriptor
 44 6 2020-07-09 2023-07-09 5 5 cal681@gmail.com jeevanrangaramaiah@gmail.com
SourceJobParameters.java
in mantis-runtime/src/main/java/io/mantisrx/runtime/parameter
 191 20 2020-12-11 2025-02-12 5 5 cal681@gmail.com 135762838+tcai-stripe@users...
LocalJobExecutorNetworked.java
in mantis-runtime/src/main/java/io/mantisrx/runtime/executor
 339 9 2021-09-22 2023-07-09 5 5 sananthanarayanan@netflix.com jeevanrangaramaiah@gmail.com
ResourceClustersManagerActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster
 219 10 2022-04-15 2025-03-17 22 4 me@sundaram.io 87735571+andyz26@users.nore...
ResourceClusterAwareSchedulerActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler
 480 37 2022-04-19 2024-11-14 19 4 me@sundaram.io 87735571+andyz26@users.nore...
Files With Least Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
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
RemoteRxEvent.java
in mantis-network/src/main/java/io/reactivex/mantis/network/push
 66 12
SingleThreadedChunker.java
in mantis-network/src/main/java/io/reactivex/mantis/network/push
 66 4
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
RoundRobin.java
in mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/slotting
 39 6
HashAlgorithm.java
in mantis-common/src/main/java/io/mantisrx/common/network
 39 1
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
MantisServerSentEvent.java
in mantis-common/src/main/java/io/mantisrx/common
 38 5
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
PushTrigger.java
in mantis-network/src/main/java/io/reactivex/mantis/network/push
 28 5
WorkerConnectionsStatus.java
in mantis-server/mantis-server-worker-client/src/main/java/io/mantisrx/server/worker/client
 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
RemoteRxConnection.java
in mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable
 23 4
WorkerMap.java
in mantis-runtime/src/main/java/io/mantisrx/runtime
 23 4
StageOut.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
StageIn.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
StringParameter.java
in mantis-runtime/src/main/java/io/mantisrx/runtime/parameter/type
 22 3
HashFunctions.java
in mantis-common/src/main/java/io/mantisrx/common/network
 22 3
Group.java
in mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable
 21 3
MantisSourceJobConstants.java
in mantis-common/src/main/java/com/mantisrx/common/utils
 21 -
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
SnapshotCache.java
in mantis-network/src/main/java/io/reactivex/mantis/network/push
 15 3
GroupChunkProcessor.java
in mantis-network/src/main/java/io/reactivex/mantis/network/push
 15 2
ThrowableWithCount.java
in mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable
 15 3
Correlations

File Size vs. Number of Changes: 882 points

mantis-common/src/main/java/io/mantisrx/common/SystemParameters.java x: 22 lines of code y: 4 # 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/ScalerControllerActor.java x: 231 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/JobAutoScaler.java x: 540 lines of code y: 1 # changes mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/JobAutoScalerService.java x: 4 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/JobMasterService.java x: 147 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/WorkerMetricHandler.java x: 420 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/ClutchAutoScaler.java x: 184 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/ClutchControllerOutput.java x: 10 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/clutch/rps/RpsMetricComputer.java x: 14 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/controllers/PIDController.java x: 38 lines of code y: 1 # changes mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/control/utils/Integrator.java x: 27 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-runtime-executor/src/main/java/io/mantisrx/server/worker/jobmaster/JobMasterComponentLoader.java x: 70 lines of code y: 1 # 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-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/DynamoDBClientSingleton.java x: 134 lines of code y: 2 # 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-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/JobActor.java x: 1798 lines of code y: 33 # changes mantis-control-plane/mantis-control-plane-dynamodb/src/main/java/io/mantisrx/extensions/dynamodb/DynamoDBMasterMonitorSingleton.java x: 159 lines of code y: 3 # changes mantis-common-akka/src/main/java/io/mantisrx/common/akka/DeadLetterActor.java x: 44 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/MantisMasterClientApi.java x: 660 lines of code y: 12 # 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/JobClustersManagerActor.java x: 918 lines of code y: 9 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/handlers/JobClusterRouteHandler.java x: 27 lines of code y: 4 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/handlers/JobClusterRouteHandlerAkkaImpl.java x: 142 lines of code y: 4 # changes 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: 3 # 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/JobDiscoveryHeartbeats.java x: 9 lines of code y: 2 # 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/api/akka/route/v1/HttpRequestMetrics.java x: 105 lines of code y: 6 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobClustersRoute.java x: 596 lines of code y: 5 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/JobClusterActor.java x: 2569 lines of code y: 35 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/IWorkerManager.java x: 19 lines of code y: 3 # 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/JobClusterScalerRuleProto.java x: 86 lines of code y: 1 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/scaler/JobClusterScalerRuleDataImplWritable.java x: 67 lines of code y: 1 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClustersManagerActor.java x: 219 lines of code y: 22 # 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/ScaleResourceResponse.java x: 39 lines of code y: 4 # 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/MasterMain.java x: 245 lines of code y: 31 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/DataFormatAdapter.java x: 679 lines of code y: 16 # 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-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/persistence/KeyValueBasedPersistenceProvider.java x: 813 lines of code y: 17 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/persistence/MantisJobStore.java x: 288 lines of code y: 17 # changes mantis-runtime/src/main/java/io/mantisrx/runtime/source/Index.java x: 28 lines of code y: 3 # changes mantis-server/mantis-server-worker-client/src/main/java/io/mantisrx/server/worker/client/SseWorkerConnection.java x: 341 lines of code y: 16 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ExecutorStateManagerImpl.java x: 517 lines of code y: 18 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterActor.java x: 1135 lines of code y: 51 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/config/MasterConfiguration.java x: 265 lines of code y: 34 # 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: 8 # 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: 14 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/JobClusterDefinitionImpl.java x: 366 lines of code y: 6 # 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/proto/JobClusterManagerProto.java x: 1841 lines of code y: 12 # changes mantis-control-plane/mantis-control-plane-dynamodb/src/main/java/io/mantisrx/extensions/dynamodb/DynamoDBMasterMonitor.java x: 25 lines of code y: 6 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/TaskExecutorState.java x: 247 lines of code y: 10 # 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/ResourceClusterAwareSchedulerActor.java x: 480 lines of code y: 19 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/MantisScheduler.java x: 12 lines of code y: 6 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/MantisSchedulerFactoryImpl.java x: 53 lines of code y: 7 # 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/SLAEnforcer.java x: 91 lines of code y: 3 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/proto/JobClusterProtoAdapter.java x: 283 lines of code y: 7 # 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/master/jobcluster/job/MantisJobMetadataImpl.java x: 385 lines of code y: 9 # 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-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent/BlobStore.java x: 149 lines of code y: 5 # changes mantis-client/src/main/java/io/mantisrx/client/MantisClient.java x: 247 lines of code y: 8 # changes mantis-client/src/main/java/io/mantisrx/client/MantisSSEJob.java x: 231 lines of code y: 4 # 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-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/ExecuteStageRequestFactory.java x: 36 lines of code y: 5 # 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/TaskExecutor.java x: 568 lines of code y: 23 # changes mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent/TaskExecutorStarter.java x: 156 lines of code y: 9 # changes mantis-runtime-loader/src/main/java/io/mantisrx/runtime/loader/config/WorkerConfigurationUtils.java x: 57 lines of code y: 7 # 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/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/master/ZookeeperMasterMonitor.java x: 106 lines of code y: 10 # 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/api/akka/MasterApiAkkaService.java x: 249 lines of code y: 12 # 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/master/zk/ZookeeperLeaderElector.java x: 107 lines of code y: 1 # 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-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/master/resourcecluster/ResourceCluster.java x: 95 lines of code y: 21 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/BaseRoute.java x: 303 lines of code y: 10 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterAkkaImpl.java x: 292 lines of code y: 23 # changes mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent/ResourceManagerGatewayCxn.java x: 213 lines of code y: 6 # 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/ClutchExperimental.java x: 79 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/master/api/akka/route/v1/JobsRoute.java x: 593 lines of code y: 3 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterScalerActor.java x: 416 lines of code y: 12 # 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-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/MantisStageMetadataImpl.java x: 406 lines of code y: 6 # 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-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/proto/MantisResourceClusterSpec.java x: 105 lines of code y: 4 # changes mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent/MachineDefinitionUtils.java x: 29 lines of code y: 4 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v0/JobClusterRoute.java x: 562 lines of code y: 3 # changes mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core/domain/JobArtifact.java x: 28 lines of code y: 2 # changes mantis-runtime-executor/src/main/java/io/mantisrx/server/worker/MantisWorker.java x: 209 lines of code y: 1 # changes mantis-runtime-executor/src/main/java/io/mantisrx/server/worker/RunningWorker.java x: 301 lines of code y: 1 # changes mantis-runtime-executor/src/main/java/io/mantisrx/server/worker/scheduling/JobSchedulingTracker.java x: 95 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-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterActorMetrics.java x: 96 lines of code y: 3 # changes mantis-connectors/mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http/PushHttpSource.java x: 102 lines of code y: 4 # 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/api/akka/route/utils/JobRouteUtils.java x: 91 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/master/jobcluster/IJobClusterManager.java x: 63 lines of code y: 3 # 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: 7 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClustersAkkaImpl.java x: 78 lines of code y: 8 # changes mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/StreamManager.java x: 176 lines of code y: 4 # 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-common/src/main/java/io/mantisrx/common/metrics/MetricsServer.java x: 142 lines of code y: 6 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/MasterApiMetrics.java x: 52 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-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/executor/StageExecutors.java x: 406 lines of code y: 10 # 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/ScalarStages.java x: 35 lines of code y: 2 # changes mantis-runtime/src/main/java/io/mantisrx/runtime/Stages.java x: 34 lines of code y: 4 # 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/LoadValidateCreate.java x: 42 lines of code y: 3 # 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/MantisStreamImpl.java x: 178 lines of code y: 2 # changes mantis-runtime/src/main/java/io/mantisrx/runtime/core/sinks/ObservableSinkImpl.java x: 14 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-runtime/src/main/java/io/mantisrx/runtime/sink/ServerSentEventRequestHandler.java x: 283 lines of code y: 10 # changes mantis-runtime/src/main/java/io/mantisrx/runtime/source/http/impl/DefaultHttpServerProvider.java x: 105 lines of code y: 3 # 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/server/master/config/StaticPropertiesConfigurationFactory.java x: 47 lines of code y: 5 # 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/resourcecluster/resourceprovider/NoopResourceClusterProvider.java x: 27 lines of code y: 3 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/resourceprovider/ResourceClusterProvider.java x: 14 lines of code y: 4 # 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-connectors/mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer/config/CommitterProperties.java x: 13 lines of code y: 3 # 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/config/WriterProperties.java x: 32 lines of code y: 5 # 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: 7 # 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: 8 # changes mantis-server/mantis-server-worker-client/src/main/java/io/mantisrx/server/worker/client/WorkerMetricsClient.java x: 75 lines of code y: 4 # 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-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/AbstractSubscriptionTracker.java x: 159 lines of code y: 9 # changes mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/DefaultSubscriptionTracker.java x: 126 lines of code y: 5 # 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-core/src/main/java/io/mantisrx/publish/internal/discovery/mantisapi/DefaultMantisApiClient.java x: 115 lines of code y: 4 # 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-runtime/src/main/java/io/mantisrx/runtime/sink/Sink.java x: 20 lines of code y: 5 # 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/proto/JobArtifactProto.java x: 82 lines of code y: 2 # 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-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core/Status.java x: 134 lines of code y: 3 # changes mantis-common/src/main/java/io/mantisrx/runtime/parameter/SinkParameter.java x: 58 lines of code y: 2 # changes mantis-common/src/main/java/io/mantisrx/runtime/parameter/SinkParameters.java x: 77 lines of code y: 2 # changes mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent/Hardware.java x: 198 lines of code y: 2 # changes mantis-common/src/main/java/io/mantisrx/common/storage/StorageUnit.java x: 390 lines of code y: 1 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/NamedJob.java x: 345 lines of code y: 3 # changes mantis-common/src/main/java/io/mantisrx/runtime/descriptor/DeploymentStrategy.java x: 38 lines of code y: 5 # changes mantis-common/src/main/java/io/mantisrx/common/WorkerPorts.java x: 102 lines of code y: 11 # changes mantis-common/src/main/java/io/mantisrx/runtime/MachineDefinition.java x: 106 lines of code y: 5 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker/JobWorker.java x: 485 lines of code y: 4 # 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-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core/domain/WorkerId.java x: 118 lines of code y: 5 # changes mantis-connectors/mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/config/WriterConfig.java x: 52 lines of code y: 6 # changes mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/DynamicConnectionSet.java x: 266 lines of code y: 2 # changes mantis-connectors/mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/KafkaSource.java x: 313 lines of code y: 3 # changes mantis-connectors/mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/sink/KafkaSink.java x: 76 lines of code y: 3 # changes mantis-runtime/src/main/java/io/mantisrx/runtime/sink/Sinks.java x: 130 lines of code y: 5 # changes mantis-common/src/main/java/io/mantisrx/common/compression/CompressionUtils.java x: 329 lines of code y: 9 # 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-publish/src/main/java/io/mantisrx/connector/publish/core/QueryMap.java x: 100 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-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/SLA.java x: 152 lines of code y: 2 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/WorkerLaunchFailed.java x: 53 lines of code y: 2 # 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-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/BatchedRxEventPipelineConfigurator.java x: 207 lines of code y: 1 # changes mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/RemoteObservableConnectionHandler.java x: 384 lines of code y: 1 # changes mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/RemoteRxServer.java x: 175 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: 2 # changes mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core/StatusPayloads.java x: 98 lines of code y: 1 # changes
51.0
# changes
  min: 1.0
  average: 2.89
  25th percentile: 1.0
  median: 2.0
  75th percentile: 3.0
  max: 51.0
0 2569.0
lines of code
min: 1.0 | average: 87.74 | 25th percentile: 19.0 | median: 45.0 | 75th percentile: 97.25 | max: 2569.0

Number of Contributors vs. Number of Changes: 882 points

mantis-common/src/main/java/io/mantisrx/common/SystemParameters.java x: 2 # contributors y: 4 # changes mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core/MantisAkkaRpcSystemLoader.java x: 3 # contributors y: 4 # changes mantis-jm-akka/src/main/java/io/mantisrx/server/worker/jobmaster/akka/JobMasterServiceV2.java x: 1 # contributors y: 1 # changes mantis-runtime-executor/src/main/java/io/mantisrx/server/worker/WorkerExecutionOperationsNetworkStage.java x: 4 # contributors y: 10 # changes mantis-runtime/src/main/java/io/mantisrx/runtime/parameter/ParameterUtils.java x: 11 # contributors y: 15 # changes mantis-control-plane/mantis-control-plane-dynamodb/src/main/java/io/mantisrx/extensions/dynamodb/DynamoDBLeaderElector.java x: 3 # contributors y: 3 # changes mantis-control-plane/mantis-control-plane-dynamodb/src/main/java/io/mantisrx/extensions/dynamodb/DynamoDBClientSingleton.java x: 2 # contributors y: 2 # changes mantis-network/src/main/java/io/reactivex/mantis/network/push/PushServer.java x: 6 # contributors y: 9 # changes mantis-runtime/src/main/java/io/mantisrx/runtime/executor/WorkerPublisherRemoteObservable.java x: 4 # contributors y: 5 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/JobActor.java x: 9 # contributors y: 33 # changes mantis-common/src/main/java/io/mantisrx/common/metrics/LoggingMetricsPublisher.java x: 1 # contributors y: 2 # changes mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/MantisMasterClientApi.java x: 5 # contributors y: 12 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/JobClustersManagerActor.java x: 5 # contributors y: 9 # 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-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v0/JobDiscoveryRoute.java x: 3 # contributors y: 5 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/HttpRequestMetrics.java x: 4 # contributors y: 6 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/JobClusterActor.java x: 7 # contributors y: 35 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClustersManagerActor.java x: 4 # contributors y: 22 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/proto/ResourceClusterAPIProto.java x: 1 # contributors y: 4 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/proto/ResourceClusterScaleRuleProto.java x: 2 # contributors y: 5 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/proto/UpgradeClusterContainersResponse.java x: 1 # contributors y: 3 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/MasterMain.java x: 11 # contributors y: 31 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/DataFormatAdapter.java x: 7 # contributors y: 16 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/persistence/IMantisPersistenceProvider.java x: 5 # contributors y: 10 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/persistence/KeyValueBasedPersistenceProvider.java x: 5 # contributors y: 17 # changes mantis-server/mantis-server-worker-client/src/main/java/io/mantisrx/server/worker/client/SseWorkerConnection.java x: 11 # contributors y: 16 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ExecutorStateManagerImpl.java x: 4 # contributors y: 18 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterActor.java x: 5 # contributors y: 51 # changes mantis-connectors/mantis-connector-job-source/src/main/java/io/mantisrx/connector/job/core/AbstractJobSource.java x: 2 # contributors y: 3 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/config/MasterConfiguration.java x: 11 # contributors y: 34 # changes mantis-runtime/src/main/java/io/mantisrx/runtime/sink/ServerSentEventsSink.java x: 5 # contributors y: 7 # changes mantis-runtime/src/main/java/io/mantisrx/runtime/parameter/SourceJobParameters.java x: 5 # contributors y: 5 # changes mantis-common/src/main/java/com/mantisrx/common/utils/MantisSSEConstants.java x: 4 # contributors y: 8 # changes mantis-network/src/main/java/io/reactivex/mantis/network/push/PushServerSse.java x: 7 # contributors y: 14 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/JobClusterDefinitionImpl.java x: 5 # contributors y: 6 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/TaskExecutorState.java x: 2 # contributors y: 10 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/ResourceClusterAwareSchedulerActor.java x: 4 # contributors y: 19 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/MantisSchedulerFactoryImpl.java x: 3 # contributors y: 7 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/ResourceClusterAwareScheduler.java x: 4 # contributors y: 7 # 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/master/jobcluster/JobDefinitionResolver.java x: 4 # contributors y: 4 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/MantisJobMetadataImpl.java x: 4 # contributors y: 9 # 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-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/events/WorkerMetricsCollector.java x: 2 # contributors y: 6 # changes mantis-common/src/main/java/io/mantisrx/runtime/descriptor/SchedulingInfo.java x: 5 # contributors y: 15 # changes mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent/TaskExecutor.java x: 5 # contributors y: 23 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/MasterApiAkkaService.java x: 8 # contributors y: 12 # changes mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/master/resourcecluster/ResourceCluster.java x: 3 # contributors y: 21 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/BaseRoute.java x: 3 # contributors y: 10 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterAkkaImpl.java x: 3 # contributors y: 23 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/ResourceClustersNonLeaderRedirectRoute.java x: 3 # contributors y: 14 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterScalerActor.java x: 3 # contributors y: 12 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClustersHostManagerActor.java x: 2 # contributors y: 9 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterGatewayAkkaImpl.java x: 2 # contributors y: 7 # changes mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClustersAkkaImpl.java x: 2 # contributors y: 8 # changes mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/worker/TaskExecutorGateway.java x: 5 # 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-runtime/src/main/java/io/mantisrx/runtime/sink/ServerSentEventRequestHandler.java x: 6 # 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-connectors/mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/IcebergWriterStage.java x: 6 # contributors y: 14 # changes mantis-runtime/src/main/java/io/mantisrx/runtime/scheduler/MantisRxSingleThreadScheduler.java x: 4 # contributors y: 3 # changes
51.0
# changes
  min: 1.0
  average: 2.89
  25th percentile: 1.0
  median: 2.0
  75th percentile: 3.0
  max: 51.0
0 11.0
# contributors
min: 1.0 | average: 1.99 | 25th percentile: 1.0 | median: 2.0 | 75th percentile: 2.0 | max: 11.0

Number of Contributors vs. File Size: 882 points

mantis-common/src/main/java/io/mantisrx/common/SystemParameters.java x: 2 # contributors y: 22 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/JobMasterServiceV2.java x: 1 # contributors y: 34 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/PerpetualRuleActor.java x: 1 # contributors y: 28 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/ScalerControllerActor.java x: 1 # contributors y: 231 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/AutoScaleMetricsConfig.java x: 1 # contributors y: 150 lines of code mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/JobAutoScaler.java x: 1 # contributors y: 540 lines of code mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/JobAutoScalerService.java x: 1 # contributors y: 4 lines of code mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/WorkerMetricHandler.java x: 1 # contributors y: 420 lines of code mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/WorkerMetricSubscription.java x: 1 # contributors y: 64 lines of code mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/clutch/ClutchAutoScaler.java x: 1 # contributors y: 184 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/clutch/rps/RpsMetricComputer.java x: 1 # contributors y: 14 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-runtime/src/main/java/io/mantisrx/runtime/parameter/ParameterUtils.java x: 11 # contributors y: 294 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-control-plane/mantis-control-plane-dynamodb/src/main/java/io/mantisrx/extensions/dynamodb/DynamoDBClientSingleton.java x: 2 # contributors y: 134 lines of code mantis-control-plane/mantis-control-plane-dynamodb/src/main/java/io/mantisrx/extensions/dynamodb/DynamoDBConfig.java x: 3 # contributors y: 48 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-network/src/main/java/io/reactivex/mantis/network/push/Routers.java x: 3 # contributors y: 88 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-executor/src/main/java/io/mantisrx/server/worker/config/StaticPropertiesConfigurationFactory.java x: 2 # contributors y: 20 lines of code mantis-runtime/src/main/java/io/mantisrx/runtime/executor/WorkerPublisherRemoteObservable.java x: 4 # contributors y: 181 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/JobActor.java x: 9 # contributors y: 1798 lines of code mantis-control-plane/mantis-control-plane-dynamodb/src/main/java/io/mantisrx/extensions/dynamodb/DynamoDBMasterMonitorSingleton.java x: 3 # contributors y: 159 lines of code mantis-common-akka/src/main/java/io/mantisrx/common/akka/DeadLetterActor.java x: 1 # contributors y: 44 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-client/src/main/java/io/mantisrx/server/master/client/MantisMasterClientApi.java x: 5 # contributors y: 660 lines of code mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/MantisMasterGateway.java x: 2 # contributors y: 62 lines of code mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/master/resourcecluster/ClusterID.java x: 2 # contributors y: 10 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/JobClustersManagerActor.java x: 5 # contributors y: 918 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/handlers/JobClusterRouteHandler.java x: 3 # contributors y: 27 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/handlers/JobClusterRouteHandlerAkkaImpl.java x: 3 # contributors y: 142 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/handlers/JobDiscoveryRouteHandlerAkkaImpl.java x: 3 # contributors y: 231 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/utils/StreamingUtils.java x: 3 # contributors y: 66 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/HttpRequestMetrics.java x: 4 # contributors y: 105 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobClustersRoute.java x: 3 # contributors y: 596 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/JobClusterActor.java x: 7 # contributors y: 2569 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/ResourceClustersManagerActor.java x: 4 # contributors y: 219 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/MasterMain.java x: 11 # contributors y: 245 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/DataFormatAdapter.java x: 7 # contributors y: 679 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-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/persistence/KeyValueBasedPersistenceProvider.java x: 5 # contributors y: 813 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/persistence/MantisJobStore.java x: 5 # contributors y: 288 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-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ExecutorStateManagerImpl.java x: 4 # contributors y: 517 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterActor.java x: 5 # contributors y: 1135 lines of code mantis-connectors/mantis-connector-job-source/src/main/java/io/mantisrx/connector/job/core/AbstractJobSource.java x: 2 # contributors y: 73 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/config/MasterConfiguration.java x: 11 # contributors y: 265 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/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-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/JobClusterDefinitionImpl.java x: 5 # contributors y: 366 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/proto/JobClusterManagerProto.java x: 5 # contributors y: 1841 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/TaskExecutorState.java x: 2 # contributors y: 247 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker/IMantisWorkerMetadata.java x: 3 # contributors y: 51 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-server/mantis-server-worker-client/src/main/java/io/mantisrx/server/worker/client/MantisHttpClientImpl.java x: 3 # contributors y: 96 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/server/master/scheduler/MantisScheduler.java x: 5 # contributors y: 12 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-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/proto/JobClusterProtoAdapter.java x: 5 # contributors y: 283 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/JobDefinitionResolver.java x: 4 # contributors y: 152 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/MantisJobMetadataImpl.java x: 4 # contributors y: 385 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/JobClusterConfig.java x: 3 # contributors y: 117 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-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-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core/ExecuteStageRequest.java x: 5 # contributors y: 109 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/ExecuteStageRequestFactory.java x: 3 # contributors y: 36 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/TaskExecutor.java x: 5 # contributors y: 568 lines of code mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent/TaskExecutorStarter.java x: 5 # 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/master/api/akka/MasterApiAkkaService.java x: 8 # contributors y: 249 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/zk/LeaderElector.java x: 4 # contributors y: 132 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/KeyValueStore.java x: 3 # contributors y: 107 lines of code mantis-runtime-executor/src/main/java/io/mantisrx/server/worker/RuntimeTaskImpl.java x: 2 # contributors y: 180 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/BaseRoute.java x: 3 # contributors y: 303 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterAkkaImpl.java x: 3 # contributors y: 292 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/jobcluster/job/MantisStageMetadataImpl.java x: 5 # contributors y: 406 lines of code mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent/MachineDefinitionUtils.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/MantisMasterRoute.java x: 4 # contributors y: 90 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v0/JobClusterRoute.java x: 3 # contributors y: 562 lines of code mantis-runtime-executor/src/main/java/io/mantisrx/server/worker/DataDroppedPayloadSetter.java x: 1 # contributors y: 92 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/RunningWorker.java x: 1 # contributors y: 301 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-client/src/main/java/io/mantisrx/client/SinkClientImpl.java x: 3 # contributors y: 251 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/AgentV2Main.java x: 3 # contributors y: 130 lines of code mantis-runtime/src/main/java/io/mantisrx/runtime/executor/SinkPublisher.java x: 4 # contributors y: 99 lines of code mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent/HadoopFileSystemBlobStore.java x: 4 # 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-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/MasterApiMetrics.java x: 2 # contributors y: 52 lines of code mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/worker/TaskExecutorGateway.java x: 5 # contributors y: 34 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-runtime/src/main/java/io/mantisrx/runtime/sink/ServerSentEventRequestHandler.java x: 6 # contributors y: 283 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-common/src/main/java/io/mantisrx/runtime/descriptor/StageSchedulingInfo.java x: 4 # contributors y: 131 lines of code mantis-network/src/main/java/io/reactivex/mantis/network/push/ObservableTrigger.java x: 3 # contributors y: 276 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/handlers/ResourceClusterRouteHandlerAkkaImpl.java x: 2 # contributors y: 98 lines of code mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/discovery/MantisJobDiscoveryCachingImpl.java x: 2 # contributors y: 166 lines of code mantis-publish/mantis-publish-netty/src/main/java/io/mantisrx/publish/netty/transmitters/ChoiceOfTwoWorkerPool.java x: 2 # contributors y: 145 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-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent/Hardware.java x: 2 # contributors y: 198 lines of code mantis-common/src/main/java/io/mantisrx/common/storage/StorageUnit.java x: 1 # contributors y: 390 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/NamedJob.java x: 3 # contributors y: 345 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker/JobWorker.java x: 3 # contributors y: 485 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-connectors/mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/KafkaSource.java x: 2 # contributors y: 313 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/reactivx/mantis/operators/BufferOnBackPressureOperator.java x: 1 # contributors y: 201 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/master/api/akka/route/v0/JobRoute.java x: 2 # contributors y: 315 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 mantis-server/mantis-server-worker-client/src/main/java/io/mantisrx/server/worker/client/MetricsClientImpl.java x: 2 # contributors y: 259 lines of code
2569.0
lines of code
  min: 1.0
  average: 87.74
  25th percentile: 19.0
  median: 45.0
  75th percentile: 97.25
  max: 2569.0
0 11.0
# contributors
min: 1.0 | average: 1.99 | 25th percentile: 1.0 | median: 2.0 | 75th percentile: 2.0 | max: 11.0