Netflix/mantis
File Size
The distribution of size of files (measured in lines of code).
File Size Overall
  • There are 1,016 files with 84,431 lines of code.
    • 4 very long files (7,885 lines of code)
    • 16 long files (10,288 lines of code)
    • 71 medium size files (20,926 lines of code)
    • 134 small files (18,137 lines of code)
    • 791 very small files (27,195 lines of code)
9% | 12% | 24% | 21% | 32%
Legend:
1001+
501-1000
201-500
101-200
1-100


explore: grouped by folders | grouped by size | sunburst | 3D view
File Size per Extension
1001+
501-1000
201-500
101-200
1-100
java9% | 12% | 24% | 21% | 32%
xml0% | 0% | 96% | 0% | 3%
html0% | 0% | 0% | 0% | 100%
jsp0% | 0% | 0% | 0% | 100%
yaml0% | 0% | 0% | 0% | 100%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
mantis-control-plane19% | 18% | 23% | 16% | 21%
mantis-remote-observable0% | 14% | 32% | 15% | 36%
mantis-runtime-executor0% | 24% | 33% | 13% | 27%
mantis-server0% | 20% | 29% | 26% | 23%
mantis-runtime0% | 7% | 22% | 15% | 54%
mantis-runtime-autoscaler-api0% | 19% | 15% | 35% | 29%
mantis-common0% | 0% | 29% | 29% | 41%
mantis-connectors0% | 0% | 23% | 27% | 48%
mantis-network0% | 0% | 35% | 27% | 37%
mantis-client0% | 0% | 72% | 21% | 5%
.baseline0% | 0% | 100% | 0% | 0%
mantis-jm-akka0% | 0% | 54% | 31% | 13%
mantis-publish0% | 0% | 8% | 43% | 47%
mantis-runtime-loader0% | 0% | 20% | 33% | 45%
mantis-source-jobs0% | 0% | 0% | 36% | 63%
mantis-rxcontrol0% | 0% | 0% | 40% | 60%
mantis-examples0% | 0% | 0% | 31% | 68%
mantis-discovery-proto0% | 0% | 0% | 36% | 63%
mantis-common-akka0% | 0% | 0% | 0% | 100%
mantis-common-serde0% | 0% | 0% | 0% | 100%
.github0% | 0% | 0% | 0% | 100%
Longest Files (Top 50)
File# lines# units
JobClusterActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster
 2641 134
JobActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job
 2213 99
JobClusterManagerProto.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto
 1888 231
ExecutorStateManagerActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster
 1143 56
JobClustersManagerActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master
 962 67
ResourceClusterActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster
 895 40
KeyValueBasedPersistenceProvider.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/persistence
 863 70
DataFormatAdapter.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain
 681 51
MantisMasterClientApi.java
in mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client
 666 32
ExecutorStateManagerImpl.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster
 664 25
JobClustersRoute.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1
 629 20
ReservationRegistryActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster
 604 37
RemoteObservable.java
in mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable
 577 33
WorkerExecutionOperationsNetworkStage.java
in mantis-runtime-executor/src/main/java/io/mantisrx/server/worker
 567 18
TaskExecutor.java
in mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent
 565 40
HttpSourceImpl.java
in mantis-runtime/src/main/java/io/mantisrx/runtime/source/http/impl
 550 39
JobAutoScaler.java
in mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster
 545 20
JobWorker.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker
 509 25
JobClusterRoute.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v0
 506 6
JobsRoute.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1
 505 17
ResourceClusterAwareSchedulerActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler
 480 37
476 -
MantisStageMetadataImpl.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job
 466 44
ResourceClusterScalerActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster
 466 21
WorkerMetricHandler.java
in mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster
 444 13
ResourceClustersNonLeaderRedirectRoute.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1
 422 22
MantisJobMetadataImpl.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job
 409 55
StageExecutors.java
in mantis-runtime/src/main/java/io/mantisrx/runtime/executor
 406 7
PushServer.java
in mantis-network/src/main/java/io/reactivex/mantis/network/push
 396 11
StorageUnit.java
in mantis-common/src/main/java/io/mantisrx/common/storage
 390 87
JobClusterDefinitionImpl.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain
 384 45
RemoteObservableConnectionHandler.java
in mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable
 384 8
BaseRoute.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1
 366 14
NamedJob.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store
 355 52
ResourceClustersHostManagerActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster
 355 15
JobDefinition.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain
 341 39
SseWorkerConnection.java
in mantis-server/mantis-server-worker-client/src/main/java/io/mantisrx/server/worker/client
 341 16
SampleArchaiusMrePublishConfiguration.java
in mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/config
 340 37
LocalJobExecutorNetworked.java
in mantis-runtime/src/main/java/io/mantisrx/runtime/executor
 339 9
ResourceClusterAkkaImpl.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster
 338 20
CompressionUtils.java
in mantis-common/src/main/java/io/mantisrx/common/compression
 329 15
MantisWorkerMetadataImpl.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker
 315 45
JobRoute.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v0
 315 5
RunningWorker.java
in mantis-runtime-executor/src/main/java/io/mantisrx/server/worker
 314 46
