apache / flink-connector-pulsar
File Size

The distribution of size of files (measured in lines of code).

Intro
Learn more...
File Size Overall
0% | 13% | 23% | 23% | 39%
Legend:
1001+
501-1000
201-500
101-200
1-100


explore: grouped by folders | grouped by size | sunburst | 3D view
File Size per Extension
1001+
501-1000
201-500
101-200
1-100
java0% | 13% | 23% | 23% | 39%
xml0% | 0% | 0% | 0% | 100%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
flink-connector-pulsar0% | 13% | 23% | 23% | 39%
tools0% | 0% | 0% | 0% | 100%
Longest Files (Top 50)
File# lines# units
PulsarOptions.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/config
 552 1
PulsarSourceOptions.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source
 519 1
PulsarSourceBuilder.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source
 284 32
PulsarPartitionSplitReader.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader
 269 9
ProducerRegister.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/topic
 260 12
PulsarSinkBuilder.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink
 235 23
PulsarClientFactory.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/config
 231 5
PulsarSourceReader.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader
 225 12
PulsarSinkOptions.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink
 221 1
PulsarSourceEnumerator.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator
 202 11
PulsarWriter.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer
 184 7
MetadataListener.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/topic
 165 10
SourceConfiguration.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/config
 158 19
PulsarSchemaUtils.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema
 152 11
PulsarSchema.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema
 152 12
PulsarSchemaTypeSerializer.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema
 148 21
PulsarSourceConfigUtils.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/config
 133 3
PulsarCommitter.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/committer
 126 4
PulsarPartitionSplitSerializer.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/split
 123 7
PulsarSource.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source
 113 8
PulsarSerdeUtils.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/utils
 112 10
SinkConfiguration.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/config
 108 12
SplitAssignerImpl.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/assigner
 107 8
TopicPartition.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic
 103 13
PulsarSourceFetcherManager.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader
 99 7
PulsarAdminInvocationHandler.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/handler
 98 6
FixedKeysRangeGenerator.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic/range
 87 10
PulsarMessage.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/message
 87 11
TopicPatternSubscriber.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/subscriber/impl
 85 5
CursorPosition.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor
 84 6
PulsarSink.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink
 81 4
PulsarSinkConfigUtils.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/config
 79 2
StopCursor.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor
 78 12
PulsarConfigBuilder.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/config
 78 7
PulsarPartitionSplit.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/split
 77 11
PulsarMessageBuilder.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/message
 72 9
TopicNameUtils.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic
 71 7
PulsarSourceEnumStateSerializer.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator
 69 3
DefaultPulsarCrypto.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/crypto
 69 7
TopicRangeUtils.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic/range
 65 6
BasePulsarSubscriber.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/subscriber/impl
 63 3
PulsarSchemaTypeInformation.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema
 63 12
PulsarConsumerBuilder.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/config
 58 1
PulsarConfigValidator.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/config
 58 6
TopicRange.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic
 55 8
PrimitiveSchemaFactory.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/factories
 55 5
GenericRecordDeserializationSchema.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/deserializer
 54 5
PulsarConfiguration.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/config
 54 5
MessageKeyHash.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/router
 51 4
PulsarRecordEmitter.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader
 47 6
Files With Most Units (Top 50)
File# lines# units
PulsarSourceBuilder.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source
 284 32
PulsarSinkBuilder.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink
 235 23
PulsarSchemaTypeSerializer.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema
 148 21
SourceConfiguration.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/config
 158 19
TopicPartition.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic
 103 13
PulsarSourceReader.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader
 225 12
StopCursor.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor
 78 12
SinkConfiguration.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/config
 108 12
ProducerRegister.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/topic
 260 12
PulsarSchemaTypeInformation.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema
 63 12
PulsarSchema.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema
 152 12
PulsarPartitionSplit.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/split
 77 11
PulsarSourceEnumerator.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator
 202 11
PulsarMessage.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/message
 87 11
PulsarSchemaUtils.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema
 152 11
FixedKeysRangeGenerator.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic/range
 87 10
MetadataListener.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/topic
 165 10
PulsarSerdeUtils.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/utils
 112 10
PulsarPartitionSplitReader.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader
 269 9
PulsarMessageBuilder.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/message
 72 9
PulsarSource.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source
 113 8
