Netflix/mantis-connectors
File Age & Freshness
File age measurements show the distribution of file ages (days since the first commit) and the file freshness (days since the latest commit).
File Change History Overall
File Age Distribution Overall
Days since first update
  • There are 70 files with 4,504 lines of code in files.
    • 70 files that are 366+ days old (4,504 lines of code)
    • 0 files that are 181-365 days old (0 lines of code)
    • 0 files that are 91-180 days old (0 lines of code)
    • 0 files that are 31-90 days old (0 lines of code)
    • 0 files that are 1-30 days old (0 lines of code)
100% | 0% | 0% | 0% | 0%
Legend:
366+
181-365
91-180
31-90
1-30

explore: grouped by folders | grouped by age
File Freshness Distribution Overall
Days since last update
  • There are 70 files with 4,504 lines of code in files.
    • 70 files have been last changed 366+ days ago (4,504 lines of code)
    • 0 files have been last changed 181-365 days ago (0 lines of code)
    • 0 files have been last changed 91-180 days ago (0 lines of code)
    • 0 files have been last changed 31-90 days ago (0 lines of code)
    • 0 files have been last changed 1-30 days ago (0 lines of code)
100% | 0% | 0% | 0% | 0%
Legend:
366+
181-365
91-180
31-90
1-30

explore: grouped by folders | grouped by freshness
File Change History per File Extension
java, gradle, md, txt, xml, properties, sh, bat, gitignore, yml
File Age Distribution per Extension
Days since first update
366+
181-365
91-180
31-90
1-30
java100% | 0% | 0% | 0% | 0%
xml0% | 0% | 0% | 0% | 0%
File Freshness Distribution per Extension
Days since last update
366+
181-365
91-180
31-90
1-30
java100% | 0% | 0% | 0% | 0%
xml0% | 0% | 0% | 0% | 0%
File Change History per Logical Decomposition
primary
primary (file age distribution)
Days since first update
366+
181-365
91-180
31-90
1-30
mantis-connector-kafka100% | 0% | 0% | 0% | 0%
mantis-connector-iceberg100% | 0% | 0% | 0% | 0%
mantis-connector-job100% | 0% | 0% | 0% | 0%
mantis-connector-publish100% | 0% | 0% | 0% | 0%
codequality0% | 0% | 0% | 0% | 0%
primary (file freshness distribution)
Days since last update
366+
181-365
91-180
31-90
1-30
mantis-connector-kafka100% | 0% | 0% | 0% | 0%
mantis-connector-iceberg100% | 0% | 0% | 0% | 0%
mantis-connector-job100% | 0% | 0% | 0% | 0%
mantis-connector-publish100% | 0% | 0% | 0% | 0%
codequality0% | 0% | 0% | 0% | 0%
Oldest Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
KafkaSource.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source
 299 5 2019-07-12 2019-09-16 2 2 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 nickmahilani nmahilani
KafkaSourceParameters.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka
 15 - 2019-07-12 2019-09-16 3 2 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 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 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 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 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 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 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 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 nickmahilani nmahilani
Files Not Recently Changed (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
MantisSourceJobConnectorFactory.java
in mantis-connector-job/src/main/java/io/mantisrx/connector/job/core
 6 1 2019-07-12 2019-07-12 1 2 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 nickmahilani nmahilani
KafkaSourceParameters.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka
 15 - 2019-07-12 2019-09-16 3 2 nickmahilani nmahilani
Most Recently Created Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
92 -
pmd.xml
in codequality
 80 -
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 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 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 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 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 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 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 jchao jchao
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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 nickmahilani nmahilani
Most Recently Changed Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
92 -
pmd.xml
in codequality
 80 -
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 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 jchao jchao
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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 nickmahilani nmahilani
KafkaSourceParameters.java
in mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka
 15 - 2019-07-12 2019-09-16 3 2 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 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 nickmahilani nmahilani
Summary
  • Number of files: 72
  • Daily file updates (only one update per file and date counted): 217
  • First update: 2019-06-26
  • Latest update: 2020-10-01
  • Days between first and latest update: 464 (66 weeks, estimated 330 working days)
  • Active days (at least one file change): 38
  • Files without commit history (ignored): 2 (172 lines of code)
  • Data: