Netflix/mantis-connectors
File Size
The distribution of size of files (measured in lines of code).
File Size Overall
  • There are 72 files with 4,676 lines of code.
    • 0 very long files (0 lines of code)
    • 0 long files (0 lines of code)
    • 5 medium size files (1,269 lines of code)
    • 9 small files (1,100 lines of code)
    • 58 very small files (2,307 lines of code)
0% | 0% | 27% | 23% | 49%
Legend:
1001+
501-1000
201-500
101-200
1-100


explore: grouped by folders | grouped by size | sunburst | 3D view
File Size per Extension
1001+
501-1000
201-500
101-200
1-100
java0% | 0% | 28% | 24% | 47%
xml0% | 0% | 0% | 0% | 100%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
mantis-connector-kafka0% | 0% | 27% | 24% | 47%
mantis-connector-job0% | 0% | 50% | 17% | 32%
mantis-connector-iceberg0% | 0% | 29% | 36% | 34%
mantis-connector-publish0% | 0% | 0% | 16% | 83%
codequality0% | 0% | 0% | 0% | 100%
Longest Files (Top 50)
File# lines# units
KafkaSource.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source
 299 5
IcebergWriterStage.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer
 275 20
MantisKafkaConsumer.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source
 250 27
JobSource.java
in mantis-connector-job/src/main/java/io/mantisrx/connector/job/source
 232 16
ServerSentEventsSink.java
in mantis-connector-job/src/main/java/io/mantisrx/connector/job/sink
 213 20
MantisSourceJobConnector.java
in mantis-connector-job/src/main/java/io/mantisrx/connector/job/core
 151 11
ConsumerMetrics.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/metrics
 131 17
MantisKafkaSourceConfig.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source
 127 13
MantisKafkaConsumerConfig.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source
 123 7
IcebergCommitterStage.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer
 120 4
HttpSourceServerHandler.java
in mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http
 116 3
DefaultIcebergWriter.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer
 115 11
FileBasedOffsetCheckpointStrategy.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy
 112 8
WriterMetrics.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/metrics
 105 4
QueryMap.java
in mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/core
 100 12
TopicPartitionStateManager.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source
 97 8
KafkaData.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka
 95 12
92 -
MultiSinkConnectionStatusObserver.java
in mantis-connector-job/src/main/java/io/mantisrx/connector/job/core
 91 11
PushHttpSource.java
in mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http
 87 2
NettyExceptionHandler.java
in mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http
 85 5
MantisKafkaProducerConfig.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/sink
 85 6
pmd.xml
in codequality
 80 -
CommitterMetrics.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer/metrics
 78 4
QueryRegistry.java
in mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/core
 77 10
KafkaSink.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/sink
 70 2
KafkaOffsetCheckpointStrategy.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy
 68 6
NettySourceHttpServer.java
in mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http
 65 4
IcebergCodecs.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/codecs
 65 5
EventFilter.java
in mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/core
 64 4
DefaultSinkConnectionStatusObserver.java
in mantis-connector-job/src/main/java/io/mantisrx/connector/job/core
 64 9
AbstractJobSource.java
in mantis-connector-job/src/main/java/io/mantisrx/connector/job/core
 59 2
AbstractSourceJobSource.java
in mantis-connector-job/src/main/java/io/mantisrx/connector/job/core
 57 7
KafkaDataNotification.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka
 51 12
KafkaConsumerRebalanceListener.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source
 51 3
CountingCheckpointTrigger.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/trigger
 50 6
StaticPartitionAssignorImpl.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/assignor
 44 1
SourceSink.java
in mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http
 41 3
WriterConfig.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/config
 39 6
KafkaAckable.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka
 35 6
NoopCheckpointStrategy.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy
 32 5
HttpServerInitializer.java
in mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http
 30 2
ParserType.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/serde
 30 5
CheckpointStrategyFactory.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy
 29 2
CheckpointingDisabledTrigger.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/trigger
 28 6
SinkConfig.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/config
 26 4
WriterProperties.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/config
 26 1
SimpleJsonDeserializer.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/serde
 26 2
IcebergCommitter.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer
 19 2
MapDeserializerBase.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/serde
 19 3
Files With Most Units (Top 50)
File# lines# units
MantisKafkaConsumer.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source
 250 27
IcebergWriterStage.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer
 275 20