KafkaSource.java
in mantis-connectors/mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source
 313 7
AssignmentHandlerActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster
 306 13
MasterClientWrapper.java
in mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client
 300 20
MasterApiAkkaService.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka
 297 7
ResourceClustersManagerActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster
 295 11
ParameterUtils.java
in mantis-runtime/src/main/java/io/mantisrx/runtime/parameter
 294 8
Large Files That Change Often (Top 20)
To change a file, an AI coding agent (or a person) has to read it: these files are read the most for the changes in the past year (lines × changes).
File# lines≈ tokens
to read		# changes
(1y)		≈ lines edited
per change		lines read per
line changed
JobActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job
 2213 ~15k–50k 5 ~150 ~15
JobClusterActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster
 2641 ~15k–50k 4 ~200 ~15
ExecutorStateManagerActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster
 1143 ~7k–20k 4 ~300 ~3
ResourceClusterActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster
 895 ~5k–15k 3 ~70 ~15
JobWorker.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker
 509 ~3k–10k 4 ~200 ~3
JobClustersManagerActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master
 962 ~5k–15k 2 ~200 ~5
JobClusterManagerProto.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto
 1888 ~10k–30k 1 ~300 ~7
ReservationRegistryActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster
 604 ~3k–10k 3 ~300 ~2
ExecutorStateManagerImpl.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster
 664 ~3k–10k 2 ~50 ~15
JobClustersRoute.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1
 629 ~3k–10k 2 ~200 ~3
KeyValueBasedPersistenceProvider.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/persistence
 863 ~5k–15k 1 ~70 ~15
MasterConfiguration.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/config
 281 ~1.5k–5k 3 ~20 ~15
BaseRoute.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1
 366 ~2k–7k 2 ~70 ~5
DataFormatAdapter.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain
 681 ~3k–10k 1 ~100 ~7
MantisMasterClientApi.java
in mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client
 666 ~3k–10k 1 ~150 ~5
ResourceClustersManagerActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster
 295 ~2k–5k 2 ~15 ~15
MantisJobDefinition.java
in mantis-common/src/main/java/io/mantisrx/runtime
 289 ~2k–5k 2 ~20 ~15
JobAutoScaler.java
in mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster
 545 ~3k–10k 1 ~300 ~2
JobsRoute.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1
 505 ~3k–10k 1 ~300 ~2
ResourceClusterAwareSchedulerActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler
 480 ~3k–7k 1 ~50 ~10

Tokens are lines × 7 to 14 (analysis.fileReadsForChanges). Lines edited per change are the file's lines added and deleted divided by its commits over the whole history. Agents read about 2,000 lines at a time: when a 17,000-line file was split into modules, the tokens an agent read for the same change fell by 83% (The Economic Benefit of Refactoring, 2026).

Files With Most Units (Top 50)
File# lines# units
JobClusterManagerProto.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto
 1888 231
JobClusterActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster
 2641 134
JobActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job
 2213 99
StorageUnit.java
in mantis-common/src/main/java/io/mantisrx/common/storage
 390 87
KeyValueBasedPersistenceProvider.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/persistence
 863 70
JobClustersManagerActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master
 962 67
ExecutorStateManagerActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster
 1143 56
MantisJobMetadataImpl.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job
 409 55
NamedJob.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store
 355 52
DataFormatAdapter.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain
 681 51
MantisWorkerMetadataWritable.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store
 283 47
RunningWorker.java
in mantis-runtime-executor/src/main/java/io/mantisrx/server/worker
 314 46
JobClusterDefinitionImpl.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain
 384 45
MantisWorkerMetadataImpl.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker
 315 45
MantisStageMetadataImpl.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job
 466 44
MantisJobStore.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/persistence
 279 43
WorkerConfigurationWritable.java
in mantis-runtime-loader/src/main/java/io/mantisrx/runtime/loader/config
 225 41
ResourceClusterActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster
 895 40
TaskExecutor.java
in mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent
 565 40
JobDefinition.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain
 341 39
HttpSourceImpl.java
in mantis-runtime/src/main/java/io/mantisrx/runtime/source/http/impl
 550 39
MantisJobDefinition.java
in mantis-common/src/main/java/io/mantisrx/runtime
 289 38
HttpClientListener.java
in mantis-common/src/main/java/io/mantisrx/common/metrics/netty
 180 37
ResourceClusterAwareSchedulerActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler
 480 37
ReservationRegistryActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster
 604 37
SampleArchaiusMrePublishConfiguration.java
in mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/config
 340 37
RemoteObservable.java
in mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable
 577 33
MantisJobClusterMetadataView.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster
 230 32
TaskExecutorState.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster
 269 32
MantisMasterClientApi.java
in mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client
 666 32
WorkerRequest.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master
 170 30
HttpServerListener.java
in mantis-common/src/main/java/io/mantisrx/common/metrics/netty
 140 28
Metrics.java
in mantis-common/src/main/java/io/mantisrx/common/metrics
 205 28
MantisKafkaConsumer.java
in mantis-connectors/mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source
 250 27
TcpServerListener.java
in mantis-common/src/main/java/io/mantisrx/common/metrics/netty
 148 26
