Netflix/mantis-connectors
File Churn
File change frequency (churn) shows the distribution of file updates (days with at least one commit).
Overview
File Change Frequency Overall
  • There are 70 files with 4,504 lines of code.
    • 0 files changed more than 100 times (0 lines of code)
    • 0 files changed 51-100 times (0 lines of code)
    • 1 file changed 21-50 times (275 lines of code)
    • 5 files changed 6-20 times (219 lines of code)
    • 64 files changed 1-5 times (4,010 lines of code)
0% | 0% | 6% | 4% | 89%
Legend:
101+
51-100
21-50
6-20
1-5

explore: grouped by folders | grouped by update frequency | data
Contributors Count Frequency Overall
  • There are 70 files with 4,504 lines of code.
    • 0 files changed by more than 25 contributors (0 lines of code)
    • 0 files changed by 11-25 contributors (0 lines of code)
    • 0 files changed by 6-10 contributors (0 lines of code)
    • 53 files changed by 2-5 contributors (3,566 lines of code)
    • 17 files changed by 1 contributor (938 lines of code)
0% | 0% | 0% | 79% | 20%
Legend:
26+
11-25
6-10
2-5
1

explore: grouped by folders | grouped by contributors count | data
File Change Frequency per File Extension
java, gradle, md, txt, xml, properties, sh, bat, gitignore, yml
File Change Frequency per Extension
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
java0% | 0% | 6% | 4% | 89%
xml0% | 0% | 0% | 0% | 0%
File Change Frequency per Logical Decomposition
primary
primary (file change frequency)
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
mantis-connector-iceberg0% | 0% | 29% | 23% | 47%
mantis-connector-kafka0% | 0% | 0% | 0% | 100%
mantis-connector-job0% | 0% | 0% | 0% | 100%
mantis-connector-publish0% | 0% | 0% | 0% | 100%
codequality0% | 0% | 0% | 0% | 0%
Most Frequently Changed Files (Top 50)

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsline
churn		first
contributor		latest
contributor
IcebergWriterStage.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer
 275 20 2020-06-02 2020-08-13 22 1 +1405 / -573 jchao jchao
WriterProperties.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/config
 26 1 2020-06-02 2020-09-10 12 1 +212 / -80 jchao jchao
IcebergCommitterStage.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer
 120 4 2020-06-02 2020-08-13 12 1 +481 / -111 jchao jchao
WriterConfig.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/config
 39 6 2020-06-02 2020-07-28 9 1 +217 / -45 jchao jchao
IcebergCommitter.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer
 19 2 2020-06-02 2020-06-30 7 1 +177 / -73 jchao jchao
IcebergWriter.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer
 15 - 2020-06-02 2020-08-10 6 1 +102 / -20 jchao jchao
IcebergCodecs.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/codecs
 65 5 2020-06-16 2020-08-10 5 1 +226 / -16 jchao jchao
CommitterMetrics.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer/metrics
 78 4 2020-06-02 2020-06-30 4 1 +223 / -9 jchao jchao
WriterMetrics.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/metrics
 105 4 2020-06-02 2020-06-30 4 1 +281 / -7 jchao jchao
DefaultIcebergWriter.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer
 115 11 2020-08-04 2020-09-23 4 1 +432 / -10 jchao jchao
MantisKafkaConsumerConfig.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source
 123 7 2019-07-12 2019-09-17 4 2 +406 / -70 nickmahilani nmahilani
KafkaSourceParameters.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka
 15 - 2019-07-12 2019-09-16 3 2 +78 / -4 nickmahilani nmahilani
CommitterConfig.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer/config
 16 2 2020-06-02 2020-07-01 3 1 +102 / -8 jchao jchao
MantisKafkaProducerConfig.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/sink
 85 6 2019-08-30 2019-09-17 3 2 +250 / -4 nickmahilani nmahilani
PartitionerFactory.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/partitioner
 5 - 2020-08-04 2020-08-10 2 1 +48 / -0 jchao jchao
Partitioner.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/partitioner
 5 - 2020-08-04 2020-08-10 2 1 +48 / -0 jchao jchao
NoOpPartitioner.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/partitioner
 8 1 2020-08-06 2020-08-10 2 1 +60 / -0 jchao jchao
CommitterProperties.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer/config
 10 1 2020-06-02 2020-06-23 2 1 +74 / -2 jchao jchao
KafkaSource.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source
 299 5 2019-07-12 2019-09-16 2 2 +748 / -12 nickmahilani nmahilani
KafkaSinkJobParameters.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/sink
 5 - 2019-08-30 2019-08-30 1 2 +44 / -0 nickmahilani nmahilani
MantisSourceJobConnectorFactory.java
in mantis-connector-job/src/main/java/io/mantisrx/connector/job/core
 6 1 2019-07-12 2019-07-12 1 2 +48 / -0 nickmahilani nmahilani
CheckpointTrigger.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/trigger
 8 - 2019-07-12 2019-07-12 1 2 +98 / -0 nickmahilani nmahilani
StaticPartitionAssignor.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/assignor
 9 - 2019-07-12 2019-07-12 1 2 +58 / -0 nickmahilani nmahilani
SinkConnectionStatusObserver.java
in mantis-connector-job/src/main/java/io/mantisrx/connector/job/core
 9 - 2019-07-12 2019-07-12 1 2 +64 / -0 nickmahilani nmahilani
CheckpointStrategyOptions.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy
 11 2 2019-07-12 2019-07-12 1 2 +86 / -0 nickmahilani nmahilani
SinkProperties.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/config
 11 1 2020-07-01 2020-07-01 1 1 +88 / -0 jchao jchao
Parser.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/serde
 12 1 2019-07-12 2019-07-12 1 2 +118 / -0 nickmahilani nmahilani
ParseException.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/serde
 13 3 2019-07-12 2019-07-12 1 2 +76 / -0 nickmahilani nmahilani
CheckpointStrategy.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy
 14 - 2019-07-12 2019-07-12 1 2 +140 / -0 nickmahilani nmahilani
OffsetAndMetadataSerializer.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/serde
 15 1 2019-07-12 2019-07-12 1 2 +68 / -0 nickmahilani nmahilani
SourceHttpServer.java
in mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http
 15 - 2019-07-12 2019-07-12 1 2 +78 / -0 nickmahilani nmahilani
OffsetAndMetadataDeserializer.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/serde
 16 1 2019-07-12 2019-07-12 1 2 +76 / -0 nickmahilani nmahilani
CheckpointTriggerFactory.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/trigger
 16 2 2019-07-12 2019-07-12 1 2 +86 / -0 nickmahilani nmahilani
ObjectUtils.java
in mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/core
 18 3 2019-07-12 2019-07-12 1 2 +80 / -0 nickmahilani nmahilani
MapDeserializerBase.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/serde
 19 3 2019-07-12 2019-07-12 1 2 +84 / -0 nickmahilani nmahilani
SimpleJsonDeserializer.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/serde
 26 2 2019-07-12 2019-07-12 1 2 +106 / -0 nickmahilani nmahilani
SinkConfig.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/config
 26 4 2020-07-01 2020-07-01 1 1 +132 / -0 jchao jchao
CheckpointingDisabledTrigger.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/trigger
 28 6 2019-07-12 2019-07-12 1 2 +110 / -0 nickmahilani nmahilani