ServerSentEventsSink.java
in mantis-connector-job/src/main/java/io/mantisrx/connector/job/sink
 213 20
ConsumerMetrics.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/metrics
 131 17
JobSource.java
in mantis-connector-job/src/main/java/io/mantisrx/connector/job/source
 232 16
MantisKafkaSourceConfig.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source
 127 13
QueryMap.java
in mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/core
 100 12
KafkaDataNotification.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka
 51 12
KafkaData.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka
 95 12
DefaultIcebergWriter.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer
 115 11
MantisSourceJobConnector.java
in mantis-connector-job/src/main/java/io/mantisrx/connector/job/core
 151 11
MultiSinkConnectionStatusObserver.java
in mantis-connector-job/src/main/java/io/mantisrx/connector/job/core
 91 11
QueryRegistry.java
in mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/core
 77 10
DefaultSinkConnectionStatusObserver.java
in mantis-connector-job/src/main/java/io/mantisrx/connector/job/core
 64 9
FileBasedOffsetCheckpointStrategy.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy
 112 8
TopicPartitionStateManager.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source
 97 8
AbstractSourceJobSource.java
in mantis-connector-job/src/main/java/io/mantisrx/connector/job/core
 57 7
MantisKafkaConsumerConfig.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source
 123 7
WriterConfig.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/config
 39 6
CheckpointingDisabledTrigger.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/trigger
 28 6
CountingCheckpointTrigger.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/trigger
 50 6
KafkaOffsetCheckpointStrategy.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy
 68 6
MantisKafkaProducerConfig.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/sink
 85 6
KafkaAckable.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka
 35 6
NettyExceptionHandler.java
in mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http
 85 5
IcebergCodecs.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/codecs
 65 5
KafkaSource.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source
 299 5
NoopCheckpointStrategy.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy
 32 5
ParserType.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/serde
 30 5
EventFilter.java
in mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/core
 64 4
NettySourceHttpServer.java
in mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http
 65 4
SinkConfig.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/config
 26 4
WriterMetrics.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/metrics
 105 4
CommitterMetrics.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer/metrics
 78 4
IcebergCommitterStage.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer
 120 4
ObjectUtils.java
in mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/core
 18 3
SourceSink.java
in mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http
 41 3
HttpSourceServerHandler.java
in mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http
 116 3
KafkaConsumerRebalanceListener.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source
 51 3
MapDeserializerBase.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/serde
 19 3
ParseException.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/serde
 13 3
HttpServerInitializer.java
in mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http
 30 2
PushHttpSource.java
in mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http
 87 2
CommitterConfig.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer/config
 16 2
IcebergCommitter.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer
 19 2
AbstractJobSource.java
in mantis-connector-job/src/main/java/io/mantisrx/connector/job/core
 59 2
CheckpointTriggerFactory.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/trigger
 16 2
CheckpointStrategyOptions.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy
 11 2
CheckpointStrategyFactory.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy
 29 2
SimpleJsonDeserializer.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/serde
 26 2
Files With Long Lines (Top 19)

There are 19 files with lines longer than 120 characters. In total, there are 81 long lines.

File# lines# units# long lines
MantisKafkaSourceConfig.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source
 127 13 17
KafkaSource.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source
 299 5 13
AbstractSourceJobSource.java
in mantis-connector-job/src/main/java/io/mantisrx/connector/job/core
 57 7 12
MantisKafkaConsumer.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source
 250 27 11
AbstractJobSource.java
in mantis-connector-job/src/main/java/io/mantisrx/connector/job/core
 59 2 6
MantisSourceJobConnector.java
in mantis-connector-job/src/main/java/io/mantisrx/connector/job/core
 151 11 3
QueryRegistry.java
in mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/core
 77 10 2
QueryMap.java
in mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/core
 100 12 2
KafkaConsumerRebalanceListener.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source
 51 3 2
MantisKafkaConsumerConfig.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source
 123 7 2
StaticPartitionAssignorImpl.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/assignor
 44 1 2
MantisKafkaProducerConfig.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/sink
 85 6 2
HttpServerInitializer.java
in mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http
 30 2 1
JobSource.java
in mantis-connector-job/src/main/java/io/mantisrx/connector/job/source
 232 16 1
CheckpointTriggerFactory.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/trigger
 16 2 1
CountingCheckpointTrigger.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/trigger
 50 6 1