ServerConfig.java
in mantis-network/src/main/java/io/reactivex/mantis/network/push
 138 26
RxMetrics.java
in mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable
 110 26
JobWorker.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker
 509 25
ExecutorStateManagerImpl.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster
 664 25
MantisSSEJob.java
in mantis-client/src/main/java/io/mantisrx/client
 231 24
TcpClientListener.java
in mantis-common/src/main/java/io/mantisrx/common/metrics/netty
 191 24
JobClusterProtoAdapter.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/proto
 285 24
MantisStageMetadataWritable.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store
 188 23
Status.java
in mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core
 134 23
ServerSentEventsSink.java
in mantis-runtime/src/main/java/io/mantisrx/runtime/sink
 240 23
MantisClient.java
in mantis-client/src/main/java/io/mantisrx/client
 247 22
ResourceClustersNonLeaderRedirectRoute.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1
 422 22
SchedulingInfo.java
in mantis-common/src/main/java/io/mantisrx/runtime/descriptor
 205 21
JobClusterProto.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto
 182 21
ResourceClusterScalerActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster
 466 21
Files With Long Lines (Top 50)

There are 295 files with lines longer than 120 characters. In total, there are 1801 long lines.

File# lines# units# long lines
JobClusterActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster
 2641 134 215
JobClustersManagerActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master
 962 67 106
RemoteObservable.java
in mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable
 577 33 49
WorkerExecutionOperationsNetworkStage.java
in mantis-runtime-executor/src/main/java/io/mantisrx/server/worker
 567 18 46
JobClusterRoute.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v0
 506 6 38
JobClusterRouteHandlerAkkaImpl.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/handlers
 148 19 37
ExecutorStateManagerActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster
 1143 56 30
DataFormatAdapter.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain
 681 51 28
PushServer.java
in mantis-network/src/main/java/io/reactivex/mantis/network/push
 396 11 28
StageExecutors.java
in mantis-runtime/src/main/java/io/mantisrx/runtime/executor
 406 7 27
WorkerMetricHandler.java
in mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster
 444 13 25
JobDefinitionResolver.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster
 152 5 23
JobDiscoveryRouteHandlerAkkaImpl.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/handlers
 231 7 22
DynamicConnectionSet.java
in mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable
 266 15 22
KeyValueBasedPersistenceProvider.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/persistence
 863 70 19
JobAutoScaler.java
in mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster
 545 20 19
ExecutorStateManagerImpl.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster
 664 25 18
JobRoute.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v0
 315 5 18
LocalJobExecutorNetworked.java
in mantis-runtime/src/main/java/io/mantisrx/runtime/executor
 339 9 18
PushServerSse.java
in mantis-network/src/main/java/io/reactivex/mantis/network/push
 262 3 18
MantisKafkaSourceConfig.java
in mantis-connectors/mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source
 127 13 17
JobClusterRouteHandler.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/handlers
 29 - 16
MasterClientWrapper.java
in mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client
 300 20 16
JobActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job
 2213 99 15
JobsRoute.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1
 505 17 15
AbstractSourceJobSource.java
in mantis-connectors/mantis-connector-job-source/src/main/java/io/mantisrx/connector/job/core
 64 8 15
PushServers.java
in mantis-network/src/main/java/io/reactivex/mantis/network/push
 77 6 15
MasterMain.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master
 254 10 14
KafkaSource.java
in mantis-connectors/mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source
 313 7 14
Reconciliator.java
in mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/reconciliator
 207 9 14
ClutchAutoScaler.java
in mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/clutch
 173 7 14
JobListHelperActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master
 187 13 13
RemoteObservableConnectionHandler.java
in mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable
 384 8 13
ResourceClusterActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster
 895 40 12
ReservationRegistryActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster
 604 37 12
ServeGroupedObservable.java
in mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable
 221 14 12
ResourceClusterScalerActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster
 466 21 11
MantisKafkaConsumer.java
in mantis-connectors/mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source
 250 27 11
MantisClient.java
in mantis-client/src/main/java/io/mantisrx/client
 247 22 10
OnSubscribeRedo.java
in mantis-common/src/main/java/io/reactivx/mantis/operators
 246 18 10
Metrics.java
in mantis-common/src/main/java/io/mantisrx/common/metrics
 205 28 10
ResourceClusterAwareSchedulerActor.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler
 480 37 10
MantisJobMetadataView.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job
 152 12 10
JobArtifactRouteHandlerImpl.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/handlers
 56 4 10
DefaultMantisApiClient.java
in mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/discovery/mantisapi
 115 4 10
ClientResumePolicies.java
in mantis-runtime/src/main/java/io/mantisrx/runtime/source/http
 72 4 10
ParameterUtils.java
in mantis-runtime/src/main/java/io/mantisrx/runtime/parameter
 294 8 10
HttpRequestMetrics.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1
 107 3 9
JobRouteUtils.java
in mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/utils
 200 2 9
DynamoDBStore.java
in mantis-control-plane/mantis-control-plane-dynamodb/src/main/java/io/mantisrx/extensions/dynamodb
 233 13 9
Correlations

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

