apache / flink-connector-pulsar
File Change Frequency

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

Overview
File Change Frequency Overall
  • There are 101 files with 8,074 lines of code.
    • 0 files changed more than 100 times (0 lines of code)
    • 0 files changed 51-100 times (0 lines of code)
    • 0 files changed 21-50 times (0 lines of code)
    • 22 files changed 6-20 times (3,676 lines of code)
    • 79 files changed 1-5 times (4,398 lines of code)
0% | 0% | 0% | 45% | 54%
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 101 files with 8,074 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)
    • 43 files changed by 2-5 contributors (4,432 lines of code)
    • 58 files changed by 1 contributor (3,642 lines of code)
0% | 0% | 0% | 54% | 45%
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, xml, html, md, yml, properties, gitignore, txt, proto, json, gitmodules, yaml
File Change Frequency per Extension
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
java0% | 0% | 0% | 45% | 54%
xml0% | 0% | 0% | 0% | 100%
File Change Frequency per Logical Decomposition
primary
primary (file change frequency)
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
flink-connector-pulsar0% | 0% | 0% | 45% | 54%
tools0% | 0% | 0% | 0% | 100%
Most Frequently Changed Files (Top 50)

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
PulsarSourceBuilder.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source
 284 32 2021-08-16 2023-02-16 17 4 yufan@streamnative.io yufan@streamnative.io
PulsarSourceOptions.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source
 519 1 2021-08-16 2023-02-15 15 2 yufan@streamnative.io yufan@streamnative.io
PulsarSourceEnumerator.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator
 202 11 2021-08-16 2023-02-16 14 2 yufan@streamnative.io yufan@streamnative.io
PulsarSourceConfigUtils.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/config
 133 3 2021-08-16 2023-07-20 11 2 yufan@streamnative.io wander4096@gmail.com
PulsarSource.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source
 113 8 2021-08-16 2023-02-13 10 2 yufan@streamnative.io yufan@streamnative.io
SourceConfiguration.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/config
 158 19 2021-08-16 2023-02-10 10 2 yufan@streamnative.io yufan@streamnative.io
PulsarWriter.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer
 184 7 2022-02-11 2023-03-31 10 3 yufan@streamnative.io mvisser@confluent.io
PulsarSinkOptions.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink
 221 1 2022-02-09 2023-03-27 10 3 yufan@streamnative.io tanyuxinwork@gmail.com
BasePulsarSubscriber.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/subscriber/impl
 63 3 2021-08-16 2023-02-16 8 1 yufan@streamnative.io yufan@streamnative.io
TopicNameUtils.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic
 71 7 2021-08-16 2023-03-31 8 3 yufan@streamnative.io mvisser@confluent.io
PulsarSinkBuilder.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink
 235 23 2022-02-11 2023-02-14 8 3 yufan@streamnative.io reswqa@163.com
PulsarOptions.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/config
 552 1 2021-08-16 2023-02-16 8 1 yufan@streamnative.io yufan@streamnative.io
MessageIdStartCursor.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor/start
 18 2 2021-08-16 2023-01-05 7 3 yufan@streamnative.io yufan@streamnative.io
TopicListSubscriber.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/subscriber/impl
 43 2 2021-08-16 2023-02-16 7 1 yufan@streamnative.io yufan@streamnative.io
TopicPatternSubscriber.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/subscriber/impl
 85 5 2021-08-16 2023-02-16 7 1 yufan@streamnative.io yufan@streamnative.io
TopicPartition.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic
 103 13 2021-08-16 2023-03-31 7 2 yufan@streamnative.io mvisser@confluent.io
SinkConfiguration.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/config
 108 12 2022-02-09 2023-02-13 7 1 yufan@streamnative.io yufan@streamnative.io
PulsarPartitionSplitReader.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader
 269 9 2023-01-03 2023-03-31 7 3 yufan@streamnative.io mvisser@confluent.io
PulsarPartitionSplit.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/split
 77 11 2021-08-16 2023-02-13 6 1 yufan@streamnative.io yufan@streamnative.io
StopCursor.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor
 78 12 2021-08-16 2023-02-13 6 3 yufan@streamnative.io yufan@streamnative.io
PulsarSinkConfigUtils.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/config
 79 2 2022-02-09 2023-02-15 6 1 yufan@streamnative.io yufan@streamnative.io
PulsarSink.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink
 81 4 2022-02-11 2023-02-14 6 2 yufan@streamnative.io reswqa@163.com
PulsarDeserializationSchema.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/deserializer
 22 1 2021-08-16 2023-02-10 5 2 yufan@streamnative.io yufan@streamnative.io
MessageIdStopCursor.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor/stop
 23 2 2021-08-16 2023-07-18 5 2 yufan@streamnative.io wander4096@gmail.com