CheckpointStrategyFactory.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy
 29 2 2019-07-12 2019-07-12 1 2 +126 / -0 nickmahilani nmahilani
ParserType.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/serde
 30 5 2019-07-12 2019-07-12 1 2 +114 / -0 nickmahilani nmahilani
HttpServerInitializer.java
in mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http
 30 2 2019-07-12 2019-07-12 1 2 +108 / -0 nickmahilani nmahilani
NoopCheckpointStrategy.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy
 32 5 2019-07-12 2019-07-12 1 2 +120 / -0 nickmahilani nmahilani
KafkaAckable.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka
 35 6 2019-07-12 2019-07-12 1 2 +170 / -0 nickmahilani nmahilani
SourceSink.java
in mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http
 41 3 2019-07-12 2019-07-12 1 2 +142 / -0 nickmahilani nmahilani
StaticPartitionAssignorImpl.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/assignor
 44 1 2019-07-12 2019-07-12 1 2 +178 / -0 nickmahilani nmahilani
CountingCheckpointTrigger.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/trigger
 50 6 2019-07-12 2019-07-12 1 2 +162 / -0 nickmahilani nmahilani
KafkaConsumerRebalanceListener.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source
 51 3 2019-07-12 2019-07-12 1 2 +164 / -0 nickmahilani nmahilani
KafkaDataNotification.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka
 51 12 2019-07-12 2019-07-12 1 2 +194 / -0 nickmahilani nmahilani
AbstractSourceJobSource.java
in mantis-connector-job/src/main/java/io/mantisrx/connector/job/core
 57 7 2019-07-12 2019-07-12 1 2 +188 / -0 nickmahilani nmahilani
AbstractJobSource.java
in mantis-connector-job/src/main/java/io/mantisrx/connector/job/core
 59 2 2019-07-12 2019-07-12 1 2 +174 / -0 nickmahilani nmahilani
Files With Most Churn (Top 50)
Based on the number of lines added and deleted across all commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsline
churn		first
contributor		latest
contributor
IcebergWriterStage.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer
 275 20 2020-06-02 2020-08-13 22 1 +1405 / -573 jchao jchao
KafkaSource.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source
 299 5 2019-07-12 2019-09-16 2 2 +748 / -12 nickmahilani nmahilani
MantisKafkaConsumer.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source
 250 27 2019-07-12 2019-07-12 1 2 +672 / -0 nickmahilani nmahilani
JobSource.java
in mantis-connector-job/src/main/java/io/mantisrx/connector/job/source
 232 16 2019-07-12 2019-07-12 1 2 +612 / -0 nickmahilani nmahilani
IcebergCommitterStage.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer
 120 4 2020-06-02 2020-08-13 12 1 +481 / -111 jchao jchao
ServerSentEventsSink.java
in mantis-connector-job/src/main/java/io/mantisrx/connector/job/sink
 213 20 2019-07-12 2019-07-12 1 2 +536 / -0 nickmahilani nmahilani
MantisKafkaConsumerConfig.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source
 123 7 2019-07-12 2019-09-17 4 2 +406 / -70 nickmahilani nmahilani
DefaultIcebergWriter.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer
 115 11 2020-08-04 2020-09-23 4 1 +432 / -10 jchao jchao
MantisSourceJobConnector.java
in mantis-connector-job/src/main/java/io/mantisrx/connector/job/core
 151 11 2019-07-12 2019-07-12 1 2 +400 / -0 nickmahilani nmahilani
ConsumerMetrics.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/metrics
 131 17 2019-07-12 2019-07-12 1 2 +336 / -0 nickmahilani nmahilani
MantisKafkaSourceConfig.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source
 127 13 2019-07-12 2019-07-12 1 2 +332 / -0 nickmahilani nmahilani
TopicPartitionStateManager.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source
 97 8 2019-07-12 2019-07-12 1 2 +316 / -0 nickmahilani nmahilani
HttpSourceServerHandler.java
in mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http
 116 3 2019-07-12 2019-07-12 1 2 +314 / -0 nickmahilani nmahilani
FileBasedOffsetCheckpointStrategy.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy
 112 8 2019-07-12 2019-07-12 1 2 +310 / -0 nickmahilani nmahilani
NettyExceptionHandler.java
in mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http
 85 5 2019-07-12 2019-07-12 1 2 +296 / -0 nickmahilani nmahilani
QueryMap.java
in mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/core
 100 12 2019-07-12 2019-07-12 1 2 +296 / -0 nickmahilani nmahilani
WriterProperties.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/config
 26 1 2020-06-02 2020-09-10 12 1 +212 / -80 jchao jchao
MultiSinkConnectionStatusObserver.java
in mantis-connector-job/src/main/java/io/mantisrx/connector/job/core
 91 11 2019-07-12 2019-07-12 1 2 +292 / -0 nickmahilani nmahilani
WriterMetrics.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/metrics
 105 4 2020-06-02 2020-06-30 4 1 +281 / -7 jchao jchao
KafkaData.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka
 95 12 2019-07-12 2019-07-12 1 2 +264 / -0 nickmahilani nmahilani
WriterConfig.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/config
 39 6 2020-06-02 2020-07-28 9 1 +217 / -45 jchao jchao
QueryRegistry.java
in mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/core
 77 10 2019-07-12 2019-07-12 1 2 +254 / -0 nickmahilani nmahilani
MantisKafkaProducerConfig.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/sink
 85 6 2019-08-30 2019-09-17 3 2 +250 / -4 nickmahilani nmahilani
IcebergCommitter.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer
 19 2 2020-06-02 2020-06-30 7 1 +177 / -73 jchao jchao
PushHttpSource.java
in mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http
 87 2 2019-07-12 2019-07-12 1 2 +250 / -0 nickmahilani nmahilani
IcebergCodecs.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/codecs
 65 5 2020-06-16 2020-08-10 5 1 +226 / -16 jchao jchao
CommitterMetrics.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer/metrics
 78 4 2020-06-02 2020-06-30 4 1 +223 / -9 jchao jchao
KafkaOffsetCheckpointStrategy.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy
 68 6 2019-07-12 2019-07-12 1 2 +206 / -0 nickmahilani nmahilani
EventFilter.java
in mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/core
 64 4 2019-07-12 2019-07-12 1 2 +204 / -0 nickmahilani nmahilani
DefaultSinkConnectionStatusObserver.java
in mantis-connector-job/src/main/java/io/mantisrx/connector/job/core
 64 9 2019-07-12 2019-07-12 1 2 +200 / -0 nickmahilani nmahilani
KafkaDataNotification.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka
 51 12 2019-07-12 2019-07-12 1 2 +194 / -0 nickmahilani nmahilani
KafkaSink.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/sink
 70 2 2019-08-30 2019-08-30 1 2 +194 / -0 nickmahilani nmahilani
NettySourceHttpServer.java
in mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http
 65 4 2019-07-12 2019-07-12 1 2 +190 / -0 nickmahilani nmahilani
AbstractSourceJobSource.java
in mantis-connector-job/src/main/java/io/mantisrx/connector/job/core
 57 7 2019-07-12 2019-07-12 1 2 +188 / -0 nickmahilani nmahilani
StaticPartitionAssignorImpl.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/assignor
 44 1 2019-07-12 2019-07-12 1 2 +178 / -0 nickmahilani nmahilani