mantis-common/src/main/java/io/mantisrx/config/dynamic/DynamicProperty.java x: 2 commits (all time) y: 55 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/MasterApiAkkaService.java x: 14 commits (all time) y: 297 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/BaseRoute.java x: 13 commits (all time) y: 366 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobsRoute.java x: 6 commits (all time) y: 505 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/utils/ApiRequestRateLimiter.java x: 1 commits (all time) y: 11 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/utils/ApiRequestRateLimiterFactory.java x: 1 commits (all time) y: 46 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/MasterMain.java x: 35 commits (all time) y: 254 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/config/MasterConfiguration.java x: 45 commits (all time) y: 281 lines of code mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/clutch/ClutchAutoScaler.java x: 2 commits (all time) y: 173 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/JobActor.java x: 50 commits (all time) y: 2213 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/MantisJobClusterMetadataView.java x: 5 commits (all time) y: 230 lines of code mantis-common/src/main/java/io/mantisrx/runtime/MantisJobDefinition.java x: 8 commits (all time) y: 289 lines of code mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/MantisMasterClientApi.java x: 14 commits (all time) y: 666 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/IWorkerManager.java x: 5 commits (all time) y: 41 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/MantisJobMetadataImpl.java x: 11 commits (all time) y: 409 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/MantisStageMetadataImpl.java x: 9 commits (all time) y: 466 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/JobClusterActor.java x: 43 commits (all time) y: 2641 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ExecutorStateManagerActor.java x: 4 commits (all time) y: 1143 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/JobClustersManagerActor.java x: 13 commits (all time) y: 962 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/handlers/JobClusterRouteHandler.java x: 6 commits (all time) y: 29 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/handlers/JobClusterRouteHandlerAkkaImpl.java x: 6 commits (all time) y: 148 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/HttpRequestMetrics.java x: 8 commits (all time) y: 107 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobClustersRoute.java x: 8 commits (all time) y: 629 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobClusterManagerProto.java x: 16 commits (all time) y: 1888 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ReservationRegistryActor.java x: 3 commits (all time) y: 604 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterActorMetrics.java x: 7 commits (all time) y: 88 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/ResourceClusterAwareSchedulerActor.java x: 21 commits (all time) y: 480 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterActor.java x: 61 commits (all time) y: 895 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClustersManagerActor.java x: 25 commits (all time) y: 295 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker/JobWorker.java x: 9 commits (all time) y: 509 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/persistence/KeyValueBasedPersistenceProvider.java x: 19 commits (all time) y: 863 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/persistence/MantisJobStore.java x: 19 commits (all time) y: 279 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ExecutorStateManagerImpl.java x: 25 commits (all time) y: 664 lines of code mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/master/resourcecluster/ResourceCluster.java x: 22 commits (all time) y: 118 lines of code mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/master/resourcecluster/ResourceClusters.java x: 2 commits (all time) y: 9 lines of code mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/master/resourcecluster/proto/MantisResourceClusterReservationProto.java x: 1 commits (all time) y: 146 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobProto.java x: 4 commits (all time) y: 170 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/AssignmentHandlerActor.java x: 1 commits (all time) y: 306 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ExecutorStateManager.java x: 7 commits (all time) y: 55 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterAkkaImpl.java x: 24 commits (all time) y: 338 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterScalerActor.java x: 14 commits (all time) y: 466 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClustersAkkaImpl.java x: 9 commits (all time) y: 88 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/TaskAssignmentManagerActor.java x: 1 commits (all time) y: 3 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/TaskExecutorState.java x: 12 commits (all time) y: 269 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/proto/GetClusterUsageResponse.java x: 3 commits (all time) y: 25 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/ExecuteStageRequestFactory.java x: 6 commits (all time) y: 65 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/MantisScheduler.java x: 8 commits (all time) y: 22 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/MantisSchedulerFactory.java x: 3 commits (all time) y: 18 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/MantisSchedulerFactoryImpl.java x: 9 commits (all time) y: 62 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/ResourceClusterReservationAwareScheduler.java x: 1 commits (all time) y: 70 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/Jackson.java x: 7 commits (all time) y: 149 lines of code mantis-common/src/main/java/io/mantisrx/runtime/JobPrincipal.java x: 1 commits (all time) y: 32 lines of code mantis-common/src/main/java/io/mantisrx/runtime/NamedJobDefinition.java x: 4 commits (all time) y: 38 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/proto/JobClusterProtoAdapter.java x: 10 commits (all time) y: 285 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/DataFormatAdapter.java x: 20 commits (all time) y: 681 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/IJobClusterDefinition.java x: 4 commits (all time) y: 22 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/JobClusterDefinitionImpl.java x: 8 commits (all time) y: 384 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/NamedJob.java x: 5 commits (all time) y: 355 lines of code mantis-control-plane/mantis-control-plane-dynamodb/src/main/java/io/mantisrx/extensions/dynamodb/DynamoDBClientSingleton.java x: 3 commits (all time) y: 133 lines of code mantis-common/src/main/java/io/mantisrx/common/SystemParameters.java x: 5 commits (all time) y: 23 lines of code mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/JobAutoScaler.java x: 2 commits (all time) y: 545 lines of code mantis-jm-akka/src/main/java/io/mantisrx/server/worker/jobmaster/akka/rules/ScalerControllerActor.java x: 2 commits (all time) y: 236 lines of code mantis-server/mantis-server-worker-client/src/main/java/io/mantisrx/server/worker/client/MetricsClientImpl.java x: 4 commits (all time) y: 259 lines of code mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/JobMasterService.java x: 2 commits (all time) y: 150 lines of code mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/WorkerMetricHandler.java x: 2 commits (all time) y: 444 lines of code mantis-runtime-executor/src/main/java/io/mantisrx/server/worker/RunningWorker.java x: 3 commits (all time) y: 314 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/utils/JobRouteUtils.java x: 6 commits (all time) y: 200 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v0/JobClusterRoute.java x: 5 commits (all time) y: 506 lines of code mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent/TaskExecutor.java x: 25 commits (all time) y: 565 lines of code mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/DefaultSubscriptionTracker.java x: 7 commits (all time) y: 126 lines of code mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/EventProcessor.java x: 5 commits (all time) y: 120 lines of code mantis-runtime/src/main/java/io/mantisrx/runtime/parameter/ParameterUtils.java x: 17 commits (all time) y: 294 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker/WorkerState.java x: 4 commits (all time) y: 94 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/DisableTaskExecutorsRequest.java x: 5 commits (all time) y: 48 lines of code mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/EventDrainer.java x: 5 commits (all time) y: 103 lines of code mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/StreamManager.java x: 9 commits (all time) y: 178 lines of code mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/api/Event.java x: 6 commits (all time) y: 106 lines of code mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/discovery/mantisapi/DefaultMantisApiClient.java x: 6 commits (all time) y: 115 lines of code mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/mql/MQL.java x: 4 commits (all time) y: 47 lines of code mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/mql/MQLSubscription.java x: 8 commits (all time) y: 129 lines of code mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core/MantisAkkaRpcSystemLoader.java x: 4 commits (all time) y: 71 lines of code mantis-jm-akka/src/main/java/io/mantisrx/server/worker/jobmaster/akka/rules/CoordinatorActor.java x: 1 commits (all time) y: 222 lines of code mantis-jm-akka/src/main/java/io/mantisrx/server/worker/jobmaster/akka/rules/CustomRuleActor.java x: 1 commits (all time) y: 126 lines of code mantis-jm-akka/src/main/java/io/mantisrx/server/worker/jobmaster/akka/rules/PerpetualRuleActor.java x: 1 commits (all time) y: 28 lines of code mantis-jm-akka/src/main/java/io/mantisrx/server/worker/jobmaster/akka/rules/RuleUtils.java x: 1 commits (all time) y: 53 lines of code mantis-jm-akka/src/main/java/io/mantisrx/server/worker/jobmaster/akka/rules/ScheduleRuleActor.java x: 1 commits (all time) y: 138 lines of code mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/clutch/ClutchConfiguration.java x: 1 commits (all time) y: 157 lines of code mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/clutch/rps/ClutchRpsPIDConfig.java x: 1 commits (all time) y: 76 lines of code mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/clutch/rps/RpsClutchConfigurationSelector.java x: 1 commits (all time) y: 116 lines of code mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/control/AdaptiveAutoscalerConfig.java x: 1 commits (all time) y: 105 lines of code mantis-runtime-executor/src/main/java/io/mantisrx/server/worker/WorkerExecutionOperationsNetworkStage.java x: 10 commits (all time) y: 567 lines of code mantis-control-plane/mantis-control-plane-dynamodb/src/main/java/io/mantisrx/extensions/dynamodb/DynamoDBLeaderElector.java x: 4 commits (all time) y: 141 lines of code mantis-control-plane/mantis-control-plane-dynamodb/src/main/java/io/mantisrx/extensions/dynamodb/DynamoDBConfig.java x: 3 commits (all time) y: 48 lines of code mantis-network/src/main/java/io/reactivex/mantis/network/push/PushServer.java x: 9 commits (all time) y: 396 lines of code mantis-network/src/main/java/io/reactivex/mantis/network/push/LegacyTcpPushServer.java x: 4 commits (all time) y: 135 lines of code mantis-network/src/main/java/io/reactivex/mantis/network/push/Routers.java x: 3 commits (all time) y: 88 lines of code mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/ConnectToObservable.java x: 2 commits (all time) y: 108 lines of code mantis-runtime-executor/src/main/java/io/mantisrx/server/worker/config/StaticPropertiesConfigurationFactory.java x: 2 commits (all time) y: 20 lines of code mantis-runtime/src/main/java/io/mantisrx/runtime/executor/WorkerConsumerRemoteObservable.java x: 3 commits (all time) y: 72 lines of code mantis-runtime/src/main/java/io/mantisrx/runtime/executor/WorkerPublisherRemoteObservable.java x: 5 commits (all time) y: 181 lines of code mantis-common/src/main/java/io/mantisrx/common/metrics/LoggingMetricsPublisher.java x: 2 commits (all time) y: 39 lines of code mantis-common/src/main/java/io/mantisrx/runtime/descriptor/JobScalingRule.java x: 1 commits (all time) y: 91 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/handlers/JobDiscoveryRouteHandler.java x: 4 commits (all time) 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: 7 commits (all time) y: 231 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/utils/JobDiscoveryHeartbeats.java x: 3 commits (all time) y: 9 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v0/JobDiscoveryRoute.java x: 6 commits (all time) y: 224 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/JobHelper.java x: 4 commits (all time) y: 81 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/BaseResponse.java x: 3 commits (all time) y: 38 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/proto/ResourceClusterScaleRuleProto.java x: 5 commits (all time) y: 82 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/persistence/IMantisPersistenceProvider.java x: 10 commits (all time) y: 81 lines of code mantis-server/mantis-server-worker-client/src/main/java/io/mantisrx/server/worker/client/SseWorkerConnection.java x: 22 commits (all time) y: 341 lines of code mantis-connectors/mantis-connector-job-source/src/main/java/io/mantisrx/connector/job/core/AbstractJobSource.java x: 3 commits (all time) y: 73 lines of code mantis-runtime/src/main/java/io/mantisrx/runtime/sink/ServerSentEventsSink.java x: 7 commits (all time) y: 240 lines of code mantis-connectors/mantis-connector-job-source/src/main/java/io/mantisrx/connector/job/core/AbstractSourceJobSource.java x: 2 commits (all time) y: 64 lines of code mantis-connectors/mantis-connector-job-source/src/main/java/io/mantisrx/connector/job/source/JobSource.java x: 2 commits (all time) y: 281 lines of code mantis-runtime/src/main/java/io/mantisrx/runtime/parameter/SourceJobParameters.java x: 5 commits (all time) y: 191 lines of code mantis-common/src/main/java/com/mantisrx/common/utils/MantisSSEConstants.java x: 8 commits (all time) y: 18 lines of code mantis-network/src/main/java/io/reactivex/mantis/network/push/AsyncConnection.java x: 2 commits (all time) y: 90 lines of code mantis-network/src/main/java/io/reactivex/mantis/network/push/PushServerSse.java x: 16 commits (all time) y: 262 lines of code mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/RemoteObservable.java x: 2 commits (all time) y: 577 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/worker/MantisWorkerMetadataImpl.java x: 5 commits (all time) y: 315 lines of code mantis-server/mantis-server-worker-client/src/main/java/io/mantisrx/server/worker/client/MantisHttpClientImpl.java x: 6 commits (all time) y: 96 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/scheduler/ResourceClusterAwareScheduler.java x: 7 commits (all time) y: 50 lines of code mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/resourcecluster/ResourceClusterGatewayClient.java x: 7 commits (all time) y: 112 lines of code mantis-runtime-loader/src/main/java/io/mantisrx/runtime/loader/config/WorkerConfiguration.java x: 14 commits (all time) y: 128 lines of code mantis-runtime/src/main/java/io/mantisrx/runtime/KeyValueStageConfig.java x: 2 commits (all time) y: 21 lines of code mantis-runtime/src/main/java/io/mantisrx/runtime/ScalarToGroup.java x: 6 commits (all time) y: 89 lines of code mantis-network/src/main/java/io/reactivex/mantis/network/push/ConsistentHashingRouter.java x: 2 commits (all time) y: 103 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/SLAEnforcer.java x: 4 commits (all time) y: 91 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/JobDefinitionResolver.java x: 5 commits (all time) y: 152 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/JobClusterConfig.java x: 4 commits (all time) y: 117 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/JobDefinition.java x: 13 commits (all time) y: 341 lines of code mantis-runtime-loader/src/main/java/io/mantisrx/runtime/loader/config/WorkerConfigurationWritable.java x: 11 commits (all time) y: 225 lines of code mantis-client/src/main/java/io/mantisrx/client/MantisClient.java x: 8 commits (all time) y: 247 lines of code mantis-client/src/main/java/io/mantisrx/client/MantisSSEJob.java x: 4 commits (all time) y: 231 lines of code mantis-connectors/mantis-connector-job-source/src/main/java/io/mantisrx/connector/job/core/MantisSourceJobConnector.java x: 2 commits (all time) y: 158 lines of code mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/HighAvailabilityServicesUtil.java x: 10 commits (all time) y: 192 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/events/WorkerMetricsCollector.java x: 6 commits (all time) y: 186 lines of code mantis-control-plane/mantis-control-plane-dynamodb/src/main/java/io/mantisrx/extensions/dynamodb/DynamoDBStore.java x: 3 commits (all time) y: 233 lines of code mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core/ExecuteStageRequest.java x: 12 commits (all time) y: 109 lines of code mantis-runtime-loader/src/main/java/io/mantisrx/runtime/loader/RuntimeTask.java x: 5 commits (all time) y: 10 lines of code mantis-common/src/main/java/io/mantisrx/runtime/descriptor/SchedulingInfo.java x: 18 commits (all time) y: 205 lines of code mantis-common/src/main/java/io/mantisrx/runtime/descriptor/StageScalingPolicy.java x: 12 commits (all time) y: 98 lines of code mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent/TaskExecutorStarter.java x: 11 commits (all time) y: 156 lines of code mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/TestGetMasterMonitor.java x: 5 commits (all time) y: 61 lines of code mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core/master/MasterMonitor.java x: 4 commits (all time) y: 9 lines of code mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core/master/ZookeeperMasterMonitor.java x: 11 commits (all time) y: 106 lines of code mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/core/zookeeper/CuratorService.java x: 7 commits (all time) y: 79 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/zk/LeaderElector.java x: 5 commits (all time) y: 132 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/LeaderRedirectionFilter.java x: 5 commits (all time) y: 87 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/persistence/FileBasedPersistenceProvider.java x: 2 commits (all time) y: 50 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/FileBasedStore.java x: 2 commits (all time) y: 137 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/KeyValueStore.java x: 4 commits (all time) y: 107 lines of code mantis-control-plane/mantis-control-plane-store/mantis-control-plane-store-dynamodb/src/main/java/io/mantisrx/server/master/store/DynamoStore.java x: 2 commits (all time) y: 189 lines of code mantis-runtime-executor/src/main/java/io/mantisrx/server/worker/RuntimeTaskImpl.java x: 3 commits (all time) y: 180 lines of code mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent/ResourceManagerGatewayCxn.java x: 6 commits (all time) 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: 14 commits (all time) y: 422 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/events/WorkerRegistryV2.java x: 6 commits (all time) y: 137 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClustersHostManagerActor.java x: 9 commits (all time) y: 355 lines of code mantis-runtime-loader/src/main/java/io/mantisrx/runtime/loader/SubscriptionStateHandlerImpl.java x: 3 commits (all time) y: 109 lines of code mantis-runtime-executor/src/main/java/io/mantisrx/server/worker/MantisWorker.java x: 1 commits (all time) y: 209 lines of code mantis-runtime-executor/src/main/java/io/mantisrx/server/worker/scheduling/JobSchedulingTracker.java x: 1 commits (all time) y: 95 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/CompletedJobStore.java x: 3 commits (all time) y: 245 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/JobClustersManagerService.java x: 5 commits (all time) y: 72 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterGatewayAkkaImpl.java x: 8 commits (all time) y: 116 lines of code mantis-control-plane/mantis-control-plane-client/src/main/java/io/mantisrx/server/master/client/MasterClientWrapper.java x: 8 commits (all time) y: 300 lines of code mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent/AgentV2Main.java x: 6 commits (all time) y: 130 lines of code mantis-runtime/src/main/java/io/mantisrx/runtime/command/LoadValidateCreateZip.java x: 4 commits (all time) y: 56 lines of code mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent/HadoopFileSystemBlobStore.java x: 6 commits (all time) y: 35 lines of code mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/worker/TaskExecutorGateway.java x: 8 commits (all time) y: 34 lines of code mantis-runtime/src/main/java/io/mantisrx/runtime/source/http/impl/HttpSourceImpl.java x: 4 commits (all time) y: 550 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/FilterableMantisJobMetadataWritable.java x: 6 commits (all time) y: 44 lines of code mantis-runtime/src/main/java/io/mantisrx/runtime/executor/StageExecutors.java x: 14 commits (all time) y: 406 lines of code mantis-runtime/src/main/java/io/mantisrx/runtime/command/LoadValidateCreateDir.java x: 3 commits (all time) y: 62 lines of code mantis-runtime/src/main/java/io/mantisrx/runtime/core/MantisStreamImpl.java x: 2 commits (all time) y: 178 lines of code mantis-runtime/src/main/java/io/mantisrx/runtime/executor/LocalJobExecutorNetworked.java x: 5 commits (all time) y: 339 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/proto/UpgradeClusterContainersRequest.java x: 5 commits (all time) y: 16 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobArtifactsRoute.java x: 3 commits (all time) y: 102 lines of code mantis-connectors/mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/DefaultIcebergWriter.java x: 12 commits (all time) y: 154 lines of code mantis-connectors/mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/IcebergWriter.java x: 6 commits (all time) y: 13 lines of code mantis-connectors/mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/IcebergWriterStage.java x: 19 commits (all time) y: 266 lines of code mantis-common/src/main/java/io/mantisrx/runtime/descriptor/StageSchedulingInfo.java x: 13 commits (all time) y: 131 lines of code mantis-network/src/main/java/io/reactivex/mantis/network/push/ObservableTrigger.java x: 4 commits (all time) y: 276 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/handlers/ResourceClusterRouteHandler.java x: 7 commits (all time) y: 31 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/handlers/ResourceClusterRouteHandlerAkkaImpl.java x: 8 commits (all time) y: 98 lines of code mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/AbstractSubscriptionTracker.java x: 12 commits (all time) y: 159 lines of code mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/discovery/MantisJobDiscoveryCachingImpl.java x: 4 commits (all time) y: 166 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/proto/JobArtifactProto.java x: 2 commits (all time) y: 82 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/MantisJobMetadataView.java x: 4 commits (all time) y: 152 lines of code mantis-server/mantis-server-agent/src/main/java/io/mantisrx/server/agent/Hardware.java x: 3 commits (all time) y: 198 lines of code mantis-common/src/main/java/io/mantisrx/common/storage/StorageUnit.java x: 1 commits (all time) y: 390 lines of code mantis-common/src/main/java/io/mantisrx/common/WorkerPorts.java x: 13 commits (all time) y: 102 lines of code mantis-common/src/main/java/io/mantisrx/runtime/MachineDefinition.java x: 5 commits (all time) y: 106 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/store/MantisWorkerMetadataWritable.java x: 4 commits (all time) y: 283 lines of code mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/DynamicConnectionSet.java x: 2 commits (all time) y: 266 lines of code mantis-connectors/mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/KafkaSource.java x: 4 commits (all time) y: 313 lines of code mantis-common/src/main/java/io/mantisrx/common/compression/CompressionUtils.java x: 11 commits (all time) y: 329 lines of code mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/api/StreamType.java x: 6 commits (all time) y: 6 lines of code mantis-common/src/main/java/io/mantisrx/common/metrics/netty/HttpClientListener.java x: 1 commits (all time) y: 180 lines of code mantis-common/src/main/java/io/mantisrx/common/metrics/netty/TcpClientListener.java x: 1 commits (all time) y: 191 lines of code mantis-common/src/main/java/io/mantisrx/common/network/ServerSlotManager.java x: 1 commits (all time) y: 173 lines of code mantis-common/src/main/java/io/reactivx/mantis/operators/BufferOnBackPressureOperator.java x: 1 commits (all time) y: 201 lines of code mantis-common/src/main/java/io/reactivx/mantis/operators/OnSubscribeRedo.java x: 1 commits (all time) y: 246 lines of code mantis-common/src/main/java/io/reactivx/mantis/operators/OperatorGroupBy.java x: 1 commits (all time) y: 252 lines of code mantis-connectors/mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/MantisKafkaConsumer.java x: 3 commits (all time) y: 250 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/pagination/ListObject.java x: 3 commits (all time) y: 219 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v0/MasterDescriptionRoute.java x: 3 commits (all time) y: 140 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/AdminMasterRoute.java x: 3 commits (all time) y: 165 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/WorkerResubmitRateLimiter.java x: 3 commits (all time) y: 123 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/WorkerRequest.java x: 3 commits (all time) y: 170 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/SLA.java x: 3 commits (all time) y: 152 lines of code mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/config/SampleArchaiusMrePublishConfiguration.java x: 3 commits (all time) y: 340 lines of code mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/RemoteObservableConnectionHandler.java x: 1 commits (all time) y: 384 lines of code .baseline/idea/intellij-java-palantir-style.xml x: 2 commits (all time) y: 476 lines of code
2641.0
lines of code
  min: 1.0
  average: 91.34
  25th percentile: 19.0
  median: 45.0
  75th percentile: 100.0
  max: 2641.0