StartCursor.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor
 30 6 2021-08-16 2023-02-10 5 3 yufan@streamnative.io yufan@streamnative.io
PulsarTransactionUtils.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/utils
 36 3 2021-08-16 2023-02-13 5 1 yufan@streamnative.io yufan@streamnative.io
PulsarSourceEnumStateSerializer.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator
 69 3 2021-08-16 2023-02-08 5 1 yufan@streamnative.io yufan@streamnative.io
CursorPosition.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor
 84 6 2021-08-16 2023-01-05 5 1 yufan@streamnative.io yufan@streamnative.io
PulsarPartitionSplitSerializer.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/split
 123 7 2021-08-16 2023-02-08 5 1 yufan@streamnative.io yufan@streamnative.io
PulsarClientFactory.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/config
 231 5 2022-02-09 2023-02-16 5 1 yufan@streamnative.io yufan@streamnative.io
TimestampStartCursor.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor/start
 14 2 2021-08-16 2022-08-12 4 2 yufan@streamnative.io yufan@streamnative.io
RangeGenerator.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic/range
 16 1 2021-08-16 2023-01-03 4 1 yufan@streamnative.io yufan@streamnative.io
PulsarSerializationSchema.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/serializer
 23 1 2022-02-15 2023-02-10 4 2 yufan@streamnative.io yufan@streamnative.io
PulsarSubscriber.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/subscriber
 27 2 2021-08-16 2023-02-16 4 1 yufan@streamnative.io yufan@streamnative.io
LatestMessageStopCursor.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor/stop
 27 3 2021-08-16 2023-02-13 4 1 yufan@streamnative.io yufan@streamnative.io
SplitAssigner.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/assigner
 29 1 2022-08-12 2023-01-03 4 1 yufan@streamnative.io yufan@streamnative.io
RoundRobinTopicRouter.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/router
 30 2 2022-02-15 2023-02-16 4 2 yufan@streamnative.io yufan@streamnative.io
PulsarDeserializationSchemaWrapper.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/deserializer
 30 4 2021-08-16 2023-02-10 4 2 yufan@streamnative.io yufan@streamnative.io
KeyHashTopicRouter.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/router
 35 2 2022-02-15 2023-03-31 4 2 yufan@streamnative.io mvisser@confluent.io
TopicRange.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic
 55 8 2021-08-16 2023-02-08 4 2 yufan@streamnative.io yufan@streamnative.io
PulsarCommitter.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/committer
 126 4 2022-02-15 2023-02-15 4 1 yufan@streamnative.io yufan@streamnative.io
PulsarSchema.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema
 152 12 2021-08-16 2022-11-07 4 1 yufan@streamnative.io yufan@streamnative.io
PulsarSourceReader.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader
 225 12 2023-01-03 2023-02-10 4 2 yufan@streamnative.io yufan@streamnative.io
FullRangeGenerator.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic/range
 15 1 2021-08-16 2023-01-03 3 1 yufan@streamnative.io yufan@streamnative.io
PulsarSourceEnumState.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator
 17 3 2021-08-16 2022-08-17 3 1 yufan@streamnative.io yufan@streamnative.io
CursorVerification.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/config
 20 1 2021-08-16 2022-11-10 3 2 yufan@streamnative.io noel.oconnor@gmail.com
JSONSchemaFactory.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/factories
 29 3 2021-08-16 2023-02-10 3 2 yufan@streamnative.io yufan@streamnative.io
PulsarSchemaWrapper.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/serializer
 34 5 2022-02-15 2023-02-08 3 2 yufan@streamnative.io yufan@streamnative.io
AvroSchemaFactory.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/factories
 35 3 2021-08-16 2023-02-10 3 2 yufan@streamnative.io yufan@streamnative.io
PulsarSchemaWrapper.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/deserializer
 43 7 2021-08-16 2023-01-08 3 2 yufan@streamnative.io syhily@gmail.com
Files With Most Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
PulsarSourceBuilder.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source
 284 32 2021-08-16 2023-02-16 17 4 yufan@streamnative.io yufan@streamnative.io
PulsarWriter.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer
 184 7 2022-02-11 2023-03-31 10 3 yufan@streamnative.io mvisser@confluent.io
PulsarSinkOptions.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink
 221 1 2022-02-09 2023-03-27 10 3 yufan@streamnative.io tanyuxinwork@gmail.com
TopicNameUtils.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic
 71 7 2021-08-16 2023-03-31 8 3 yufan@streamnative.io mvisser@confluent.io
PulsarSinkBuilder.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink
 235 23 2022-02-11 2023-02-14 8 3 yufan@streamnative.io reswqa@163.com
PulsarPartitionSplitReader.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader
 269 9 2023-01-03 2023-03-31 7 3 yufan@streamnative.io mvisser@confluent.io
MessageIdStartCursor.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor/start
 18 2 2021-08-16 2023-01-05 7 3 yufan@streamnative.io yufan@streamnative.io
StopCursor.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor
 78 12 2021-08-16 2023-02-13 6 3 yufan@streamnative.io yufan@streamnative.io
StartCursor.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor
 30 6 2021-08-16 2023-02-10 5 3 yufan@streamnative.io yufan@streamnative.io
PulsarSourceOptions.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source
 519 1 2021-08-16 2023-02-15 15 2 yufan@streamnative.io yufan@streamnative.io
PulsarSourceEnumerator.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator
 202 11 2021-08-16 2023-02-16 14 2 yufan@streamnative.io yufan@streamnative.io
PulsarSourceConfigUtils.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/config
 133 3 2021-08-16 2023-07-20 11 2 yufan@streamnative.io wander4096@gmail.com
SourceConfiguration.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/config
 158 19 2021-08-16 2023-02-10 10 2 yufan@streamnative.io yufan@streamnative.io
PulsarSource.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source
 113 8 2021-08-16 2023-02-13 10 2 yufan@streamnative.io yufan@streamnative.io
TopicPartition.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic
 103 13 2021-08-16 2023-03-31 7 2 yufan@streamnative.io mvisser@confluent.io
PulsarSink.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink
 81 4 2022-02-11 2023-02-14 6 2 yufan@streamnative.io reswqa@163.com
PulsarDeserializationSchema.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/deserializer
 22 1 2021-08-16 2023-02-10 5 2 yufan@streamnative.io yufan@streamnative.io
MessageIdStopCursor.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor/stop
 23 2 2021-08-16 2023-07-18 5 2 yufan@streamnative.io wander4096@gmail.com
PulsarDeserializationSchemaWrapper.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/deserializer
 30 4 2021-08-16 2023-02-10 4 2 yufan@streamnative.io yufan@streamnative.io
PulsarSourceReader.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader
 225 12 2023-01-03 2023-02-10 4 2 yufan@streamnative.io yufan@streamnative.io
TimestampStartCursor.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor/start
 14 2 2021-08-16 2022-08-12 4 2 yufan@streamnative.io yufan@streamnative.io
TopicRange.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic
 55 8 2021-08-16 2023-02-08 4 2 yufan@streamnative.io yufan@streamnative.io
PulsarSerializationSchema.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/serializer
 23 1 2022-02-15 2023-02-10 4 2 yufan@streamnative.io yufan@streamnative.io
KeyHashTopicRouter.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/router
 35 2 2022-02-15 2023-03-31 4 2 yufan@streamnative.io mvisser@confluent.io
RoundRobinTopicRouter.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/router
 30 2 2022-02-15 2023-02-16 4 2 yufan@streamnative.io yufan@streamnative.io
PulsarSchemaWrapper.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/deserializer
 43 7 2021-08-16 2023-01-08 3 2 yufan@streamnative.io syhily@gmail.com
PulsarSourceFetcherManager.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader
 99 7 2023-01-03 2023-04-25 3 2 yufan@streamnative.io wander4096@gmail.com
CursorVerification.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/config
 20 1 2021-08-16 2022-11-10 3 2 yufan@streamnative.io noel.oconnor@gmail.com
PulsarSchemaWrapper.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/serializer
 34 5 2022-02-15 2023-02-08 3 2 yufan@streamnative.io yufan@streamnative.io
ProducerRegister.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/topic
 260 12 2023-02-08 2023-03-31 3 2 yufan@streamnative.io mvisser@confluent.io
MetadataListener.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/topic
 165 10 2023-02-08 2023-03-31 3 2 yufan@streamnative.io mvisser@confluent.io
MessageKeyHash.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/router
 51 4 2022-02-15 2022-11-10 3 2 yufan@streamnative.io noel.oconnor@gmail.com
AvroSchemaFactory.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/factories
 35 3 2021-08-16 2023-02-10 3 2 yufan@streamnative.io yufan@streamnative.io
JSONSchemaFactory.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/factories
 29 3 2021-08-16 2023-02-10 3 2 yufan@streamnative.io yufan@streamnative.io
PulsarConsumerBuilder.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/config
 58 1 2022-09-28 2023-03-31 2 2 yufan@streamnative.io mvisser@confluent.io
EventTimestampStopCursor.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor/stop
 17 2 2022-01-12 2022-08-12 2 2 affeisme@gmail.com yufan@streamnative.io
PublishTimestampStopCursor.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor/stop
 17 2 2022-01-12 2022-08-12 2 2 affeisme@gmail.com yufan@streamnative.io
TopicRoutingMode.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/router
 44 2 2022-02-15 2022-11-10 2 2 yufan@streamnative.io noel.oconnor@gmail.com
PulsarAdminInvocationHandler.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/handler
 98 6 2023-02-16 2023-03-31 2 2 yufan@streamnative.io mvisser@confluent.io