AbstractJobSource.java
in mantis-connector-job/src/main/java/io/mantisrx/connector/job/core
 59 2 2019-07-12 2019-07-12 1 2 +174 / -0 nickmahilani nmahilani
KafkaAckable.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka
 35 6 2019-07-12 2019-07-12 1 2 +170 / -0 nickmahilani nmahilani
KafkaConsumerRebalanceListener.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source
 51 3 2019-07-12 2019-07-12 1 2 +164 / -0 nickmahilani nmahilani
CountingCheckpointTrigger.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/trigger
 50 6 2019-07-12 2019-07-12 1 2 +162 / -0 nickmahilani nmahilani
SourceSink.java
in mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http
 41 3 2019-07-12 2019-07-12 1 2 +142 / -0 nickmahilani nmahilani
CheckpointStrategy.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy
 14 - 2019-07-12 2019-07-12 1 2 +140 / -0 nickmahilani nmahilani
SinkConfig.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/config
 26 4 2020-07-01 2020-07-01 1 1 +132 / -0 jchao jchao
CheckpointStrategyFactory.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy
 29 2 2019-07-12 2019-07-12 1 2 +126 / -0 nickmahilani nmahilani
IcebergWriter.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer
 15 - 2020-06-02 2020-08-10 6 1 +102 / -20 jchao jchao
NoopCheckpointStrategy.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy
 32 5 2019-07-12 2019-07-12 1 2 +120 / -0 nickmahilani nmahilani
Parser.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/serde
 12 1 2019-07-12 2019-07-12 1 2 +118 / -0 nickmahilani nmahilani
ParserType.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/serde
 30 5 2019-07-12 2019-07-12 1 2 +114 / -0 nickmahilani nmahilani
CommitterConfig.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer/config
 16 2 2020-06-02 2020-07-01 3 1 +102 / -8 jchao jchao
CheckpointingDisabledTrigger.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/trigger
 28 6 2019-07-12 2019-07-12 1 2 +110 / -0 nickmahilani nmahilani
HttpServerInitializer.java
in mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http
 30 2 2019-07-12 2019-07-12 1 2 +108 / -0 nickmahilani nmahilani
Files With Most Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsline
churn		first
contributor		latest
contributor
MantisKafkaConsumerConfig.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source
 123 7 2019-07-12 2019-09-17 4 2 +406 / -70 nickmahilani nmahilani
MantisKafkaProducerConfig.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/sink
 85 6 2019-08-30 2019-09-17 3 2 +250 / -4 nickmahilani nmahilani
KafkaSourceParameters.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka
 15 - 2019-07-12 2019-09-16 3 2 +78 / -4 nickmahilani nmahilani
KafkaSource.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source
 299 5 2019-07-12 2019-09-16 2 2 +748 / -12 nickmahilani nmahilani
QueryRegistry.java
in mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/core
 77 10 2019-07-12 2019-07-12 1 2 +254 / -0 nickmahilani nmahilani
QueryMap.java
in mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/core
 100 12 2019-07-12 2019-07-12 1 2 +296 / -0 nickmahilani nmahilani
ObjectUtils.java
in mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/core
 18 3 2019-07-12 2019-07-12 1 2 +80 / -0 nickmahilani nmahilani
EventFilter.java
in mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/core
 64 4 2019-07-12 2019-07-12 1 2 +204 / -0 nickmahilani nmahilani
NettyExceptionHandler.java
in mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http
 85 5 2019-07-12 2019-07-12 1 2 +296 / -0 nickmahilani nmahilani
SourceHttpServer.java
in mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http
 15 - 2019-07-12 2019-07-12 1 2 +78 / -0 nickmahilani nmahilani
NettySourceHttpServer.java
in mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http
 65 4 2019-07-12 2019-07-12 1 2 +190 / -0 nickmahilani nmahilani
HttpServerInitializer.java
in mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http
 30 2 2019-07-12 2019-07-12 1 2 +108 / -0 nickmahilani nmahilani
SourceSink.java
in mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http
 41 3 2019-07-12 2019-07-12 1 2 +142 / -0 nickmahilani nmahilani
PushHttpSource.java
in mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http
 87 2 2019-07-12 2019-07-12 1 2 +250 / -0 nickmahilani nmahilani
HttpSourceServerHandler.java
in mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http
 116 3 2019-07-12 2019-07-12 1 2 +314 / -0 nickmahilani nmahilani
MantisSourceJobConnectorFactory.java
in mantis-connector-job/src/main/java/io/mantisrx/connector/job/core
 6 1 2019-07-12 2019-07-12 1 2 +48 / -0 nickmahilani nmahilani
AbstractSourceJobSource.java
in mantis-connector-job/src/main/java/io/mantisrx/connector/job/core
 57 7 2019-07-12 2019-07-12 1 2 +188 / -0 nickmahilani nmahilani
MantisSourceJobConnector.java
in mantis-connector-job/src/main/java/io/mantisrx/connector/job/core
 151 11 2019-07-12 2019-07-12 1 2 +400 / -0 nickmahilani nmahilani
SinkConnectionStatusObserver.java
in mantis-connector-job/src/main/java/io/mantisrx/connector/job/core
 9 - 2019-07-12 2019-07-12 1 2 +64 / -0 nickmahilani nmahilani
AbstractJobSource.java
in mantis-connector-job/src/main/java/io/mantisrx/connector/job/core
 59 2 2019-07-12 2019-07-12 1 2 +174 / -0 nickmahilani nmahilani
MultiSinkConnectionStatusObserver.java
in mantis-connector-job/src/main/java/io/mantisrx/connector/job/core
 91 11 2019-07-12 2019-07-12 1 2 +292 / -0 nickmahilani nmahilani
DefaultSinkConnectionStatusObserver.java
in mantis-connector-job/src/main/java/io/mantisrx/connector/job/core
 64 9 2019-07-12 2019-07-12 1 2 +200 / -0 nickmahilani nmahilani
JobSource.java
in mantis-connector-job/src/main/java/io/mantisrx/connector/job/source
 232 16 2019-07-12 2019-07-12 1 2 +612 / -0 nickmahilani nmahilani
ServerSentEventsSink.java
in mantis-connector-job/src/main/java/io/mantisrx/connector/job/sink
 213 20 2019-07-12 2019-07-12 1 2 +536 / -0 nickmahilani nmahilani
KafkaDataNotification.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka
 51 12 2019-07-12 2019-07-12 1 2 +194 / -0 nickmahilani nmahilani
ConsumerMetrics.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/metrics
 131 17 2019-07-12 2019-07-12 1 2 +336 / -0 nickmahilani nmahilani
KafkaConsumerRebalanceListener.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source
 51 3 2019-07-12 2019-07-12 1 2 +164 / -0 nickmahilani nmahilani
CheckpointTrigger.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/trigger
 8 - 2019-07-12 2019-07-12 1 2 +98 / -0 nickmahilani nmahilani
CheckpointingDisabledTrigger.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/trigger
 28 6 2019-07-12 2019-07-12 1 2 +110 / -0 nickmahilani nmahilani
CheckpointTriggerFactory.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/trigger
 16 2 2019-07-12 2019-07-12 1 2 +86 / -0 nickmahilani nmahilani