0 61.0
commits (all time)
min: 1.0 | average: 3.54 | 25th percentile: 1.0 | median: 3.0 | 75th percentile: 4.0 | max: 61.0

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

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

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

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

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

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

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

mantis-common/src/main/java/io/mantisrx/config/dynamic/DynamicProperty.java x: 1 commits (90d) y: 55 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/MasterApiAkkaService.java x: 1 commits (90d) y: 297 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/BaseRoute.java x: 1 commits (90d) y: 366 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobsRoute.java x: 1 commits (90d) y: 505 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/utils/ApiRequestRateLimiter.java x: 1 commits (90d) y: 11 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/utils/ApiRequestRateLimiterFactory.java x: 1 commits (90d) y: 46 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/MasterMain.java x: 1 commits (90d) y: 254 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/config/MasterConfiguration.java x: 1 commits (90d) y: 281 lines of code mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/clutch/ClutchAutoScaler.java x: 1 commits (90d) y: 173 lines of code
505.0
lines of code
  min: 11.0
  average: 185.91
  25th percentile: 46.0
  median: 173.0
  75th percentile: 297.0
  max: 505.0
0 1.0
commits (90d)
min: 1.0 | average: 1.0 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 1.0

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

mantis-common/src/main/java/io/mantisrx/config/dynamic/DynamicProperty.java x: 1 contributors (90d) y: 55 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/MasterApiAkkaService.java x: 1 contributors (90d) y: 297 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/BaseRoute.java x: 1 contributors (90d) y: 366 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/JobsRoute.java x: 1 contributors (90d) y: 505 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/utils/ApiRequestRateLimiter.java x: 1 contributors (90d) y: 11 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/utils/ApiRequestRateLimiterFactory.java x: 1 contributors (90d) y: 46 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/MasterMain.java x: 1 contributors (90d) y: 254 lines of code mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/config/MasterConfiguration.java x: 1 contributors (90d) y: 281 lines of code mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/clutch/ClutchAutoScaler.java x: 1 contributors (90d) y: 173 lines of code
505.0
lines of code
  min: 11.0
  average: 185.91
  25th percentile: 46.0
  median: 173.0
  75th percentile: 297.0
  max: 505.0
0 1.0
contributors (90d)
min: 1.0 | average: 1.0 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 1.0
About This Analysis
  • File size measurements show the distribution of size of files.
  • Files are classified in four categories based on their size (lines of code): 1-100 (very small files), 101-200 (small files), 201-500 (medium size files), 501-1000 (long files), 1001+(very long files).
  • It is a good practice to keep files small. Long files may become "bloaters", code that have increased to such gargantuan proportions that they are hard to work with.
Learn more...