PulsarConfigValidator.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/config
 58 6 2022-02-09 2023-03-31 2 2 yufan@streamnative.io mvisser@confluent.io
PrimitiveSchemaFactory.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/factories
 55 5 2021-08-16 2023-03-31 2 2 yufan@streamnative.io mvisser@confluent.io
KeyValueSchemaFactory.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/factories
 45 1 2021-08-16 2023-01-08 2 2 yufan@streamnative.io syhily@gmail.com
PulsarSchemaTypeSerializer.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema
 148 21 2021-08-16 2023-01-08 2 2 yufan@streamnative.io syhily@gmail.com
BasePulsarSubscriber.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/subscriber/impl
 63 3 2021-08-16 2023-02-16 8 1 yufan@streamnative.io yufan@streamnative.io
PulsarOptions.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/config
 552 1 2021-08-16 2023-02-16 8 1 yufan@streamnative.io yufan@streamnative.io
TopicPatternSubscriber.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/subscriber/impl
 85 5 2021-08-16 2023-02-16 7 1 yufan@streamnative.io yufan@streamnative.io
TopicListSubscriber.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/subscriber/impl
 43 2 2021-08-16 2023-02-16 7 1 yufan@streamnative.io yufan@streamnative.io
SinkConfiguration.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/config
 108 12 2022-02-09 2023-02-13 7 1 yufan@streamnative.io yufan@streamnative.io
PulsarPartitionSplit.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/split
 77 11 2021-08-16 2023-02-13 6 1 yufan@streamnative.io yufan@streamnative.io
PulsarSinkConfigUtils.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/config
 79 2 2022-02-09 2023-02-15 6 1 yufan@streamnative.io yufan@streamnative.io
Files With Least Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
PulsarOptions.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/config
 552 1 2021-08-16 2023-02-16 8 1 yufan@streamnative.io yufan@streamnative.io
PulsarClientFactory.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/config
 231 5 2022-02-09 2023-02-16 5 1 yufan@streamnative.io yufan@streamnative.io
PulsarSchemaUtils.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema
 152 11 2021-08-16 2023-02-08 3 1 yufan@streamnative.io yufan@streamnative.io
PulsarSchema.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema
 152 12 2021-08-16 2022-11-07 4 1 yufan@streamnative.io yufan@streamnative.io
PulsarCommitter.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/committer
 126 4 2022-02-15 2023-02-15 4 1 yufan@streamnative.io yufan@streamnative.io
PulsarPartitionSplitSerializer.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/split
 123 7 2021-08-16 2023-02-08 5 1 yufan@streamnative.io yufan@streamnative.io
PulsarSerdeUtils.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/utils
 112 10 2021-08-16 2022-09-28 3 1 yufan@streamnative.io yufan@streamnative.io
SinkConfiguration.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/config
 108 12 2022-02-09 2023-02-13 7 1 yufan@streamnative.io yufan@streamnative.io
SplitAssignerImpl.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/assigner
 107 8 2023-01-03 2023-01-03 1 1 yufan@streamnative.io yufan@streamnative.io
FixedKeysRangeGenerator.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic/range
 87 10 2022-09-28 2023-01-03 2 1 yufan@streamnative.io yufan@streamnative.io
PulsarMessage.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/message
 87 11 2022-02-15 2023-02-15 3 1 yufan@streamnative.io yufan@streamnative.io
TopicPatternSubscriber.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/subscriber/impl
 85 5 2021-08-16 2023-02-16 7 1 yufan@streamnative.io yufan@streamnative.io
CursorPosition.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor
 84 6 2021-08-16 2023-01-05 5 1 yufan@streamnative.io yufan@streamnative.io
PulsarSinkConfigUtils.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/config
 79 2 2022-02-09 2023-02-15 6 1 yufan@streamnative.io yufan@streamnative.io
PulsarConfigBuilder.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/config
 78 7 2022-02-09 2022-02-09 1 1 yufan@streamnative.io yufan@streamnative.io
PulsarPartitionSplit.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/split
 77 11 2021-08-16 2023-02-13 6 1 yufan@streamnative.io yufan@streamnative.io
PulsarMessageBuilder.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/message
 72 9 2022-02-15 2023-02-08 3 1 yufan@streamnative.io yufan@streamnative.io
PulsarSourceEnumStateSerializer.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator
 69 3 2021-08-16 2023-02-08 5 1 yufan@streamnative.io yufan@streamnative.io
DefaultPulsarCrypto.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/crypto
 69 7 2023-01-10 2023-02-08 2 1 yufan@streamnative.io yufan@streamnative.io
TopicRangeUtils.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic/range
 65 6 2022-09-28 2023-01-03 2 1 yufan@streamnative.io yufan@streamnative.io