CountingCheckpointTrigger.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/trigger
 50 6 2019-07-12 2019-07-12 1 2 +162 / -0 nickmahilani nmahilani
FileBasedOffsetCheckpointStrategy.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy
 112 8 2019-07-12 2019-07-12 1 2 +310 / -0 nickmahilani nmahilani
NoopCheckpointStrategy.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy
 32 5 2019-07-12 2019-07-12 1 2 +120 / -0 nickmahilani nmahilani
CheckpointStrategyOptions.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy
 11 2 2019-07-12 2019-07-12 1 2 +86 / -0 nickmahilani nmahilani
KafkaOffsetCheckpointStrategy.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy
 68 6 2019-07-12 2019-07-12 1 2 +206 / -0 nickmahilani nmahilani
CheckpointStrategyFactory.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy
 29 2 2019-07-12 2019-07-12 1 2 +126 / -0 nickmahilani nmahilani
CheckpointStrategy.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy
 14 - 2019-07-12 2019-07-12 1 2 +140 / -0 nickmahilani nmahilani
TopicPartitionStateManager.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source
 97 8 2019-07-12 2019-07-12 1 2 +316 / -0 nickmahilani nmahilani
MantisKafkaConsumer.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source
 250 27 2019-07-12 2019-07-12 1 2 +672 / -0 nickmahilani nmahilani
MantisKafkaSourceConfig.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source
 127 13 2019-07-12 2019-07-12 1 2 +332 / -0 nickmahilani nmahilani
StaticPartitionAssignorImpl.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/assignor
 44 1 2019-07-12 2019-07-12 1 2 +178 / -0 nickmahilani nmahilani
StaticPartitionAssignor.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/assignor
 9 - 2019-07-12 2019-07-12 1 2 +58 / -0 nickmahilani nmahilani
MapDeserializerBase.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/serde
 19 3 2019-07-12 2019-07-12 1 2 +84 / -0 nickmahilani nmahilani
Parser.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/serde
 12 1 2019-07-12 2019-07-12 1 2 +118 / -0 nickmahilani nmahilani
OffsetAndMetadataDeserializer.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/serde
 16 1 2019-07-12 2019-07-12 1 2 +76 / -0 nickmahilani nmahilani
ParseException.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/serde
 13 3 2019-07-12 2019-07-12 1 2 +76 / -0 nickmahilani nmahilani
SimpleJsonDeserializer.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/serde
 26 2 2019-07-12 2019-07-12 1 2 +106 / -0 nickmahilani nmahilani
ParserType.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/serde
 30 5 2019-07-12 2019-07-12 1 2 +114 / -0 nickmahilani nmahilani
OffsetAndMetadataSerializer.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/serde
 15 1 2019-07-12 2019-07-12 1 2 +68 / -0 nickmahilani nmahilani
KafkaSinkJobParameters.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/sink
 5 - 2019-08-30 2019-08-30 1 2 +44 / -0 nickmahilani nmahilani
Files With Least Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsline
churn		first
contributor		latest
contributor
92 -
pmd.xml
in codequality
 80 -
IcebergWriterStage.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer
 275 20 2020-06-02 2020-08-13 22 1 +1405 / -573 jchao jchao
IcebergCommitterStage.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer
 120 4 2020-06-02 2020-08-13 12 1 +481 / -111 jchao jchao
DefaultIcebergWriter.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer
 115 11 2020-08-04 2020-09-23 4 1 +432 / -10 jchao jchao
WriterMetrics.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/metrics
 105 4 2020-06-02 2020-06-30 4 1 +281 / -7 jchao jchao
CommitterMetrics.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer/metrics
 78 4 2020-06-02 2020-06-30 4 1 +223 / -9 jchao jchao
IcebergCodecs.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/codecs
 65 5 2020-06-16 2020-08-10 5 1 +226 / -16 jchao jchao
WriterConfig.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/config
 39 6 2020-06-02 2020-07-28 9 1 +217 / -45 jchao jchao
SinkConfig.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/config
 26 4 2020-07-01 2020-07-01 1 1 +132 / -0 jchao jchao
WriterProperties.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/config
 26 1 2020-06-02 2020-09-10 12 1 +212 / -80 jchao jchao
IcebergCommitter.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer
 19 2 2020-06-02 2020-06-30 7 1 +177 / -73 jchao jchao
CommitterConfig.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer/config
 16 2 2020-06-02 2020-07-01 3 1 +102 / -8 jchao jchao
IcebergWriter.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer
 15 - 2020-06-02 2020-08-10 6 1 +102 / -20 jchao jchao
SinkProperties.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/config
 11 1 2020-07-01 2020-07-01 1 1 +88 / -0 jchao jchao
CommitterProperties.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer/config
 10 1 2020-06-02 2020-06-23 2 1 +74 / -2 jchao jchao
NoOpPartitioner.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/partitioner
 8 1 2020-08-06 2020-08-10 2 1 +60 / -0 jchao jchao
Partitioner.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/partitioner
 5 - 2020-08-04 2020-08-10 2 1 +48 / -0 jchao jchao
PartitionerFactory.java
in mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/partitioner
 5 - 2020-08-04 2020-08-10 2 1 +48 / -0 jchao jchao
KafkaSource.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source
 299 5 2019-07-12 2019-09-16 2 2 +748 / -12 nickmahilani nmahilani
MantisKafkaConsumer.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source
 250 27 2019-07-12 2019-07-12 1 2 +672 / -0 nickmahilani nmahilani
JobSource.java
in mantis-connector-job/src/main/java/io/mantisrx/connector/job/source
 232 16 2019-07-12 2019-07-12 1 2 +612 / -0 nickmahilani nmahilani
ServerSentEventsSink.java
in mantis-connector-job/src/main/java/io/mantisrx/connector/job/sink
 213 20 2019-07-12 2019-07-12 1 2 +536 / -0 nickmahilani nmahilani
MantisSourceJobConnector.java
in mantis-connector-job/src/main/java/io/mantisrx/connector/job/core
 151 11 2019-07-12 2019-07-12 1 2 +400 / -0 nickmahilani nmahilani
ConsumerMetrics.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/metrics
 131 17 2019-07-12 2019-07-12 1 2 +336 / -0 nickmahilani nmahilani
MantisKafkaSourceConfig.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source
 127 13 2019-07-12 2019-07-12 1 2 +332 / -0 nickmahilani nmahilani
MantisKafkaConsumerConfig.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source
 123 7 2019-07-12 2019-09-17 4 2 +406 / -70 nickmahilani nmahilani
HttpSourceServerHandler.java
in mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http
 116 3 2019-07-12 2019-07-12 1 2 +314 / -0 nickmahilani nmahilani
FileBasedOffsetCheckpointStrategy.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy
 112 8 2019-07-12 2019-07-12 1 2 +310 / -0 nickmahilani nmahilani
QueryMap.java
in mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/core
 100 12 2019-07-12 2019-07-12 1 2 +296 / -0 nickmahilani nmahilani
TopicPartitionStateManager.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source
 97 8 2019-07-12 2019-07-12 1 2 +316 / -0 nickmahilani nmahilani
KafkaData.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka
 95 12 2019-07-12 2019-07-12 1 2 +264 / -0 nickmahilani nmahilani
MultiSinkConnectionStatusObserver.java
in mantis-connector-job/src/main/java/io/mantisrx/connector/job/core
 91 11 2019-07-12 2019-07-12 1 2 +292 / -0 nickmahilani nmahilani