TopicRange.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic
 55 8
SplitAssignerImpl.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/assigner
 107 8
PulsarSchemaWrapper.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/deserializer
 43 7
PulsarSourceFetcherManager.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader
 99 7
PulsarPartitionSplitState.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/split
 37 7
PulsarPartitionSplitSerializer.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/split
 123 7
TopicNameUtils.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic
 71 7
PulsarWriter.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer
 184 7
DefaultPulsarCrypto.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/crypto
 69 7
PulsarConfigBuilder.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/config
 78 7
PulsarRecordEmitter.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader
 47 6
StartCursor.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor
 30 6
CursorPosition.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor
 84 6
TopicRangeUtils.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic/range
 65 6
PulsarSinkContextImpl.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/context
 47 6
PulsarCommittable.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/committer
 38 6
PulsarAdminInvocationHandler.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/handler
 98 6
PulsarConfigValidator.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/config
 58 6
GenericRecordDeserializationSchema.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/deserializer
 54 5
TopicPatternSubscriber.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/subscriber/impl
 85 5
PulsarSchemaWrapper.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/serializer
 34 5
ProducerMetricsInterceptor.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/metrics
 38 5
PulsarConfiguration.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/config
 54 5
PulsarClientFactory.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/config
 231 5
PrimitiveSchemaFactory.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema/factories
 55 5
BytesSchema.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/schema
 45 5
PulsarDeserializationSchemaInitializationContext.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/deserializer
 30 4
PulsarDeserializationSchemaWrapper.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/deserializer
 30 4
TopicMetadata.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/topic
 23 4
Files With Long Lines (Top 13)

There are 13 files with lines longer than 120 characters. In total, there are 135 long lines.

File# lines# units# long lines
PulsarSourceOptions.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source
 519 1 62
PulsarOptions.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/config
 552 1 38
PulsarSinkOptions.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink
 221 1 14
PulsarSinkBuilder.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink
 235 23 5
PulsarSourceConfigUtils.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/config
 133 3 4
TopicRoutingMode.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/writer/router
 44 2 3
PulsarSourceBuilder.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source
 284 32 2
PulsarCommitter.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/committer
 126 4 2
PulsarDeserializationSchemaInitializationContext.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/reader/deserializer
 30 4 1
SourceConfiguration.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/config
 158 19 1
PulsarSinkConfigUtils.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/sink/config
 79 2 1
PulsarConfigValidator.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/config
 58 6 1
PulsarClientFactory.java
in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/common/config
 231 5 1
Correlations

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

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

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

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

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

flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/config/PulsarSourceConfigUtils.java x: 1 commits (30d) y: 133 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor/stop/MessageIdStopCursor.java x: 1 commits (30d) y: 23 lines of code
133.0
lines of code
  min: 23.0
  average: 78.0
  25th percentile: 23.0
  median: 78.0
  75th percentile: 133.0
  max: 133.0
0 1.0
commits (30d)
min: 1.0 | average: 1.0 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 1.0

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

flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/config/PulsarSourceConfigUtils.java x: 1 contributors (30d) y: 133 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor/stop/MessageIdStopCursor.java x: 1 contributors (30d) y: 23 lines of code
133.0
lines of code
  min: 23.0
  average: 78.0
  25th percentile: 23.0
  median: 78.0
  75th percentile: 133.0
  max: 133.0
0 1.0
contributors (30d)
min: 1.0 | average: 1.0 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 1.0

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

flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/config/PulsarSourceConfigUtils.java x: 1 commits (90d) y: 133 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor/stop/MessageIdStopCursor.java x: 1 commits (90d) y: 23 lines of code
133.0
lines of code
  min: 23.0
  average: 78.0
  25th percentile: 23.0
  median: 78.0
  75th percentile: 133.0
  max: 133.0
0 1.0
commits (90d)
min: 1.0 | average: 1.0 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 1.0

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

flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/config/PulsarSourceConfigUtils.java x: 1 contributors (90d) y: 133 lines of code flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/enumerator/cursor/stop/MessageIdStopCursor.java x: 1 contributors (90d) y: 23 lines of code
133.0
lines of code
  min: 23.0
  average: 78.0
  25th percentile: 23.0
  median: 78.0
  75th percentile: 133.0
  max: 133.0
0 1.0
contributors (90d)
min: 1.0 | average: 1.0 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 1.0