BasePulsarSubscriber.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/subscriber/impl
 63 3 2021-08-16 2023-02-16 8 1 yufan@streamnative.io yufan@streamnative.io
PulsarSchemaTypeInformation.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema
 63 12 2021-08-16 2021-08-16 1 1 yufan@streamnative.io yufan@streamnative.io
GenericRecordDeserializationSchema.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/deserializer
 54 5 2023-02-10 2023-02-10 1 1 yufan@streamnative.io yufan@streamnative.io
PulsarConfiguration.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/config
 54 5 2022-02-09 2022-03-30 2 1 yufan@streamnative.io yufan@streamnative.io
PulsarRecordEmitter.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader
 47 6 2023-01-03 2023-01-03 1 1 yufan@streamnative.io yufan@streamnative.io
PulsarSinkContextImpl.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/context
 47 6 2022-02-15 2023-02-08 2 1 yufan@streamnative.io yufan@streamnative.io
BytesSchema.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema
 45 5 2023-01-08 2023-01-08 1 1 syhily@gmail.com syhily@gmail.com
TopicListSubscriber.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/subscriber/impl
 43 2 2021-08-16 2023-02-16 7 1 yufan@streamnative.io yufan@streamnative.io
MetricNames.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/metrics
 39 1 2022-11-11 2022-11-11 1 1 yufan@streamnative.io yufan@streamnative.io
PulsarCommittable.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/committer
 38 6 2022-02-15 2022-02-15 1 1 yufan@streamnative.io yufan@streamnative.io
PulsarCommittableSerializer.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/committer
 38 2 2022-02-15 2022-02-15 1 1 yufan@streamnative.io yufan@streamnative.io
ProducerMetricsInterceptor.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/metrics
 38 5 2022-11-11 2022-11-11 1 1 yufan@streamnative.io yufan@streamnative.io
PulsarPartitionSplitState.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/split
 37 7 2021-08-16 2021-09-03 2 1 yufan@streamnative.io yufan@streamnative.io
PulsarTransactionUtils.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/utils
 36 3 2021-08-16 2023-02-13 5 1 yufan@streamnative.io yufan@streamnative.io
PulsarTypeInformationWrapper.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/deserializer
 33 3 2021-08-16 2023-02-10 2 1 yufan@streamnative.io yufan@streamnative.io
PulsarDeserializationSchemaInitializationContext.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/deserializer
 30 4 2021-08-16 2023-02-10 2 1 yufan@streamnative.io yufan@streamnative.io
SplitAssigner.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/assigner
 29 1 2022-08-12 2023-01-03 4 1 yufan@streamnative.io yufan@streamnative.io
PulsarSerializationSchemaWrapper.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/serializer
 28 3 2022-02-15 2023-02-08 2 1 yufan@streamnative.io yufan@streamnative.io
PulsarCrypto.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/crypto
 28 3 2023-01-10 2023-01-10 1 1 yufan@streamnative.io yufan@streamnative.io
LatestMessageStopCursor.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor/stop
 27 3 2021-08-16 2023-02-13 4 1 yufan@streamnative.io yufan@streamnative.io
PulsarSubscriber.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/subscriber
 27 2 2021-08-16 2023-02-16 4 1 yufan@streamnative.io yufan@streamnative.io
PulsarAdminProxyBuilder.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/config
 26 3 2023-02-16 2023-02-16 1 1 yufan@streamnative.io yufan@streamnative.io
TopicMetadata.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic
 23 4 2021-08-16 2021-08-16 1 1 yufan@streamnative.io yufan@streamnative.io
ProtobufNativeSchemaFactory.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/factories
 20 2 2021-08-16 2023-02-10 2 1 yufan@streamnative.io yufan@streamnative.io
MessageDelayer.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/delayer
 19 3 2022-02-11 2022-02-11 1 1 yufan@streamnative.io yufan@streamnative.io
FixedMessageDelayer.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/delayer
 19 2 2022-02-11 2022-02-11 1 1 yufan@streamnative.io yufan@streamnative.io
ProtobufSchemaFactory.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/factories
 19 2 2021-08-16 2023-02-10 2 1 yufan@streamnative.io yufan@streamnative.io
PulsarSchemaFactory.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema
 18 1 2021-08-16 2023-02-10 2 1 yufan@streamnative.io yufan@streamnative.io
PulsarSourceEnumState.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator
 17 3 2021-08-16 2022-08-17 3 1 yufan@streamnative.io yufan@streamnative.io
TopicRouter.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/router
 17 1 2022-02-15 2023-02-08 2 1 yufan@streamnative.io yufan@streamnative.io
Correlations

File Size vs. Number of Changes: 101 points

flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/config/PulsarSourceConfigUtils.java x: 133 lines of code y: 11 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor/stop/MessageIdStopCursor.java x: 23 lines of code y: 5 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/PulsarSourceFetcherManager.java x: 99 lines of code y: 3 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/config/PulsarConfigValidator.java x: 58 lines of code y: 2 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/handler/PulsarAdminInvocationHandler.java x: 98 lines of code y: 2 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/factories/PrimitiveSchemaFactory.java x: 55 lines of code y: 2 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/PulsarWriter.java x: 184 lines of code y: 10 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/router/KeyHashTopicRouter.java x: 35 lines of code y: 4 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/topic/MetadataListener.java x: 165 lines of code y: 3 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/topic/ProducerRegister.java x: 260 lines of code y: 3 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic/TopicNameUtils.java x: 71 lines of code y: 8 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic/TopicPartition.java x: 103 lines of code y: 7 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/PulsarPartitionSplitReader.java x: 269 lines of code y: 7 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/PulsarSinkOptions.java x: 221 lines of code y: 10 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/subscriber/impl/TopicPatternSubscriber.java x: 85 lines of code y: 7 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/PulsarSourceBuilder.java x: 284 lines of code y: 17 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/router/RoundRobinTopicRouter.java x: 30 lines of code y: 4 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/PulsarSourceEnumerator.java x: 202 lines of code y: 14 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/subscriber/PulsarSubscriber.java x: 27 lines of code y: 4 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/subscriber/impl/BasePulsarSubscriber.java x: 63 lines of code y: 8 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/subscriber/impl/TopicListSubscriber.java x: 43 lines of code y: 7 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/config/PulsarAdminProxyBuilder.java x: 26 lines of code y: 1 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/config/PulsarClientFactory.java x: 231 lines of code y: 5 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/config/PulsarOptions.java x: 552 lines of code y: 8 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/committer/PulsarCommitter.java x: 126 lines of code y: 4 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/config/PulsarSinkConfigUtils.java x: 79 lines of code y: 6 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/message/PulsarMessage.java x: 87 lines of code y: 3 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/PulsarSourceOptions.java x: 519 lines of code y: 15 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/PulsarSink.java x: 81 lines of code y: 6 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/PulsarSinkBuilder.java x: 235 lines of code y: 8 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/PulsarSource.java x: 113 lines of code y: 10 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/utils/PulsarTransactionUtils.java x: 36 lines of code y: 5 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/config/SinkConfiguration.java x: 108 lines of code y: 7 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor/StopCursor.java x: 78 lines of code y: 6 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/split/PulsarPartitionSplit.java x: 77 lines of code y: 6 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/config/SourceConfiguration.java x: 158 lines of code y: 10 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/PulsarSchemaFactory.java x: 18 lines of code y: 2 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/factories/AvroSchemaFactory.java x: 35 lines of code y: 3 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/factories/JSONSchemaFactory.java x: 29 lines of code y: 3 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/factories/ProtobufNativeSchemaFactory.java x: 20 lines of code y: 2 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/factories/ProtobufSchemaFactory.java x: 19 lines of code y: 2 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/factories/StringSchemaFactory.java x: 14 lines of code y: 2 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/serializer/PulsarSerializationSchema.java x: 23 lines of code y: 4 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor/StartCursor.java x: 30 lines of code y: 5 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/PulsarSourceReader.java x: 225 lines of code y: 4 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/deserializer/GenericRecordDeserializationSchema.java x: 54 lines of code y: 1 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/deserializer/GenericRecordDeserializer.java x: 10 lines of code y: 1 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/deserializer/PulsarDeserializationSchema.java x: 22 lines of code y: 5 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/deserializer/PulsarDeserializationSchemaInitializationContext.java x: 30 lines of code y: 2 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/deserializer/PulsarTypeInformationWrapper.java x: 33 lines of code y: 2 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/context/PulsarSinkContextImpl.java x: 47 lines of code y: 2 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/message/PulsarMessageBuilder.java x: 72 lines of code y: 3 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/router/TopicRouter.java x: 17 lines of code y: 2 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/PulsarSourceEnumStateSerializer.java x: 69 lines of code y: 5 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic/TopicRange.java x: 55 lines of code y: 4 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/split/PulsarPartitionSplitSerializer.java x: 123 lines of code y: 5 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/crypto/DefaultPulsarCrypto.java x: 69 lines of code y: 2 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/PulsarSchemaUtils.java x: 152 lines of code y: 3 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/serializer/PulsarSchemaWrapper.java x: 34 lines of code y: 3 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/serializer/PulsarSerializationSchemaWrapper.java x: 28 lines of code y: 2 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/crypto/PulsarCrypto.java x: 28 lines of code y: 1 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/BytesSchema.java x: 45 lines of code y: 1 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/PulsarSchemaTypeSerializer.java x: 148 lines of code y: 2 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/factories/KeyValueSchemaFactory.java x: 45 lines of code y: 2 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/deserializer/PulsarSchemaWrapper.java x: 43 lines of code y: 3 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor/CursorPosition.java x: 84 lines of code y: 5 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor/start/MessageIdStartCursor.java x: 18 lines of code y: 7 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/assigner/SplitAssigner.java x: 29 lines of code y: 4 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/assigner/SplitAssignerImpl.java x: 107 lines of code y: 1 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic/range/FixedKeysRangeGenerator.java x: 87 lines of code y: 2 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic/range/FullRangeGenerator.java x: 15 lines of code y: 3 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic/range/RangeGenerator.java x: 16 lines of code y: 4 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic/range/TopicRangeUtils.java x: 65 lines of code y: 2 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/PulsarRecordEmitter.java x: 47 lines of code y: 1 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/metrics/MetricNames.java x: 39 lines of code y: 1 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/metrics/ProducerMetricsInterceptor.java x: 38 lines of code y: 1 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/router/MessageKeyHash.java x: 51 lines of code y: 3 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/router/TopicRoutingMode.java x: 44 lines of code y: 2 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/config/CursorVerification.java x: 20 lines of code y: 3 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/PulsarSchema.java x: 152 lines of code y: 4 # changes tools/maven/suppressions.xml x: 9 lines of code y: 1 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/utils/PulsarSerdeUtils.java x: 112 lines of code y: 3 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/PulsarSourceEnumState.java x: 17 lines of code y: 3 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor/start/TimestampStartCursor.java x: 14 lines of code y: 4 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor/stop/NeverStopCursor.java x: 10 lines of code y: 2 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/config/PulsarConfiguration.java x: 54 lines of code y: 2 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/delayer/FixedMessageDelayer.java x: 19 lines of code y: 1 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/config/PulsarConfigBuilder.java x: 78 lines of code y: 1 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/split/PulsarPartitionSplitState.java x: 37 lines of code y: 2 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/PulsarSchemaTypeInformation.java x: 63 lines of code y: 1 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic/TopicMetadata.java x: 23 lines of code y: 1 # changes
17.0
# changes
  min: 1.0
  average: 3.97
  25th percentile: 2.0
  median: 3.0
  75th percentile: 5.0
  max: 17.0