PushHttpSource.java
in mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http
 87 2 2019-07-12 2019-07-12 1 2 +250 / -0 nickmahilani nmahilani
NettyExceptionHandler.java
in mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http
 85 5 2019-07-12 2019-07-12 1 2 +296 / -0 nickmahilani nmahilani
MantisKafkaProducerConfig.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/sink
 85 6 2019-08-30 2019-09-17 3 2 +250 / -4 nickmahilani nmahilani
QueryRegistry.java
in mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/core
 77 10 2019-07-12 2019-07-12 1 2 +254 / -0 nickmahilani nmahilani
KafkaSink.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/sink
 70 2 2019-08-30 2019-08-30 1 2 +194 / -0 nickmahilani nmahilani
KafkaOffsetCheckpointStrategy.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy
 68 6 2019-07-12 2019-07-12 1 2 +206 / -0 nickmahilani nmahilani
NettySourceHttpServer.java
in mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http
 65 4 2019-07-12 2019-07-12 1 2 +190 / -0 nickmahilani nmahilani
EventFilter.java
in mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/core
 64 4 2019-07-12 2019-07-12 1 2 +204 / -0 nickmahilani nmahilani
DefaultSinkConnectionStatusObserver.java
in mantis-connector-job/src/main/java/io/mantisrx/connector/job/core
 64 9 2019-07-12 2019-07-12 1 2 +200 / -0 nickmahilani nmahilani
AbstractJobSource.java
in mantis-connector-job/src/main/java/io/mantisrx/connector/job/core
 59 2 2019-07-12 2019-07-12 1 2 +174 / -0 nickmahilani nmahilani
AbstractSourceJobSource.java
in mantis-connector-job/src/main/java/io/mantisrx/connector/job/core
 57 7 2019-07-12 2019-07-12 1 2 +188 / -0 nickmahilani nmahilani
KafkaDataNotification.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka
 51 12 2019-07-12 2019-07-12 1 2 +194 / -0 nickmahilani nmahilani
KafkaConsumerRebalanceListener.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source
 51 3 2019-07-12 2019-07-12 1 2 +164 / -0 nickmahilani nmahilani
CountingCheckpointTrigger.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/trigger
 50 6 2019-07-12 2019-07-12 1 2 +162 / -0 nickmahilani nmahilani
StaticPartitionAssignorImpl.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/assignor
 44 1 2019-07-12 2019-07-12 1 2 +178 / -0 nickmahilani nmahilani
SourceSink.java
in mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http
 41 3 2019-07-12 2019-07-12 1 2 +142 / -0 nickmahilani nmahilani
KafkaAckable.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka
 35 6 2019-07-12 2019-07-12 1 2 +170 / -0 nickmahilani nmahilani
Correlations

File Size vs. Number of Changes: 70 points

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

Number of Contributors vs. Number of Changes: 70 points

mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/DefaultIcebergWriter.java x: 1 # contributors y: 4 # changes mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/config/WriterProperties.java x: 1 # contributors y: 12 # changes mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/IcebergWriterStage.java x: 1 # contributors y: 22 # changes mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/codecs/IcebergCodecs.java x: 1 # contributors y: 5 # changes mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/IcebergWriter.java x: 1 # contributors y: 6 # changes mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/partitioner/NoOpPartitioner.java x: 1 # contributors y: 2 # changes mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/config/WriterConfig.java x: 1 # contributors y: 9 # changes mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer/config/CommitterConfig.java x: 1 # contributors y: 3 # changes mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/config/SinkConfig.java x: 1 # contributors y: 1 # changes mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer/IcebergCommitter.java x: 1 # contributors y: 7 # changes mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/sink/MantisKafkaProducerConfig.java x: 2 # contributors y: 3 # changes mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/MantisKafkaConsumerConfig.java x: 2 # contributors y: 4 # changes mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/KafkaSource.java x: 2 # contributors y: 2 # changes mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/sink/KafkaSink.java x: 2 # contributors y: 1 # changes
22.0
# changes
  min: 1.0
  average: 2.27
  25th percentile: 1.0
  median: 1.0
  75th percentile: 2.0
  max: 22.0
0 2.0
# contributors
min: 1.0 | average: 1.76 | 25th percentile: 1.75 | median: 2.0 | 75th percentile: 2.0 | max: 2.0

Number of Contributors vs. File Size: 70 points

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

Number of Changes vs. Line Churn: 216 points