FileBasedOffsetCheckpointStrategy.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy
 112 8 1
TopicPartitionStateManager.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source
 97 8 1
KafkaAckable.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka
 35 6 1
Correlations

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

mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/DefaultIcebergWriter.java x: 7 commits (all time) y: 115 lines of code mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/config/WriterProperties.java x: 16 commits (all time) y: 26 lines of code mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer/IcebergCommitterStage.java x: 19 commits (all time) y: 120 lines of code mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/IcebergWriterStage.java x: 38 commits (all time) y: 275 lines of code mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/codecs/IcebergCodecs.java x: 7 commits (all time) y: 65 lines of code mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/IcebergWriter.java x: 9 commits (all time) y: 15 lines of code mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/partitioner/NoOpPartitioner.java x: 2 commits (all time) y: 8 lines of code mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/partitioner/Partitioner.java x: 2 commits (all time) y: 5 lines of code mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/config/WriterConfig.java x: 11 commits (all time) y: 39 lines of code mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer/config/CommitterConfig.java x: 4 commits (all time) y: 16 lines of code mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/config/SinkConfig.java x: 2 commits (all time) y: 26 lines of code mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/config/SinkProperties.java x: 2 commits (all time) y: 11 lines of code mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer/IcebergCommitter.java x: 10 commits (all time) y: 19 lines of code mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer/metrics/CommitterMetrics.java x: 6 commits (all time) y: 78 lines of code mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/metrics/WriterMetrics.java x: 5 commits (all time) y: 105 lines of code mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer/config/CommitterProperties.java x: 3 commits (all time) y: 10 lines of code mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/sink/MantisKafkaProducerConfig.java x: 6 commits (all time) y: 85 lines of code mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/MantisKafkaConsumerConfig.java x: 8 commits (all time) y: 123 lines of code mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/KafkaSourceParameters.java x: 6 commits (all time) y: 15 lines of code mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/KafkaSource.java x: 4 commits (all time) y: 299 lines of code mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/sink/KafkaSink.java x: 2 commits (all time) y: 70 lines of code mantis-connector-job/src/main/java/io/mantisrx/connector/job/core/AbstractJobSource.java x: 2 commits (all time) y: 59 lines of code mantis-connector-job/src/main/java/io/mantisrx/connector/job/core/AbstractSourceJobSource.java x: 2 commits (all time) y: 57 lines of code mantis-connector-job/src/main/java/io/mantisrx/connector/job/core/DefaultSinkConnectionStatusObserver.java x: 2 commits (all time) y: 64 lines of code mantis-connector-job/src/main/java/io/mantisrx/connector/job/core/MantisSourceJobConnector.java x: 2 commits (all time) y: 151 lines of code mantis-connector-job/src/main/java/io/mantisrx/connector/job/core/MantisSourceJobConnectorFactory.java x: 2 commits (all time) y: 6 lines of code mantis-connector-job/src/main/java/io/mantisrx/connector/job/core/MultiSinkConnectionStatusObserver.java x: 2 commits (all time) y: 91 lines of code mantis-connector-job/src/main/java/io/mantisrx/connector/job/core/SinkConnectionStatusObserver.java x: 2 commits (all time) y: 9 lines of code mantis-connector-job/src/main/java/io/mantisrx/connector/job/sink/ServerSentEventsSink.java x: 2 commits (all time) y: 213 lines of code mantis-connector-job/src/main/java/io/mantisrx/connector/job/source/JobSource.java x: 2 commits (all time) y: 232 lines of code mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/KafkaAckable.java x: 2 commits (all time) y: 35 lines of code mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/KafkaData.java x: 2 commits (all time) y: 95 lines of code mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/KafkaDataNotification.java x: 2 commits (all time) y: 51 lines of code mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/MantisKafkaConsumer.java x: 2 commits (all time) y: 250 lines of code mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/MantisKafkaSourceConfig.java x: 2 commits (all time) y: 127 lines of code mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/TopicPartitionStateManager.java x: 2 commits (all time) y: 97 lines of code mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/assignor/StaticPartitionAssignorImpl.java x: 2 commits (all time) y: 44 lines of code mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy/CheckpointStrategy.java x: 2 commits (all time) y: 14 lines of code mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy/CheckpointStrategyFactory.java x: 2 commits (all time) y: 29 lines of code mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy/FileBasedOffsetCheckpointStrategy.java x: 2 commits (all time) y: 112 lines of code mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy/KafkaOffsetCheckpointStrategy.java x: 2 commits (all time) y: 68 lines of code mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy/NoopCheckpointStrategy.java x: 2 commits (all time) y: 32 lines of code mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/trigger/CheckpointTriggerFactory.java x: 2 commits (all time) y: 16 lines of code mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/trigger/CheckpointingDisabledTrigger.java x: 2 commits (all time) y: 28 lines of code mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/trigger/CountingCheckpointTrigger.java x: 2 commits (all time) y: 50 lines of code mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/metrics/ConsumerMetrics.java x: 2 commits (all time) y: 131 lines of code mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/serde/MapDeserializerBase.java x: 2 commits (all time) y: 19 lines of code mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/serde/OffsetAndMetadataSerializer.java x: 2 commits (all time) y: 15 lines of code mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/serde/Parser.java x: 2 commits (all time) y: 12 lines of code mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/serde/ParserType.java x: 2 commits (all time) y: 30 lines of code mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/core/ObjectUtils.java x: 2 commits (all time) y: 18 lines of code mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/core/QueryMap.java x: 2 commits (all time) y: 100 lines of code mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/core/QueryRegistry.java x: 2 commits (all time) y: 77 lines of code mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http/HttpSourceServerHandler.java x: 2 commits (all time) y: 116 lines of code mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http/NettyExceptionHandler.java x: 2 commits (all time) y: 85 lines of code mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http/NettySourceHttpServer.java x: 2 commits (all time) y: 65 lines of code mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http/PushHttpSource.java x: 2 commits (all time) y: 87 lines of code mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http/SourceSink.java x: 2 commits (all time) y: 41 lines of code
299.0
lines of code
  min: 5.0
  average: 64.34
  25th percentile: 15.0
  median: 42.5
  75th percentile: 92.0
  max: 299.0