0 552.0
lines of code
min: 9.0 | average: 79.94 | 25th percentile: 26.5 | median: 47.0 | 75th percentile: 98.5 | max: 552.0

Number of Contributors vs. Number of Changes: 101 points

flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/config/PulsarSourceConfigUtils.java x: 2 # contributors y: 11 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor/stop/MessageIdStopCursor.java x: 2 # contributors y: 5 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/PulsarSourceFetcherManager.java x: 2 # contributors y: 3 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/config/PulsarConfigValidator.java x: 2 # contributors y: 2 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/PulsarWriter.java x: 3 # contributors y: 10 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/router/KeyHashTopicRouter.java x: 2 # contributors y: 4 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic/TopicNameUtils.java x: 3 # contributors y: 8 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic/TopicPartition.java x: 2 # contributors y: 7 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/PulsarPartitionSplitReader.java x: 3 # contributors y: 7 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/subscriber/impl/TopicPatternSubscriber.java x: 1 # contributors y: 7 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/PulsarSourceBuilder.java x: 4 # contributors y: 17 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/PulsarSourceEnumerator.java x: 2 # contributors y: 14 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/subscriber/PulsarSubscriber.java x: 1 # contributors y: 4 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/subscriber/impl/BasePulsarSubscriber.java x: 1 # contributors y: 8 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/config/PulsarAdminProxyBuilder.java x: 1 # contributors y: 1 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/config/PulsarClientFactory.java x: 1 # contributors y: 5 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/config/PulsarSinkConfigUtils.java x: 1 # contributors y: 6 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/message/PulsarMessage.java x: 1 # contributors y: 3 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/PulsarSourceOptions.java x: 2 # contributors y: 15 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/PulsarSink.java x: 2 # contributors y: 6 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/PulsarSource.java x: 2 # contributors y: 10 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor/StopCursor.java x: 3 # contributors y: 6 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/PulsarSchemaFactory.java x: 1 # contributors y: 2 # changes flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor/StartCursor.java x: 3 # contributors y: 5 # changes
17.0
# changes
  min: 1.0
  average: 3.97
  25th percentile: 2.0
  median: 3.0
  75th percentile: 5.0
  max: 17.0
0 4.0
# contributors
min: 1.0 | average: 1.52 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 4.0

Number of Contributors vs. File Size: 101 points

flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/config/PulsarSourceConfigUtils.java x: 2 # contributors y: 133 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor/stop/MessageIdStopCursor.java x: 2 # contributors y: 23 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/PulsarSourceFetcherManager.java x: 2 # contributors y: 99 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/config/PulsarConfigValidator.java x: 2 # contributors y: 58 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/factories/PrimitiveSchemaFactory.java x: 2 # contributors y: 55 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/PulsarWriter.java x: 3 # contributors y: 184 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/router/KeyHashTopicRouter.java x: 2 # contributors y: 35 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/topic/MetadataListener.java x: 2 # contributors y: 165 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/topic/ProducerRegister.java x: 2 # contributors y: 260 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic/TopicNameUtils.java x: 3 # contributors y: 71 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic/TopicPartition.java x: 2 # contributors y: 103 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/PulsarPartitionSplitReader.java x: 3 # contributors y: 269 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/PulsarSinkOptions.java x: 3 # contributors y: 221 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/subscriber/impl/TopicPatternSubscriber.java x: 1 # contributors y: 85 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/PulsarSourceBuilder.java x: 4 # contributors y: 284 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/router/RoundRobinTopicRouter.java x: 2 # contributors y: 30 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/PulsarSourceEnumerator.java x: 2 # contributors y: 202 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/subscriber/PulsarSubscriber.java x: 1 # contributors y: 27 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/subscriber/impl/BasePulsarSubscriber.java x: 1 # contributors y: 63 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/subscriber/impl/TopicListSubscriber.java x: 1 # contributors y: 43 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/config/PulsarAdminProxyBuilder.java x: 1 # contributors y: 26 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/config/PulsarClientFactory.java x: 1 # contributors y: 231 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/config/PulsarOptions.java x: 1 # contributors y: 552 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/committer/PulsarCommitter.java x: 1 # contributors y: 126 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/config/PulsarSinkConfigUtils.java x: 1 # contributors y: 79 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/message/PulsarMessage.java x: 1 # contributors y: 87 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/PulsarSourceOptions.java x: 2 # contributors y: 519 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/PulsarSink.java x: 2 # contributors y: 81 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/PulsarSinkBuilder.java x: 3 # contributors y: 235 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/PulsarSource.java x: 2 # contributors y: 113 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/utils/PulsarTransactionUtils.java x: 1 # contributors y: 36 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/config/SinkConfiguration.java x: 1 # contributors y: 108 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor/StopCursor.java x: 3 # contributors y: 78 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/split/PulsarPartitionSplit.java x: 1 # contributors y: 77 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/config/SourceConfiguration.java x: 2 # contributors y: 158 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/PulsarSchemaFactory.java x: 1 # contributors y: 18 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/factories/ProtobufNativeSchemaFactory.java x: 1 # contributors y: 20 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/factories/StringSchemaFactory.java x: 1 # contributors y: 14 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor/StartCursor.java x: 3 # contributors y: 30 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/PulsarSourceReader.java x: 2 # contributors y: 225 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/deserializer/GenericRecordDeserializationSchema.java x: 1 # contributors y: 54 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/deserializer/GenericRecordDeserializer.java x: 1 # contributors y: 10 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/deserializer/PulsarDeserializationSchemaInitializationContext.java x: 1 # contributors y: 30 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/deserializer/PulsarTypeInformationWrapper.java x: 1 # contributors y: 33 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/context/PulsarSinkContextImpl.java x: 1 # contributors y: 47 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/message/PulsarMessageBuilder.java x: 1 # contributors y: 72 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/router/TopicRouter.java x: 1 # contributors y: 17 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/PulsarSourceEnumStateSerializer.java x: 1 # contributors y: 69 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/split/PulsarPartitionSplitSerializer.java x: 1 # contributors y: 123 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/PulsarSchemaUtils.java x: 1 # contributors y: 152 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/serializer/PulsarSchemaWrapper.java x: 2 # contributors y: 34 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/BytesSchema.java x: 1 # contributors y: 45 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/PulsarSchemaTypeSerializer.java x: 2 # contributors y: 148 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/factories/KeyValueSchemaFactory.java x: 2 # contributors y: 45 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/deserializer/PulsarSchemaWrapper.java x: 2 # contributors y: 43 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor/CursorPosition.java x: 1 # contributors y: 84 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor/start/MessageIdStartCursor.java x: 3 # contributors y: 18 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic/range/TopicRangeUtils.java x: 1 # contributors y: 65 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/metrics/MetricNames.java x: 1 # contributors y: 39 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/router/MessageKeyHash.java x: 2 # contributors y: 51 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/config/CursorVerification.java x: 2 # contributors y: 20 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/utils/PulsarSerdeUtils.java x: 1 # contributors y: 112 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor/start/TimestampStartCursor.java x: 2 # contributors y: 14 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor/stop/EventTimestampStopCursor.java x: 2 # contributors y: 17 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic/TopicMetadata.java x: 1 # contributors y: 23 lines of code
552.0
lines of code
  min: 9.0
  average: 79.94
  25th percentile: 26.5
  median: 47.0
  75th percentile: 98.5
  max: 552.0
0 4.0
# contributors
min: 1.0 | average: 1.52 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 4.0