OSSMETADATA x: 1 # changes y: 2 line churn README.md x: 4 # changes y: 94 line churn mantis-connector-iceberg/build.gradle x: 9 # changes y: 174 line churn mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/DefaultIcebergWriter.java x: 4 # changes y: 442 line churn mantis-connector-iceberg/README.md x: 7 # changes y: 650 line churn mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/config/WriterProperties.java x: 12 # changes y: 292 line churn mantis-connector-iceberg/src/test/java/io/mantisrx/connector/iceberg/sink/writer/IcebergWriterStageTest.java x: 13 # changes y: 1154 line churn mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer/IcebergCommitterStage.java x: 12 # changes y: 592 line churn mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/IcebergWriterStage.java x: 22 # changes y: 1978 line churn mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/codecs/IcebergCodecs.java x: 5 # changes y: 242 line churn mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/BaseIcebergWriter.java x: 13 # changes y: 830 line churn mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/IcebergWriter.java x: 6 # changes y: 122 line churn mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/PartitionKey.java x: 4 # changes y: 324 line churn mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/PartitionedIcebergWriter.java x: 9 # changes y: 340 line churn mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/UnpartitionedIcebergWriter.java x: 8 # changes y: 222 line churn mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/partitioner/NoOpPartitioner.java x: 2 # changes y: 60 line churn mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/partitioner/Partitioner.java x: 2 # changes y: 48 line churn mantis-connector-iceberg/src/test/java/io/mantisrx/connector/iceberg/sink/codecs/IcebergCodecsTest.java x: 3 # changes y: 212 line churn mantis-connector-iceberg/src/test/java/io/mantisrx/connector/iceberg/sink/writer/PartitionedIcebergWriterTest.java x: 3 # changes y: 200 line churn mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/config/WriterConfig.java x: 9 # changes y: 262 line churn mantis-connector-iceberg/src/test/java/io/mantisrx/connector/iceberg/sink/StageOverrideParameters.java x: 2 # changes y: 102 line churn mantis-connector-iceberg/src/test/java/io/mantisrx/connector/iceberg/sink/TableIdentifierParameters.java x: 3 # changes y: 188 line churn mantis-connector-iceberg/src/test/java/io/mantisrx/connector/iceberg/sink/committer/IcebergCommitterStageTest.java x: 11 # changes y: 464 line churn mantis-connector-iceberg/src/test/java/io/mantisrx/connector/iceberg/sink/WriterStageOverrideParameters.java x: 1 # changes y: 102 line churn mantis-connector-publish/src/test/java/io/mantisrx/connector/publish/core/QueryRegistryTest.java x: 2 # changes y: 672 line churn mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer/config/CommitterConfig.java x: 3 # changes y: 110 line churn mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/config/SinkConfig.java x: 1 # changes y: 132 line churn mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/config/SinkProperties.java x: 1 # changes y: 88 line churn mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer/IcebergCommitter.java x: 7 # changes y: 250 line churn mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer/metrics/CommitterMetrics.java x: 4 # changes y: 232 line churn mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/metrics/WriterMetrics.java x: 4 # changes y: 288 line churn .github/CODEOWNERS x: 2 # changes y: 8 line churn build.gradle x: 4 # changes y: 12 line churn gradle/shadow.gradle x: 2 # changes y: 126 line churn gradle/wrapper/gradle-wrapper.properties x: 2 # changes y: 40 line churn mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer/config/CommitterProperties.java x: 2 # changes y: 76 line churn settings.gradle x: 4 # changes y: 22 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/sink/MantisKafkaProducerConfig.java x: 3 # changes y: 254 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/MantisKafkaConsumerConfig.java x: 4 # changes y: 476 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/KafkaSourceParameters.java x: 3 # changes y: 82 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/KafkaSource.java x: 2 # changes y: 760 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/sink/KafkaSink.java x: 1 # changes y: 194 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/sink/KafkaSinkJobParameters.java x: 1 # changes y: 44 line churn mantis-connector-kafka/src/test/java/io/mantisrx/connector/kafka/sink/KafkaSinkTest.java x: 1 # changes y: 184 line churn mantis-connector-kafka/src/test/java/io/mantisrx/connector/kafka/sink/MantisKafkaProducerConfigTest.java x: 1 # changes y: 138 line churn mantis-connector-kafka/src/test/java/io/mantisrx/connector/kafka/source/KafkaSourceTest.java x: 2 # changes y: 622 line churn mantis-connector-kafka/src/test/java/io/mantisrx/connector/kafka/source/MantisKafkaSourceConfigTest.java x: 2 # changes y: 170 line churn mantis-connector-kafka/src/test/java/io/mantisrx/connector/kafka/source/ParameterTestUtils.java x: 2 # changes y: 208 line churn mantis-connector-job/build.gradle x: 1 # changes y: 66 line churn mantis-connector-job/src/main/java/io/mantisrx/connector/job/core/AbstractJobSource.java x: 1 # changes y: 174 line churn mantis-connector-job/src/main/java/io/mantisrx/connector/job/core/DefaultSinkConnectionStatusObserver.java x: 1 # changes y: 200 line churn mantis-connector-job/src/main/java/io/mantisrx/connector/job/core/MantisSourceJobConnector.java x: 1 # changes y: 400 line churn mantis-connector-job/src/main/java/io/mantisrx/connector/job/core/MantisSourceJobConnectorFactory.java x: 1 # changes y: 48 line churn mantis-connector-job/src/main/java/io/mantisrx/connector/job/core/MultiSinkConnectionStatusObserver.java x: 1 # changes y: 292 line churn mantis-connector-job/src/main/java/io/mantisrx/connector/job/sink/ServerSentEventsSink.java x: 1 # changes y: 536 line churn mantis-connector-job/src/main/java/io/mantisrx/connector/job/source/JobSource.java x: 1 # changes y: 612 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/KafkaAckable.java x: 1 # changes y: 170 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/KafkaData.java x: 1 # changes y: 264 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/MantisKafkaConsumer.java x: 1 # changes y: 672 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/MantisKafkaSourceConfig.java x: 1 # changes y: 332 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/TopicPartitionStateManager.java x: 1 # changes y: 316 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/assignor/StaticPartitionAssignor.java x: 1 # changes y: 58 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy/FileBasedOffsetCheckpointStrategy.java x: 1 # changes y: 310 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy/KafkaOffsetCheckpointStrategy.java x: 1 # changes y: 206 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy/NoopCheckpointStrategy.java x: 1 # changes y: 120 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/trigger/CheckpointTrigger.java x: 1 # changes y: 98 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/trigger/CheckpointingDisabledTrigger.java x: 1 # changes y: 110 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/trigger/CountingCheckpointTrigger.java x: 1 # changes y: 162 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/metrics/ConsumerMetrics.java x: 1 # changes y: 336 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/serde/MapDeserializerBase.java x: 1 # changes y: 84 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/serde/OffsetAndMetadataDeserializer.java x: 1 # changes y: 76 line churn mantis-connector-kafka/src/test/java/io/mantisrx/connector/kafka/source/assignor/StaticPartitionAssignorTest.java x: 1 # changes y: 374 line churn mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/core/QueryMap.java x: 1 # changes y: 296 line churn mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/core/QueryRegistry.java x: 1 # changes y: 254 line churn mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http/SourceSink.java x: 1 # changes y: 142 line churn mantis-connector-publish/src/test/java/io/mantisrx/connector/publish/core/EventFilterTest.java x: 1 # changes y: 284 line churn mantis-connectors-job/build.gradle x: 2 # changes y: 84 line churn mantis-connectors-kafka/kafka-2.2/build.gradle x: 2 # changes y: 180 line churn mantis-connectors-kafka/kafka-2.2/src/main/java/io/mantisrx/connectors/kafka/KafkaAckable.java x: 2 # changes y: 340 line churn mantis-connectors-kafka/kafka-2.2/src/main/java/io/mantisrx/connectors/kafka/KafkaData.java x: 2 # changes y: 528 line churn mantis-connectors-kafka/kafka-2.2/src/main/java/io/mantisrx/connectors/kafka/KafkaDataNotification.java x: 2 # changes y: 388 line churn mantis-connectors-kafka/kafka-2.2/src/main/java/io/mantisrx/connectors/kafka/KafkaSourceParameters.java x: 2 # changes y: 148 line churn mantis-connectors-kafka/kafka-2.2/src/main/java/io/mantisrx/connectors/kafka/source/Kafka22ConsumerRebalanceListener.java x: 2 # changes y: 328 line churn mantis-connectors-kafka/kafka-2.2/src/main/java/io/mantisrx/connectors/kafka/source/KafkaSource22.java x: 2 # changes y: 1496 line churn mantis-connectors-kafka/kafka-2.2/src/main/java/io/mantisrx/connectors/kafka/source/MantisKafka22Consumer.java x: 2 # changes y: 1344 line churn mantis-connectors-kafka/kafka-2.2/src/main/java/io/mantisrx/connectors/kafka/source/MantisKafka22ConsumerConfig.java x: 2 # changes y: 736 line churn mantis-connectors-kafka/kafka-2.2/src/main/java/io/mantisrx/connectors/kafka/source/TopicPartitionStateManager.java x: 2 # changes y: 632 line churn mantis-connectors-kafka/kafka-2.2/src/main/java/io/mantisrx/connectors/kafka/source/assignor/StaticPartitionAssignor.java x: 2 # changes y: 116 line churn mantis-connectors-kafka/kafka-2.2/src/main/java/io/mantisrx/connectors/kafka/source/assignor/StaticPartitionAssignorImpl.java x: 2 # changes y: 356 line churn mantis-connectors-kafka/kafka-2.2/src/main/java/io/mantisrx/connectors/kafka/source/checkpoint/strategy/CheckpointStrategy.java x: 2 # changes y: 280 line churn mantis-connectors-kafka/kafka-2.2/src/main/java/io/mantisrx/connectors/kafka/source/checkpoint/strategy/CheckpointStrategyFactory.java x: 2 # changes y: 252 line churn mantis-connectors-kafka/kafka-2.2/src/main/java/io/mantisrx/connectors/kafka/source/checkpoint/strategy/CheckpointStrategyOptions.java x: 2 # changes y: 172 line churn mantis-connectors-kafka/kafka-2.2/src/main/java/io/mantisrx/connectors/kafka/source/checkpoint/strategy/Kafka22OffsetCheckpointStrategy.java x: 2 # changes y: 412 line churn mantis-connectors-kafka/kafka-2.2/src/main/java/io/mantisrx/connectors/kafka/source/checkpoint/strategy/NoopCheckpointStrategy.java x: 2 # changes y: 240 line churn mantis-connectors-kafka/kafka-2.2/src/main/java/io/mantisrx/connectors/kafka/source/checkpoint/trigger/CheckpointTrigger.java x: 2 # changes y: 196 line churn mantis-connectors-kafka/kafka-2.2/src/main/java/io/mantisrx/connectors/kafka/source/checkpoint/trigger/CheckpointingDisabledTrigger.java x: 2 # changes y: 220 line churn mantis-connectors-kafka/kafka-2.2/src/main/java/io/mantisrx/connectors/kafka/source/checkpoint/trigger/CountingCheckpointTrigger.java x: 2 # changes y: 324 line churn mantis-connectors-kafka/kafka-2.2/src/main/java/io/mantisrx/connectors/kafka/source/serde/OffsetAndMetadataSerializer.java x: 2 # changes y: 136 line churn mantis-connectors-kafka/kafka-2.2/src/main/java/io/mantisrx/connectors/kafka/source/serde/ParserType.java x: 2 # changes y: 228 line churn mantis-connectors-kafka/kafka-2.2/src/main/java/io/mantisrx/connectors/kafka/source/serde/SimpleJsonDeserializer.java x: 2 # changes y: 212 line churn mantis-connectors-kafka/kafka-2.2/src/test/java/io/mantisrx/connectors/kafka/source/KafkaSource22Test.java x: 2 # changes y: 1180 line churn mantis-connectors-kafka/kafka-2.2/src/test/java/io/mantisrx/connectors/kafka/source/MantisKafka22ConsumerConfigTest.java x: 2 # changes y: 364 line churn mantis-connectors-kafka/kafka-2.2/src/test/java/io/mantisrx/connectors/kafka/source/assignor/StaticPartitionAssignorTest.java x: 2 # changes y: 748 line churn mantis-connectors-kafka/kafka-2.2/src/test/java/io/mantisrx/connectors/kafka/source/checkpoint/strategy/FileBasedOffsetCheckpointStrategyTest.java x: 2 # changes y: 284 line churn mantis-connectors-publish/build.gradle x: 2 # changes y: 66 line churn mantis-connectors-publish/src/test/java/io/mantisrx/connectors/publish/core/QueryRegistryTest.java x: 1 # changes y: 662 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connectors/kafka/source/KafkaSource.java x: 1 # changes y: 748 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connectors/kafka/source/MantisKafkaConsumerConfig.java x: 1 # changes y: 368 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connectors/kafka/source/MantisKafkaSourceConfig.java x: 1 # changes y: 344 line churn mantis-connector-kafka/src/test/java/io/mantisrx/connectors/kafka/source/KafkaSourceTest.java x: 1 # changes y: 590 line churn mantis-connectors-kafka/build.gradle x: 1 # changes y: 32 line churn buildViaTravis.sh x: 2 # changes y: 26 line churn
1978.0
line churn
  min: 2.0
  average: 263.64
  25th percentile: 104.0
  median: 188.0
  75th percentile: 316.0
  max: 1978.0