0 38.0
commits (all time)
min: 2.0 | average: 3.81 | 25th percentile: 2.0 | median: 2.0 | 75th percentile: 2.0 | max: 38.0

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

mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/DefaultIcebergWriter.java x: 1 contributors (all time) y: 115 lines of code mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/config/WriterProperties.java x: 1 contributors (all time) y: 26 lines of code mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer/IcebergCommitterStage.java x: 1 contributors (all time) y: 120 lines of code mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/IcebergWriterStage.java x: 1 contributors (all time) y: 275 lines of code mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/codecs/IcebergCodecs.java x: 1 contributors (all time) y: 65 lines of code mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/IcebergWriter.java x: 1 contributors (all time) y: 15 lines of code mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/partitioner/NoOpPartitioner.java x: 1 contributors (all time) y: 8 lines of code mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/partitioner/Partitioner.java x: 1 contributors (all time) y: 5 lines of code mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/config/WriterConfig.java x: 1 contributors (all time) y: 39 lines of code mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer/config/CommitterConfig.java x: 1 contributors (all time) y: 16 lines of code mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/config/SinkProperties.java x: 1 contributors (all time) y: 11 lines of code mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer/IcebergCommitter.java x: 1 contributors (all time) y: 19 lines of code mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer/metrics/CommitterMetrics.java x: 1 contributors (all time) y: 78 lines of code mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/metrics/WriterMetrics.java x: 1 contributors (all time) y: 105 lines of code mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer/config/CommitterProperties.java x: 1 contributors (all time) y: 10 lines of code mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/sink/MantisKafkaProducerConfig.java x: 2 contributors (all time) y: 85 lines of code mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/MantisKafkaConsumerConfig.java x: 2 contributors (all time) y: 123 lines of code mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/KafkaSourceParameters.java x: 2 contributors (all time) y: 15 lines of code mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/KafkaSource.java x: 2 contributors (all time) y: 299 lines of code mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/sink/KafkaSink.java x: 2 contributors (all time) y: 70 lines of code mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/sink/KafkaSinkJobParameters.java x: 2 contributors (all time) y: 5 lines of code mantis-connector-job/src/main/java/io/mantisrx/connector/job/core/AbstractJobSource.java x: 2 contributors (all time) y: 59 lines of code mantis-connector-job/src/main/java/io/mantisrx/connector/job/core/AbstractSourceJobSource.java x: 2 contributors (all time) y: 57 lines of code mantis-connector-job/src/main/java/io/mantisrx/connector/job/core/DefaultSinkConnectionStatusObserver.java x: 2 contributors (all time) y: 64 lines of code mantis-connector-job/src/main/java/io/mantisrx/connector/job/core/MantisSourceJobConnector.java x: 2 contributors (all time) y: 151 lines of code mantis-connector-job/src/main/java/io/mantisrx/connector/job/core/MantisSourceJobConnectorFactory.java x: 2 contributors (all time) y: 6 lines of code mantis-connector-job/src/main/java/io/mantisrx/connector/job/core/MultiSinkConnectionStatusObserver.java x: 2 contributors (all time) y: 91 lines of code mantis-connector-job/src/main/java/io/mantisrx/connector/job/core/SinkConnectionStatusObserver.java x: 2 contributors (all time) y: 9 lines of code mantis-connector-job/src/main/java/io/mantisrx/connector/job/sink/ServerSentEventsSink.java x: 2 contributors (all time) y: 213 lines of code mantis-connector-job/src/main/java/io/mantisrx/connector/job/source/JobSource.java x: 2 contributors (all time) y: 232 lines of code mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/KafkaAckable.java x: 2 contributors (all time) y: 35 lines of code mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/KafkaData.java x: 2 contributors (all time) y: 95 lines of code mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/KafkaDataNotification.java x: 2 contributors (all time) y: 51 lines of code mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/MantisKafkaConsumer.java x: 2 contributors (all time) y: 250 lines of code mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/MantisKafkaSourceConfig.java x: 2 contributors (all time) y: 127 lines of code mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/TopicPartitionStateManager.java x: 2 contributors (all time) y: 97 lines of code mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/assignor/StaticPartitionAssignorImpl.java x: 2 contributors (all time) y: 44 lines of code mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy/CheckpointStrategy.java x: 2 contributors (all time) y: 14 lines of code mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy/CheckpointStrategyFactory.java x: 2 contributors (all time) y: 29 lines of code mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy/CheckpointStrategyOptions.java x: 2 contributors (all time) y: 11 lines of code mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy/FileBasedOffsetCheckpointStrategy.java x: 2 contributors (all time) y: 112 lines of code mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy/KafkaOffsetCheckpointStrategy.java x: 2 contributors (all time) y: 68 lines of code mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy/NoopCheckpointStrategy.java x: 2 contributors (all time) y: 32 lines of code mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/trigger/CheckpointTrigger.java x: 2 contributors (all time) y: 8 lines of code mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/trigger/CheckpointTriggerFactory.java x: 2 contributors (all time) y: 16 lines of code mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/trigger/CheckpointingDisabledTrigger.java x: 2 contributors (all time) y: 28 lines of code mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/trigger/CountingCheckpointTrigger.java x: 2 contributors (all time) y: 50 lines of code mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/metrics/ConsumerMetrics.java x: 2 contributors (all time) y: 131 lines of code mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/serde/MapDeserializerBase.java x: 2 contributors (all time) y: 19 lines of code mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/serde/Parser.java x: 2 contributors (all time) y: 12 lines of code mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/serde/ParserType.java x: 2 contributors (all time) y: 30 lines of code mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/serde/SimpleJsonDeserializer.java x: 2 contributors (all time) y: 26 lines of code mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/core/ObjectUtils.java x: 2 contributors (all time) y: 18 lines of code mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/core/QueryMap.java x: 2 contributors (all time) y: 100 lines of code mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/core/QueryRegistry.java x: 2 contributors (all time) y: 77 lines of code mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http/HttpSourceServerHandler.java x: 2 contributors (all time) y: 116 lines of code mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http/NettySourceHttpServer.java x: 2 contributors (all time) y: 65 lines of code mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http/PushHttpSource.java x: 2 contributors (all time) y: 87 lines of code mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http/SourceSink.java x: 2 contributors (all time) y: 41 lines of code
299.0
lines of code
  min: 5.0
  average: 64.34
  25th percentile: 15.0
  median: 42.5
  75th percentile: 92.0
  max: 299.0
0 2.0
contributors (all time)
min: 1.0 | average: 1.76 | 25th percentile: 1.75 | median: 2.0 | 75th percentile: 2.0 | max: 2.0

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

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

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

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

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

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

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

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

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...