0 22.0
# changes
min: 1.0 | average: 2.05 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 22.0

Number of Contributors vs. Line Churn: 70 points

mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/DefaultIcebergWriter.java x: 1 # contributors y: 442 line churn mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/config/WriterProperties.java x: 1 # contributors y: 292 line churn mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer/IcebergCommitterStage.java x: 1 # contributors y: 592 line churn mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/IcebergWriterStage.java x: 1 # contributors y: 1978 line churn mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/codecs/IcebergCodecs.java x: 1 # contributors y: 242 line churn mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/IcebergWriter.java x: 1 # contributors y: 122 line churn mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/partitioner/NoOpPartitioner.java x: 1 # contributors y: 60 line churn mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/partitioner/Partitioner.java x: 1 # contributors y: 48 line churn mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/config/WriterConfig.java x: 1 # contributors y: 262 line churn mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer/config/CommitterConfig.java x: 1 # contributors y: 110 line churn mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/config/SinkConfig.java x: 1 # contributors y: 132 line churn mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/config/SinkProperties.java x: 1 # contributors y: 88 line churn mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer/IcebergCommitter.java x: 1 # contributors y: 250 line churn mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer/metrics/CommitterMetrics.java x: 1 # contributors y: 232 line churn mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/metrics/WriterMetrics.java x: 1 # contributors y: 288 line churn mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer/config/CommitterProperties.java x: 1 # contributors y: 76 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/sink/MantisKafkaProducerConfig.java x: 2 # contributors y: 254 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/MantisKafkaConsumerConfig.java x: 2 # contributors y: 476 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/KafkaSourceParameters.java x: 2 # contributors y: 82 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/KafkaSource.java x: 2 # contributors y: 760 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/sink/KafkaSink.java x: 2 # contributors y: 194 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/sink/KafkaSinkJobParameters.java x: 2 # contributors y: 44 line churn mantis-connector-job/src/main/java/io/mantisrx/connector/job/core/AbstractJobSource.java x: 2 # contributors y: 174 line churn mantis-connector-job/src/main/java/io/mantisrx/connector/job/core/DefaultSinkConnectionStatusObserver.java x: 2 # contributors y: 200 line churn mantis-connector-job/src/main/java/io/mantisrx/connector/job/core/MantisSourceJobConnector.java x: 2 # contributors y: 400 line churn mantis-connector-job/src/main/java/io/mantisrx/connector/job/core/MantisSourceJobConnectorFactory.java x: 2 # contributors y: 48 line churn mantis-connector-job/src/main/java/io/mantisrx/connector/job/core/MultiSinkConnectionStatusObserver.java x: 2 # contributors y: 292 line churn mantis-connector-job/src/main/java/io/mantisrx/connector/job/core/SinkConnectionStatusObserver.java x: 2 # contributors y: 64 line churn mantis-connector-job/src/main/java/io/mantisrx/connector/job/sink/ServerSentEventsSink.java x: 2 # contributors y: 536 line churn mantis-connector-job/src/main/java/io/mantisrx/connector/job/source/JobSource.java x: 2 # contributors y: 612 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/KafkaAckable.java x: 2 # contributors y: 170 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/KafkaData.java x: 2 # contributors y: 264 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/MantisKafkaConsumer.java x: 2 # contributors y: 672 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/MantisKafkaSourceConfig.java x: 2 # contributors y: 332 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/TopicPartitionStateManager.java x: 2 # contributors y: 316 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/assignor/StaticPartitionAssignor.java x: 2 # contributors y: 58 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy/CheckpointStrategy.java x: 2 # contributors y: 140 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy/CheckpointStrategyFactory.java x: 2 # contributors y: 126 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy/CheckpointStrategyOptions.java x: 2 # contributors y: 86 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy/FileBasedOffsetCheckpointStrategy.java x: 2 # contributors y: 310 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy/KafkaOffsetCheckpointStrategy.java x: 2 # contributors y: 206 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy/NoopCheckpointStrategy.java x: 2 # contributors y: 120 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/trigger/CheckpointTrigger.java x: 2 # contributors y: 98 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/trigger/CheckpointingDisabledTrigger.java x: 2 # contributors y: 110 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/trigger/CountingCheckpointTrigger.java x: 2 # contributors y: 162 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/metrics/ConsumerMetrics.java x: 2 # contributors y: 336 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/serde/OffsetAndMetadataDeserializer.java x: 2 # contributors y: 76 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/serde/SimpleJsonDeserializer.java x: 2 # contributors y: 106 line churn mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/core/QueryMap.java x: 2 # contributors y: 296 line churn mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http/SourceSink.java x: 2 # contributors y: 142 line churn
1978.0
line churn
  min: 44.0
  average: 236.69
  25th percentile: 87.5
  median: 176.0
  75th percentile: 292.0
  max: 1978.0
0 2.0
# contributors
min: 1.0 | average: 1.76 | 25th percentile: 1.75 | median: 2.0 | 75th percentile: 2.0 | max: 2.0

File Size vs. Line Churn: 70 points

mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/DefaultIcebergWriter.java x: 115 lines of code y: 442 line churn mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/config/WriterProperties.java x: 26 lines of code y: 292 line churn mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer/IcebergCommitterStage.java x: 120 lines of code y: 592 line churn mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/IcebergWriterStage.java x: 275 lines of code y: 1978 line churn mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/codecs/IcebergCodecs.java x: 65 lines of code y: 242 line churn mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/IcebergWriter.java x: 15 lines of code y: 122 line churn mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/partitioner/NoOpPartitioner.java x: 8 lines of code y: 60 line churn mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/partitioner/Partitioner.java x: 5 lines of code y: 48 line churn mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/config/WriterConfig.java x: 39 lines of code y: 262 line churn mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer/config/CommitterConfig.java x: 16 lines of code y: 110 line churn mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/config/SinkConfig.java x: 26 lines of code y: 132 line churn mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/config/SinkProperties.java x: 11 lines of code y: 88 line churn mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer/IcebergCommitter.java x: 19 lines of code y: 250 line churn mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer/metrics/CommitterMetrics.java x: 78 lines of code y: 232 line churn mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/metrics/WriterMetrics.java x: 105 lines of code y: 288 line churn mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer/config/CommitterProperties.java x: 10 lines of code y: 76 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/sink/MantisKafkaProducerConfig.java x: 85 lines of code y: 254 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/MantisKafkaConsumerConfig.java x: 123 lines of code y: 476 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/KafkaSourceParameters.java x: 15 lines of code y: 82 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/KafkaSource.java x: 299 lines of code y: 760 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/sink/KafkaSink.java x: 70 lines of code y: 194 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/sink/KafkaSinkJobParameters.java x: 5 lines of code y: 44 line churn mantis-connector-job/src/main/java/io/mantisrx/connector/job/core/AbstractJobSource.java x: 59 lines of code y: 174 line churn mantis-connector-job/src/main/java/io/mantisrx/connector/job/core/AbstractSourceJobSource.java x: 57 lines of code y: 188 line churn mantis-connector-job/src/main/java/io/mantisrx/connector/job/core/DefaultSinkConnectionStatusObserver.java x: 64 lines of code y: 200 line churn mantis-connector-job/src/main/java/io/mantisrx/connector/job/core/MantisSourceJobConnector.java x: 151 lines of code y: 400 line churn mantis-connector-job/src/main/java/io/mantisrx/connector/job/core/MantisSourceJobConnectorFactory.java x: 6 lines of code y: 48 line churn mantis-connector-job/src/main/java/io/mantisrx/connector/job/core/MultiSinkConnectionStatusObserver.java x: 91 lines of code y: 292 line churn mantis-connector-job/src/main/java/io/mantisrx/connector/job/core/SinkConnectionStatusObserver.java x: 9 lines of code y: 64 line churn mantis-connector-job/src/main/java/io/mantisrx/connector/job/sink/ServerSentEventsSink.java x: 213 lines of code y: 536 line churn mantis-connector-job/src/main/java/io/mantisrx/connector/job/source/JobSource.java x: 232 lines of code y: 612 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/KafkaAckable.java x: 35 lines of code y: 170 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/KafkaData.java x: 95 lines of code y: 264 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/KafkaDataNotification.java x: 51 lines of code y: 194 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/KafkaConsumerRebalanceListener.java x: 51 lines of code y: 164 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/MantisKafkaConsumer.java x: 250 lines of code y: 672 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/MantisKafkaSourceConfig.java x: 127 lines of code y: 332 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/TopicPartitionStateManager.java x: 97 lines of code y: 316 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/assignor/StaticPartitionAssignor.java x: 9 lines of code y: 58 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/assignor/StaticPartitionAssignorImpl.java x: 44 lines of code y: 178 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy/CheckpointStrategy.java x: 14 lines of code y: 140 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy/CheckpointStrategyFactory.java x: 29 lines of code y: 126 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy/FileBasedOffsetCheckpointStrategy.java x: 112 lines of code y: 310 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy/KafkaOffsetCheckpointStrategy.java x: 68 lines of code y: 206 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/strategy/NoopCheckpointStrategy.java x: 32 lines of code y: 120 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/trigger/CheckpointTrigger.java x: 8 lines of code y: 98 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/trigger/CheckpointTriggerFactory.java x: 16 lines of code y: 86 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/trigger/CheckpointingDisabledTrigger.java x: 28 lines of code y: 110 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/checkpoint/trigger/CountingCheckpointTrigger.java x: 50 lines of code y: 162 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/metrics/ConsumerMetrics.java x: 131 lines of code y: 336 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/serde/MapDeserializerBase.java x: 19 lines of code y: 84 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/serde/OffsetAndMetadataDeserializer.java x: 16 lines of code y: 76 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/serde/OffsetAndMetadataSerializer.java x: 15 lines of code y: 68 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/serde/ParseException.java x: 13 lines of code y: 76 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/serde/Parser.java x: 12 lines of code y: 118 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/serde/ParserType.java x: 30 lines of code y: 114 line churn mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/serde/SimpleJsonDeserializer.java x: 26 lines of code y: 106 line churn mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/core/EventFilter.java x: 64 lines of code y: 204 line churn mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/core/ObjectUtils.java x: 18 lines of code y: 80 line churn mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/core/QueryMap.java x: 100 lines of code y: 296 line churn mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/core/QueryRegistry.java x: 77 lines of code y: 254 line churn mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http/HttpServerInitializer.java x: 30 lines of code y: 108 line churn mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http/HttpSourceServerHandler.java x: 116 lines of code y: 314 line churn mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http/NettyExceptionHandler.java x: 85 lines of code y: 296 line churn mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http/NettySourceHttpServer.java x: 65 lines of code y: 190 line churn mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http/PushHttpSource.java x: 87 lines of code y: 250 line churn mantis-connector-publish/src/main/java/io/mantisrx/connector/publish/source/http/SourceSink.java x: 41 lines of code y: 142 line churn
1978.0
line churn
  min: 44.0
  average: 236.69
  25th percentile: 87.5
  median: 176.0
  75th percentile: 292.0
  max: 1978.0
0 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