apache / pulsar
File Size

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

Intro
Learn more...
File Size Overall
27% | 14% | 25% | 13% | 19%
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
java27% | 14% | 25% | 12% | 19%
go61% | 12% | 10% | 12% | 4%
xml28% | 15% | 12% | 19% | 24%
proto0% | 51% | 12% | 13% | 22%
py0% | 0% | 36% | 30% | 33%
yaml0% | 0% | 0% | 44% | 55%
tf0% | 0% | 0% | 0% | 100%
lua0% | 0% | 0% | 0% | 100%
tfvars0% | 0% | 0% | 0% | 100%
rdf0% | 0% | 0% | 0% | 100%
cfg0% | 0% | 0% | 0% | 100%
js0% | 0% | 0% | 0% | 100%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
pulsar-broker40% | 16% | 18% | 11% | 13%
pulsar-client33% | 7% | 25% | 10% | 22%
managed-ledger54% | 0% | 17% | 14% | 13%
pulsar-client-tools49% | 15% | 17% | 9% | 8%
pulsar-client-admin52% | 6% | 28% | 4% | 7%
pulsar-broker-common32% | 12% | 15% | 19% | 20%
pulsar-function-go60% | 12% | 10% | 12% | 4%
pulsar-common7% | 16% | 32% | 18% | 25%
pulsar-functions4% | 33% | 29% | 15% | 17%
pulsar-metadata12% | 20% | 38% | 15% | 13%
testmocks42% | 0% | 48% | 4% | 4%
pulsar-testclient0% | 38% | 40% | 4% | 16%
pulsar-proxy0% | 31% | 46% | 10% | 11%
pulsar-client-admin-api0% | 12% | 11% | 7% | 68%
tiered-storage0% | 15% | 56% | 11% | 17%
pulsar-transaction0% | 21% | 31% | 11% | 34%
pulsar-client-api0% | 14% | 0% | 10% | 74%
pulsar-io0% | 0% | 37% | 19% | 42%
pulsar-websocket0% | 0% | 63% | 9% | 27%
src0% | 0% | 60% | 24% | 15%
pulsar-client-messagecrypto-bc0% | 0% | 99% | 0% | <1%
pulsar-broker-auth-oidc0% | 0% | 40% | 38% | 21%
pulsar-config-validation0% | 0% | 52% | 0% | 47%
pulsar-client-auth-sasl0% | 0% | 62% | 26% | 10%
pulsar-broker-auth-sasl0% | 0% | 42% | 40% | 17%
pulsar-package-management0% | 0% | 23% | 43% | 32%
pulsar-client-auth-athenz0% | 0% | 86% | 0% | 13%
structured-event-log0% | 0% | 37% | 30% | 31%
conf0% | 0% | 0% | 85% | 14%
deployment0% | 0% | 0% | 33% | 66%
pulsar-opentelemetry0% | 0% | 0% | 57% | 42%
pulsar-broker-auth-athenz0% | 0% | 0% | 99% | <1%
distribution0% | 0% | 0% | 39% | 60%
docker0% | 0% | 0% | 0% | 100%
pulsar-cli-utils0% | 0% | 0% | 0% | 100%
microbench0% | 0% | 0% | 0% | 100%
buildtools0% | 0% | 0% | 0% | 100%
pulsar-client-tools-api0% | 0% | 0% | 0% | 100%
bouncy-castle0% | 0% | 0% | 0% | 100%
wireshark0% | 0% | 0% | 0% | 100%
jclouds-shaded0% | 0% | 0% | 0% | 100%
ROOT0% | 0% | 0% | 0% | 100%
Longest Files (Top 50)
File# lines# units
PersistentTopicsBase.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl
4990 160
PersistentTopics.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2
4831 143
ManagedLedgerImpl.java
in managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl
3837 218
PersistentTopic.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent
3740 188
ServiceConfiguration.java
in pulsar-broker-common/src/main/java/org/apache/pulsar/broker
3475 24
ServerCnx.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/service
3241 128
ManagedCursorImpl.java
in managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl
3144 166
BrokerService.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/service
3094 156
Namespaces.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2
2968 149
ConsumerImpl.java
in pulsar-client/src/main/java/org/apache/pulsar/client/impl
2716 123
NamespacesBase.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl
2569 121
CmdTopics.java
in pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli
2527 138
TopicsImpl.java
in pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal
2397 310
CmdNamespaces.java
in pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli
2346 144
ProducerImpl.java
in pulsar-client/src/main/java/org/apache/pulsar/client/impl
2134 122
Function.pb.go
in pulsar-function-go/pb
2010 209
PulsarService.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker
1759 96
Commands.java
in pulsar-common/src/main/java/org/apache/pulsar/common/protocol
1733 157
ServiceUnitStateChannelImpl.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/channel
1699 78
NamespacesImpl.java
in pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal
1689 308
Namespaces.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1
1651 81
CmdTopicPolicies.java
in pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli
1606 85
ComponentImpl.java
in pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api
1601 57
NamespaceService.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace
1456 68
MultiTopicsConsumerImpl.java
in pulsar-client/src/main/java/org/apache/pulsar/client/impl
1405 69
PersistentSubscription.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent
1302 79
ClientCnx.java
in pulsar-client/src/main/java/org/apache/pulsar/client/impl
1279 83
ManagedLedgerFactoryImpl.java
in managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl
1272 48
PulsarZooKeeperClient.java
in pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl
1253 68
CmdFunctions.java
in pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli
1176 47
AbstractTopic.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/service
1176 103
PersistentDispatcherMultipleConsumers.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent
1168 89
SimpleLoadManagerImpl.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl
1163 52
PulsarClientImpl.java
in pulsar-client/src/main/java/org/apache/pulsar/client/impl
1119 69
PulsarWebResource.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/web
1107 73
ConsumerBase.java
in pulsar-client/src/main/java/org/apache/pulsar/client/impl
1092 101
TopicPoliciesImpl.java
in pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal
1074 197
PersistentTopics.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1
1063 39
PersistentDispatcherMultipleConsumersClassic.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent
1050 75
MockZooKeeper.java
in testmocks/src/main/java/org/apache/zookeeper
1034 77
Consumer.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/service
1024 72
NonPersistentTopic.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent
1024 70
InstanceCommunication.pb.go
in pulsar-function-go/pb
1022 93
findbugsExclude.xml
in pulsar-client/src/main/resources
1006 -
ClustersBase.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl
997 23
KubernetesRuntime.java
in pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/kubernetes
984 37
FunctionConfigUtils.java
in pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils
977 16
JavaInstanceRunnable.java
in pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance
963 30
ExtensibleLoadManagerImpl.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions
953 39
PendingAckHandleImpl.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/pendingack/impl
942 42
Files With Most Units (Top 50)
File# lines# units
TopicsImpl.java
in pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal
2397 310
NamespacesImpl.java
in pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal
1689 308
ManagedLedgerImpl.java
in managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl
3837 218
Function.pb.go
in pulsar-function-go/pb
2010 209
TopicPoliciesImpl.java
in pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal
1074 197
PersistentTopic.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent
3740 188
ManagedCursorImpl.java
in managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl
3144 166
PersistentTopicsBase.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl
4990 160
Commands.java
in pulsar-common/src/main/java/org/apache/pulsar/common/protocol
1733 157
BrokerService.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/service
3094 156
Namespaces.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2
2968 149
CmdNamespaces.java
in pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli
2346 144
PersistentTopics.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2
4831 143
CmdTopics.java
in pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli
2527 138
ServerCnx.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/service
3241 128
ConsumerImpl.java
in pulsar-client/src/main/java/org/apache/pulsar/client/impl
2716 123
ProducerImpl.java
in pulsar-client/src/main/java/org/apache/pulsar/client/impl
2134 122
NamespacesBase.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl
2569 121
AbstractTopic.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/service
1176 103
ConsumerBase.java
in pulsar-client/src/main/java/org/apache/pulsar/client/impl
1092 101
PulsarService.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker
1759 96
InstanceCommunication.pb.go
in pulsar-function-go/pb
1022 93
PersistentDispatcherMultipleConsumers.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent
1168 89
CmdTopicPolicies.java
in pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli
1606 85
ManagedLedgerConfig.java
in managed-ledger/src/main/java/org/apache/bookkeeper/mledger
364 84
ClientCnx.java
in pulsar-client/src/main/java/org/apache/pulsar/client/impl
1279 83
Namespaces.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1
1651 81
PersistentSubscription.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent
1302 79
ServiceUnitStateChannelImpl.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/channel
1699 78
LoadReport.java
in pulsar-common/src/main/java/org/apache/pulsar/policies/data/loadbalancer
380 77
MockZooKeeper.java
in testmocks/src/main/java/org/apache/zookeeper
1034 77
ProtectedObjectMapper.java
in pulsar-common/src/main/java/org/apache/pulsar/common/util
349 76
ContextImpl.java
in pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance
627 75
Producer.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/service
740 75
PersistentDispatcherMultipleConsumersClassic.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent
1050 75
PulsarWebResource.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/web
1107 73
LocalBrokerData.java
in pulsar-common/src/main/java/org/apache/pulsar/policies/data/loadbalancer
384 72
Consumer.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/service
1024 72
PulsarClientException.java
in pulsar-client-api/src/main/java/org/apache/pulsar/client/api
506 72
NonPersistentTopic.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent
1024 70
PulsarClientImpl.java
in pulsar-client/src/main/java/org/apache/pulsar/client/impl
1119 69
MultiTopicsConsumerImpl.java
in pulsar-client/src/main/java/org/apache/pulsar/client/impl
1405 69
MessageImpl.java
in pulsar-client/src/main/java/org/apache/pulsar/client/impl
673 68
PulsarZooKeeperClient.java
in pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl
1253 68
NamespaceService.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace
1456 68
AdminResource.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/admin
837 67
FunctionsImpl.java
in pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal
644 64
ConsumerBuilderImpl.java
in pulsar-client/src/main/java/org/apache/pulsar/client/impl
539 64
PulsarDecoder.java
in pulsar-common/src/main/java/org/apache/pulsar/common/protocol
587 63
ManagedLedgerMBeanImpl.java
in managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl
299 61
Files With Long Lines (Top 49)

There are 49 files with lines longer than 120 characters. In total, there are 266 long lines.

File# lines# units# long lines
Function.pb.go
in pulsar-function-go/pb
2010 209 58
InstanceCommunication.pb.go
in pulsar-function-go/pb
1022 93 33
python_instance.py
in pulsar-functions/instance/src/main/python
482 22 25
ElasticSearchConfig.java
in pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch
326 3 17
io.xml
in distribution/io/src/assemble
59 - 16
Message.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/fbs
44 2 11
python_instance_main.py
in pulsar-functions/instance/src/main/python
233 5 10
function_stats.py
in pulsar-functions/instance/src/main/python
150 24 10
EncryptionCtx.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/fbs
59 2 8
EncryptionKey.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/fbs
43 2 7
KinesisSinkConfig.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis
111 1 6
JwksCache.java
in pulsar-broker-auth-oidc/src/main/java/org/apache/pulsar/broker/authentication/oidc
189 9 5
Request.pb.go
in pulsar-function-go/pb
204 18 4
OpenIDProviderMetadataCache.java
in pulsar-broker-auth-oidc/src/main/java/org/apache/pulsar/broker/authentication/oidc
155 5 4
bin.xml
in distribution/server/src/assemble
105 - 3
deploy-pulsar.yaml
in deployment/terraform-ansible
163 - 3
ServiceUnitStateChannelImpl.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/channel
1699 78 3
108 - 2
110 - 2
function.go
in pulsar-function-go/pf
107 8 2
instance.go
in pulsar-function-go/pf
622 38 2
JCloudBlobStoreProvider.java
in tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/provider
349 24 2
29 - 2
MLTransactionLogImpl.java
in pulsar-transaction/coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/impl
333 19 2
findbugsExclude.xml
in pulsar-functions/secrets/src/main/resources
12 - 2
java_instance_log4j2.xml
in pulsar-functions/runtime-all/src/main/resources
110 - 2
contextimpl.py
in pulsar-functions/instance/src/main/python
179 36 2
MLPendingAckStore.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/pendingack/impl
440 25 2
PerformanceProducer.java
in pulsar-testclient/src/main/java/org/apache/pulsar/testclient
659 9 1
offloaders.xml
in distribution/offloaders/src/assemble
32 - 1
429 - 1
171 - 1
PulsarVersion.java
in pulsar-common/src/main/java-templates/org/apache/pulsar
58 7 1
conf.yaml
in pulsar-function-go/conf
34 - 1
BinaryProtoLookupService.java
in pulsar-client/src/main/java/org/apache/pulsar/client/impl
410 15 1
PartitionedProducerImpl.java
in pulsar-client/src/main/java/org/apache/pulsar/client/impl
422 22 1
variables.tf
in deployment/terraform-ansible/aws
40 - 1
ElasticSearchClient.java
in pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch
282 19 1
KafkaConnectData.java
in pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/schema
333 8 1
KinesisSink.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis
252 11 1
KeyValue.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/fbs
32 2 1
typed_message_builder_publish.py
in pulsar-functions/python-examples
14 2 1
log.py
in pulsar-functions/instance/src/main/python
72 7 1
BookKeeperClientFactoryImpl.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker
203 6 1
PulsarService.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker
1759 96 1
ServiceUnitStateTableViewSyncer.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/channel
219 12 1
NamespaceService.java
in pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace
1456 68 1
update-rocksdb-conf-from-env.py
in docker/pulsar/scripts
48 1 1
apply-config-from-env.py
in docker/pulsar/scripts
56 1 1
Correlations

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

pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractTopic.java x: 157 commits (all time) y: 1176 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/PolicyHierarchyValue.java x: 5 commits (all time) y: 54 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedCursorImpl.java x: 224 commits (all time) y: 3144 lines of code pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/AbstractKafkaConnectSource.java x: 16 commits (all time) y: 260 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/GeoReplicationProducerImpl.java x: 2 commits (all time) y: 189 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/HandlerState.java x: 9 commits (all time) y: 70 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java x: 193 commits (all time) y: 2134 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarClientImplementationBindingImpl.java x: 9 commits (all time) y: 267 lines of code pulsar-common/src/main/java/org/apache/pulsar/client/impl/schema/SchemaInfoImpl.java x: 5 commits (all time) y: 70 lines of code pulsar-common/src/main/java/org/apache/pulsar/client/impl/schema/SchemaUtils.java x: 11 commits (all time) y: 272 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java x: 429 commits (all time) y: 3094 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/metrics/ObserverGauge.java x: 5 commits (all time) y: 79 lines of code pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java x: 438 commits (all time) y: 3475 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/TopicPolicies.java x: 38 commits (all time) y: 143 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/stats/NonPersistentTopicStatsImpl.java x: 9 commits (all time) y: 142 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/AckSetState.java x: 3 commits (all time) y: 9 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java x: 298 commits (all time) y: 3837 lines of code pulsar-broker-auth-oidc/src/main/java/org/apache/pulsar/broker/authentication/oidc/OpenIDProviderMetadataCache.java x: 4 commits (all time) y: 155 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/NamespacesBase.java x: 239 commits (all time) y: 2569 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java x: 422 commits (all time) y: 4990 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v3/Transactions.java x: 25 commits (all time) y: 452 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/bucket/BookkeeperBucketSnapshotStorage.java x: 11 commits (all time) y: 244 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace/NamespaceEphemeralData.java x: 9 commits (all time) y: 42 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace/NamespaceService.java x: 160 commits (all time) y: 1456 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractBaseDispatcher.java x: 70 commits (all time) y: 403 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ConsumerHashAssignmentsSnapshot.java x: 3 commits (all time) y: 161 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/SystemTopicBasedTopicPoliciesService.java x: 64 commits (all time) y: 641 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentMessageExpiryMonitor.java x: 29 commits (all time) y: 223 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java x: 522 commits (all time) y: 3740 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/SystemTopic.java x: 21 commits (all time) y: 81 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/BookkeeperSchemaStorage.java x: 48 commits (all time) y: 654 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/BookkeeperSchemaStorageFactory.java x: 7 commits (all time) y: 12 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/SchemaRegistryServiceImpl.java x: 48 commits (all time) y: 603 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/SchemaStorageFactory.java x: 6 commits (all time) y: 8 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/web/PulsarWebResource.java x: 114 commits (all time) y: 1107 lines of code pulsar-broker/src/main/java/org/apache/pulsar/compaction/CompactedTopicImpl.java x: 44 commits (all time) y: 338 lines of code pulsar-broker/src/main/java/org/apache/pulsar/compaction/PulsarCompactionServiceFactory.java x: 4 commits (all time) y: 58 lines of code pulsar-broker/src/main/java/org/apache/pulsar/compaction/PulsarTopicCompactionService.java x: 7 commits (all time) y: 102 lines of code pulsar-broker/src/main/java/org/apache/pulsar/compaction/TopicCompactionService.java x: 4 commits (all time) y: 18 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ControlledClusterFailover.java x: 10 commits (all time) y: 210 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicsConsumerImpl.java x: 158 commits (all time) y: 1405 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/PersistentAcknowledgmentsGroupingTracker.java x: 43 commits (all time) y: 596 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarClientImpl.java x: 154 commits (all time) y: 1119 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/util/FutureUtil.java x: 25 commits (all time) y: 236 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/util/URIPreconditions.java x: 3 commits (all time) y: 41 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/util/collections/GrowableArrayBlockingQueue.java x: 9 commits (all time) y: 364 lines of code pulsar-io/azure-data-explorer/src/main/java/org/apache/pulsar/io/azuredataexplorer/ADXSink.java x: 2 commits (all time) y: 246 lines of code pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/KafkaConnectSource.java x: 18 commits (all time) y: 249 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/TransactionMetaStoreHandler.java x: 33 commits (all time) y: 736 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/rest/TopicsBase.java x: 15 commits (all time) y: 699 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/ManagedLedger.java x: 47 commits (all time) y: 123 lines of code managed-ledger/src/main/proto/MLDataFormats.proto x: 20 commits (all time) y: 134 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentMessageFinder.java x: 13 commits (all time) y: 124 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/HealthChecker.java x: 2 commits (all time) y: 257 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/TenantsBase.java x: 35 commits (all time) y: 317 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/AdminResource.java x: 168 commits (all time) y: 837 lines of code pulsar-client-admin-api/src/main/java/org/apache/pulsar/common/policies/data/BacklogQuota.java x: 7 commits (all time) y: 32 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/channel/ServiceUnitStateChannelImpl.java x: 60 commits (all time) y: 1699 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java x: 321 commits (all time) y: 1759 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/BrokersBase.java x: 64 commits (all time) y: 478 lines of code pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ConsumerBuilder.java x: 56 commits (all time) y: 77 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/conf/ConsumerConfigurationData.java x: 54 commits (all time) y: 377 lines of code pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/PulsarOffsetBackingStore.java x: 13 commits (all time) y: 223 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/OffloadPoliciesImpl.java x: 16 commits (all time) y: 539 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/util/Backoff.java x: 3 commits (all time) y: 88 lines of code pulsar-metadata/src/main/java/org/apache/pulsar/metadata/api/MetadataCacheConfig.java x: 5 commits (all time) y: 30 lines of code pulsar-metadata/src/main/java/org/apache/pulsar/metadata/tableview/impl/MetadataStoreTableViewImpl.java x: 2 commits (all time) y: 283 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/validator/StructSchemaDataValidator.java x: 6 commits (all time) y: 65 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/generic/GenericSchemaImpl.java x: 11 commits (all time) y: 44 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ClientCnx.java x: 132 commits (all time) y: 1279 lines of code pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/LookupProxyHandler.java x: 36 commits (all time) y: 379 lines of code pulsar-broker-common/src/main/java/org/apache/pulsar/bookie/rackawareness/IsolatedBookieEnsemblePlacementPolicy.java x: 16 commits (all time) y: 240 lines of code pulsar-client-admin-api/src/main/java/org/apache/pulsar/common/functions/ConsumerConfig.java x: 4 commits (all time) y: 29 lines of code pulsar-client-admin-api/src/main/java/org/apache/pulsar/common/functions/MessagePayloadProcessorConfig.java x: 1 commits (all time) y: 16 lines of code pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/JavaInstanceRunnable.java x: 156 commits (all time) y: 963 lines of code pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/PulsarSource.java x: 59 commits (all time) y: 164 lines of code pulsar-functions/proto/src/main/proto/Function.proto x: 63 commits (all time) y: 227 lines of code pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/FunctionConfigUtils.java x: 78 commits (all time) y: 977 lines of code pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/MessagePayloadProcessorUtils.java x: 1 commits (all time) y: 65 lines of code pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/SinkConfigUtils.java x: 63 commits (all time) y: 674 lines of code pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/ValidatorUtils.java x: 13 commits (all time) y: 155 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Consumer.java x: 140 commits (all time) y: 1024 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Producer.java x: 86 commits (all time) y: 740 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerImpl.java x: 308 commits (all time) y: 2716 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/naming/Metadata.java x: 6 commits (all time) y: 21 lines of code testmocks/src/main/java/org/apache/zookeeper/MockZooKeeper.java x: 24 commits (all time) y: 1034 lines of code testmocks/src/main/java/org/apache/zookeeper/MockZooKeeperSession.java x: 8 commits (all time) y: 334 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/scheduler/TransferShedder.java x: 15 commits (all time) y: 665 lines of code pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ProducerBuilder.java x: 27 commits (all time) y: 52 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerBuilderImpl.java x: 37 commits (all time) y: 299 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/protocol/Commands.java x: 98 commits (all time) y: 1733 lines of code pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/DirectProxyHandler.java x: 51 commits (all time) y: 418 lines of code pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyClientCnx.java x: 15 commits (all time) y: 69 lines of code pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyConnection.java x: 67 commits (all time) y: 693 lines of code pulsar-client-api/src/main/java/org/apache/pulsar/client/api/PulsarClientException.java x: 33 commits (all time) y: 506 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentSubscription.java x: 60 commits (all time) y: 441 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumers.java x: 167 commits (all time) y: 1168 lines of code pulsar-function-go/pf/instance.go x: 30 commits (all time) y: 622 lines of code pulsar-function-go/pf/context.go x: 11 commits (all time) y: 129 lines of code pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/Utils.java x: 12 commits (all time) y: 217 lines of code pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/json/JsonConverter.java x: 4 commits (all time) y: 194 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/EntryCountEstimator.java x: 3 commits (all time) y: 103 lines of code pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/KafkaConnectSink.java x: 21 commits (all time) y: 435 lines of code pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaAbstractSink.java x: 15 commits (all time) y: 95 lines of code pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaBytesSource.java x: 11 commits (all time) y: 178 lines of code pulsar-broker/src/main/java/org/apache/pulsar/PulsarClusterMetadataTeardown.java x: 16 commits (all time) y: 228 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/oauth2/ClientCredentialsFlow.java x: 9 commits (all time) y: 113 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/PatternMultiTopicsConsumerImpl.java x: 24 commits (all time) y: 323 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Dispatcher.java x: 33 commits (all time) y: 99 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentSubscription.java x: 182 commits (all time) y: 1302 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/AggregatedNamespaceStats.java x: 32 commits (all time) y: 188 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/AggregatedSubscriptionStats.java x: 16 commits (all time) y: 41 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/NamespaceStatsAggregator.java x: 68 commits (all time) y: 510 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/TopicStats.java x: 51 commits (all time) y: 519 lines of code pulsar-client-admin-api/src/main/java/org/apache/pulsar/common/policies/data/SubscriptionStats.java x: 18 commits (all time) y: 52 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/stats/SubscriptionStatsImpl.java x: 27 commits (all time) y: 178 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerBuilderImpl.java x: 81 commits (all time) y: 539 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentReplicator.java x: 71 commits (all time) y: 575 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/MessageDeduplication.java x: 44 commits (all time) y: 558 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PulsarMetadataEventSynchronizer.java x: 6 commits (all time) y: 281 lines of code pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/AbstractMetadataStore.java x: 40 commits (all time) y: 494 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace/OwnedBundle.java x: 17 commits (all time) y: 89 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentTopic.java x: 185 commits (all time) y: 1024 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/BatchMessageContainerBase.java x: 8 commits (all time) y: 16 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/BatchMessageContainerImpl.java x: 37 commits (all time) y: 294 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/BatchMessageKeyBasedContainer.java x: 16 commits (all time) y: 98 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerMBeanImpl.java x: 20 commits (all time) y: 299 lines of code pulsar-broker/src/main/java/org/apache/pulsar/compaction/CompactionRecord.java x: 6 commits (all time) y: 95 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java x: 356 commits (all time) y: 3241 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/TopicListService.java x: 9 commits (all time) y: 202 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/ThresholdShedder.java x: 23 commits (all time) y: 189 lines of code pulsar-client-admin-api/src/main/java/org/apache/pulsar/common/functions/BatchingConfig.java x: 1 commits (all time) y: 21 lines of code pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ProducerBuilderFactory.java x: 2 commits (all time) y: 146 lines of code pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/BatchingUtils.java x: 1 commits (all time) y: 57 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/api/raw/RawMessageImpl.java x: 14 commits (all time) y: 177 lines of code pulsar-client-api/src/main/java/org/apache/pulsar/client/api/DeadLetterPolicy.java x: 10 commits (all time) y: 23 lines of code pulsar-broker-common/src/main/java/org/apache/pulsar/broker/stats/prometheus/PrometheusMetricsServlet.java x: 7 commits (all time) y: 146 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/PulsarPrometheusMetricsServlet.java x: 6 commits (all time) y: 153 lines of code pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/FunctionsMetricsResource.java x: 8 commits (all time) y: 66 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/TypedMessageBuilderImpl.java x: 36 commits (all time) y: 262 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/InMemoryDelayedDeliveryTracker.java x: 23 commits (all time) y: 171 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/GeoPersistentReplicator.java x: 12 commits (all time) y: 182 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/ShadowReplicator.java x: 9 commits (all time) y: 89 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/LedgerOffloaderFactory.java x: 10 commits (all time) y: 57 lines of code tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/impl/BlobStoreManagedLedgerOffloader.java x: 31 commits (all time) y: 636 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/qos/AsyncTokenBucket.java x: 3 commits (all time) y: 122 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/qos/DynamicRateAsyncTokenBucketBuilder.java x: 3 commits (all time) y: 39 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/resourcegroup/ResourceGroup.java x: 16 commits (all time) y: 499 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PublishRateLimiterImpl.java x: 9 commits (all time) y: 126 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentDispatcherMultipleConsumers.java x: 37 commits (all time) y: 187 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentDispatcherSingleActiveConsumer.java x: 31 commits (all time) y: 82 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/DispatchRateLimiter.java x: 45 commits (all time) y: 122 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/DispatchRateLimiterAsyncTokenBucketImpl.java x: 1 commits (all time) y: 122 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumersClassic.java x: 4 commits (all time) y: 1050 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherSingleActiveConsumer.java x: 100 commits (all time) y: 501 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/SubscribeRateLimiter.java x: 20 commits (all time) y: 151 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/util/RateLimiter.java x: 19 commits (all time) y: 164 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdPersistentTopics.java x: 45 commits (all time) y: 559 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdTopics.java x: 173 commits (all time) y: 2527 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/bucket/BucketDelayedDeliveryTracker.java x: 27 commits (all time) y: 629 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractReplicator.java x: 36 commits (all time) y: 397 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Topic.java x: 98 commits (all time) y: 181 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/conf/ProducerConfigurationData.java x: 33 commits (all time) y: 220 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/protocol/Markers.java x: 15 commits (all time) y: 225 lines of code pulsar-common/src/main/proto/PulsarApi.proto x: 122 commits (all time) y: 928 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerBase.java x: 114 commits (all time) y: 1092 lines of code pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/ZKMetadataStore.java x: 34 commits (all time) y: 565 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/LoadManagerShared.java x: 41 commits (all time) y: 593 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/ModularLoadManagerImpl.java x: 113 commits (all time) y: 902 lines of code pulsar-broker/src/main/java/org/apache/pulsar/common/naming/NamespaceBundles.java x: 16 commits (all time) y: 155 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ShadowManagedLedgerImpl.java x: 13 commits (all time) y: 321 lines of code pulsar-broker/src/main/java/org/apache/pulsar/client/impl/RawBatchMessageContainerImpl.java x: 5 commits (all time) y: 131 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/MessageImpl.java x: 78 commits (all time) y: 673 lines of code pulsar-metadata/src/main/java/org/apache/pulsar/metadata/bookkeeper/PulsarRegistrationClient.java x: 11 commits (all time) y: 281 lines of code pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyConfiguration.java x: 82 commits (all time) y: 879 lines of code pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/WebServer.java x: 38 commits (all time) y: 373 lines of code pulsar-broker-auth-sasl/src/main/java/org/apache/pulsar/broker/authentication/AuthenticationProviderSasl.java x: 17 commits (all time) y: 254 lines of code pulsar-client-api/src/main/java/org/apache/pulsar/client/api/TypedMessageBuilder.java x: 9 commits (all time) y: 35 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentStickyKeyDispatcherMultipleConsumers.java x: 85 commits (all time) y: 527 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/util/RangeCache.java x: 20 commits (all time) y: 321 lines of code pulsar-client-auth-athenz/src/main/java/org/apache/pulsar/client/impl/auth/AuthenticationAthenz.java x: 22 commits (all time) y: 219 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerServiceException.java x: 32 commits (all time) y: 231 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/Namespaces.java x: 146 commits (all time) y: 2968 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/PersistentTopics.java x: 234 commits (all time) y: 4831 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/TopicTransactionBuffer.java x: 58 commits (all time) y: 662 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ClientBuilderImpl.java x: 42 commits (all time) y: 388 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/SameAuthParamsLookupAutoClusterFailover.java x: 2 commits (all time) y: 302 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/ManagedLedgerFactoryConfig.java x: 21 commits (all time) y: 37 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerFactoryImpl.java x: 79 commits (all time) y: 1272 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/ManagedLedgerClientFactory.java x: 36 commits (all time) y: 191 lines of code pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/JavaInstance.java x: 32 commits (all time) y: 175 lines of code pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/stats/ComponentStatsManager.java x: 16 commits (all time) y: 103 lines of code pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/stats/FunctionStatsManager.java x: 16 commits (all time) y: 351 lines of code pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/stats/SourceStatsManager.java x: 17 commits (all time) y: 267 lines of code pulsar-functions/instance/src/main/resources/findbugsExclude.xml x: 6 commits (all time) y: 543 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdFunctions.java x: 164 commits (all time) y: 1176 lines of code testmocks/src/main/java/org/apache/bookkeeper/client/PulsarMockBookKeeper.java x: 16 commits (all time) y: 395 lines of code testmocks/src/main/java/org/apache/bookkeeper/client/PulsarMockReadHandle.java x: 4 commits (all time) y: 102 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/ManagedLedgerConfig.java x: 55 commits (all time) y: 364 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/RangeSetWrapper.java x: 11 commits (all time) y: 154 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConnectionHandler.java x: 31 commits (all time) y: 201 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractDispatcherMultipleConsumers.java x: 20 commits (all time) y: 116 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/DrainingHashesTracker.java x: 3 commits (all time) y: 296 lines of code pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authentication/AuthenticationService.java x: 21 commits (all time) y: 187 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/ReplicatedSubscriptionsController.java x: 25 commits (all time) y: 264 lines of code pulsar-client/src/main/resources/findbugsExclude.xml x: 10 commits (all time) y: 1006 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/ManagedCursor.java x: 48 commits (all time) y: 162 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/OpAddEntry.java x: 50 commits (all time) y: 326 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/systopic/TransactionBufferSnapshotBaseSystemTopicClient.java x: 5 commits (all time) y: 169 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/SnapshotSegmentAbortedTxnProcessorImpl.java x: 13 commits (all time) y: 605 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/TableView.java x: 2 commits (all time) y: 70 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/systopic/TopicPoliciesSystemTopicClient.java x: 13 commits (all time) y: 174 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentStickyKeyDispatcherMultipleConsumersClassic.java x: 3 commits (all time) y: 469 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/NegativeAcksTracker.java x: 19 commits (all time) y: 147 lines of code pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/http/AsyncHttpConnector.java x: 34 commits (all time) y: 483 lines of code pulsar-client-api/src/main/java/org/apache/pulsar/client/api/Authentication.java x: 8 commits (all time) y: 36 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/CmdConsume.java x: 30 commits (all time) y: 251 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/CmdProduce.java x: 30 commits (all time) y: 476 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/CmdRead.java x: 6 commits (all time) y: 254 lines of code pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/AdminProxyHandler.java x: 27 commits (all time) y: 356 lines of code pulsar-testclient/src/main/java/org/apache/pulsar/proxy/socket/client/PerformanceClient.java x: 30 commits (all time) y: 366 lines of code pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authentication/AuthenticationProviderList.java x: 13 commits (all time) y: 301 lines of code pulsar-client-api/src/main/java/org/apache/pulsar/client/api/KeySharedPolicy.java x: 8 commits (all time) y: 81 lines of code pulsar-client-api/src/main/java/org/apache/pulsar/client/api/Range.java x: 10 commits (all time) y: 73 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/conf/ReaderConfigurationData.java x: 22 commits (all time) y: 152 lines of code pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisSink.java x: 28 commits (all time) y: 252 lines of code pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisSinkConfig.java x: 17 commits (all time) y: 111 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/LocalPolicies.java x: 12 commits (all time) y: 32 lines of code pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ProducerCache.java x: 2 commits (all time) y: 114 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/naming/TopicName.java x: 32 commits (all time) y: 276 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/OpReadEntry.java x: 33 commits (all time) y: 169 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/UniformLoadShedder.java x: 14 commits (all time) y: 151 lines of code pulsar-broker-common/src/main/java/org/apache/pulsar/broker/resources/BaseResources.java x: 16 commits (all time) y: 196 lines of code pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ClientBuilder.java x: 31 commits (all time) y: 76 lines of code pulsar-broker-auth-oidc/src/main/java/org/apache/pulsar/broker/authentication/oidc/AuthenticationProviderOpenID.java x: 8 commits (all time) y: 358 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/oauth2/protocol/TokenClient.java x: 10 commits (all time) y: 94 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerStatsRecorderImpl.java x: 19 commits (all time) y: 295 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdTopicPolicies.java x: 43 commits (all time) y: 1606 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/intercept/BrokerInterceptorWithClassLoader.java x: 14 commits (all time) y: 262 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/web/WebService.java x: 54 commits (all time) y: 409 lines of code pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authorization/AuthorizationProvider.java x: 35 commits (all time) y: 162 lines of code pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authorization/AuthorizationService.java x: 46 commits (all time) y: 636 lines of code pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authorization/PulsarAuthorizationProvider.java x: 67 commits (all time) y: 744 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/ClustersBase.java x: 42 commits (all time) y: 997 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/PolicyName.java x: 14 commits (all time) y: 37 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/PrometheusMetricsGenerator.java x: 41 commits (all time) y: 448 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/lookup/TopicLookupBase.java x: 33 commits (all time) y: 316 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace/OwnershipCache.java x: 37 commits (all time) y: 204 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/util/KeyManagerProxy.java x: 5 commits (all time) y: 115 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/InMemoryRedeliveryTracker.java x: 11 commits (all time) y: 86 lines of code pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authentication/AuthenticationDataSubscription.java x: 4 commits (all time) y: 60 lines of code pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/windowing/WindowContextImpl.java x: 8 commits (all time) y: 131 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/models/TopKBundles.java x: 6 commits (all time) y: 119 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractDispatcherSingleActiveConsumer.java x: 34 commits (all time) y: 236 lines of code tiered-storage/file-system/src/main/java/org/apache/bookkeeper/mledger/offload/filesystem/impl/FileSystemManagedLedgerOffloader.java x: 15 commits (all time) y: 354 lines of code testmocks/src/main/java/org/apache/bookkeeper/client/BookKeeperTestClient.java x: 6 commits (all time) y: 99 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConnectionPool.java x: 49 commits (all time) y: 394 lines of code pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyService.java x: 67 commits (all time) y: 458 lines of code pulsar-package-management/bookkeeper-storage/src/main/java/org/apache/pulsar/packages/management/storage/bookkeeper/DLOutputStream.java x: 6 commits (all time) y: 56 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdClusters.java x: 31 commits (all time) y: 386 lines of code pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ReaderBuilder.java x: 17 commits (all time) y: 39 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/ExtensibleLoadManagerImpl.java x: 60 commits (all time) y: 953 lines of code pulsar-broker/src/main/java/org/apache/pulsar/zookeeper/LocalBookkeeperEnsemble.java x: 7 commits (all time) y: 482 lines of code pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ConsumerStats.java x: 11 commits (all time) y: 33 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/BinaryProtoLookupService.java x: 43 commits (all time) y: 410 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ConsistentHashingStickyKeyConsumerSelector.java x: 17 commits (all time) y: 222 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/RemovedHashRanges.java x: 2 commits (all time) y: 49 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/systopic/NamespaceEventsSystemTopicFactory.java x: 8 commits (all time) y: 45 lines of code pulsar-broker/src/main/java/org/apache/pulsar/compaction/CompactorTool.java x: 34 commits (all time) y: 149 lines of code distribution/io/src/assemble/io.xml x: 32 commits (all time) y: 59 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/offload/OffloaderUtils.java x: 12 commits (all time) y: 114 lines of code pulsar-functions/localrun/src/main/java/org/apache/pulsar/functions/LocalRunner.java x: 44 commits (all time) y: 704 lines of code pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/io/ConnectorUtils.java x: 18 commits (all time) y: 135 lines of code pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/service/WorkerServiceLoader.java x: 8 commits (all time) y: 107 lines of code pulsar-client-admin-api/src/main/java/org/apache/pulsar/client/admin/Namespaces.java x: 34 commits (all time) y: 411 lines of code pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/NamespacesImpl.java x: 97 commits (all time) y: 1689 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/conf/ClientConfigurationData.java x: 58 commits (all time) y: 395 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/HashRangeAutoSplitStickyKeyConsumerSelector.java x: 17 commits (all time) y: 144 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/HashRangeExclusiveStickyKeyConsumerSelector.java x: 15 commits (all time) y: 142 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/StickyKeyConsumerSelector.java x: 15 commits (all time) y: 24 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PendingAcksMap.java x: 1 commits (all time) y: 249 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentStickyKeyDispatcherMultipleConsumers.java x: 24 commits (all time) y: 164 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/TransactionMetadataStoreService.java x: 49 commits (all time) y: 438 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/metrics/ManagedLedgerMetrics.java x: 14 commits (all time) y: 101 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/pendingack/impl/MLPendingAckStoreProvider.java x: 13 commits (all time) y: 202 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdNamespaces.java x: 136 commits (all time) y: 2346 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ReaderBuilderImpl.java x: 30 commits (all time) y: 226 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/SchemasResourceBase.java x: 22 commits (all time) y: 212 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1/SchemasResource.java x: 7 commits (all time) y: 360 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/SchemasResource.java x: 32 commits (all time) y: 326 lines of code pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/SchemasImpl.java x: 22 commits (all time) y: 310 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdSchemas.java x: 22 commits (all time) y: 165 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/util/collections/ConcurrentOpenLongPairRangeSet.java x: 20 commits (all time) y: 345 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/util/collections/LongPairRangeSet.java x: 13 commits (all time) y: 186 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/util/collections/OpenLongPairRangeSet.java x: 4 commits (all time) y: 347 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/TableViewImpl.java x: 22 commits (all time) y: 340 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/util/SecurityUtility.java x: 34 commits (all time) y: 466 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/store/TableViewLoadDataStoreImpl.java x: 9 commits (all time) y: 223 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/AbstractCmdConsume.java x: 4 commits (all time) y: 227 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerBase.java x: 28 commits (all time) y: 130 lines of code pulsar-websocket/src/main/java/org/apache/pulsar/websocket/WebSocketService.java x: 45 commits (all time) y: 264 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/NonPersistentTopics.java x: 63 commits (all time) y: 599 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PulsarStats.java x: 30 commits (all time) y: 212 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/TransactionAggregator.java x: 12 commits (all time) y: 243 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/channel/ServiceUnitStateTableViewSyncer.java x: 1 commits (all time) y: 219 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/LoadManager.java x: 22 commits (all time) y: 77 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/TopicPoliciesService.java x: 20 commits (all time) y: 49 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/nar/NarUnpacker.java x: 10 commits (all time) y: 122 lines of code pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch/ElasticSearchConfig.java x: 23 commits (all time) y: 326 lines of code pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch/client/opensearch/OpenSearchHighLevelRestClient.java x: 8 commits (all time) y: 300 lines of code pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ConsumerInterceptor.java x: 10 commits (all time) y: 19 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/ManagedLedgerFactory.java x: 23 commits (all time) y: 50 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerOfflineBacklog.java x: 21 commits (all time) y: 77 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/OpFindNewest.java x: 13 commits (all time) y: 117 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/OpenTelemetryManagedCursorStats.java x: 2 commits (all time) y: 90 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ReadOnlyCursorImpl.java x: 12 commits (all time) y: 50 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BacklogQuotaManager.java x: 38 commits (all time) y: 216 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/pendingack/impl/MLPendingAckStore.java x: 18 commits (all time) y: 440 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/pendingack/impl/PendingAckHandleImpl.java x: 43 commits (all time) y: 942 lines of code pulsar-broker/src/main/java/org/apache/pulsar/compaction/AbstractTwoPhaseCompactor.java x: 2 commits (all time) y: 373 lines of code pulsar-broker/src/main/java/org/apache/pulsar/compaction/EventTimeOrderCompactor.java x: 2 commits (all time) y: 127 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/TopicListWatcher.java x: 12 commits (all time) y: 213 lines of code pulsar-broker/src/main/java/org/apache/pulsar/PulsarClusterMetadataSetup.java x: 56 commits (all time) y: 409 lines of code pulsar-client-messagecrypto-bc/src/main/java/org/apache/pulsar/client/impl/crypto/MessageCryptoBc.java x: 14 commits (all time) y: 427 lines of code pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authentication/AuthenticationProvider.java x: 14 commits (all time) y: 85 lines of code pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authentication/AuthenticationProviderBasic.java x: 11 commits (all time) y: 166 lines of code pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authentication/AuthenticationProviderToken.java x: 30 commits (all time) y: 344 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/TransactionBuffer.java x: 25 commits (all time) y: 33 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/InMemTransactionBuffer.java x: 28 commits (all time) y: 362 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/SimpleLoadManagerImpl.java x: 49 commits (all time) y: 1163 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace/LookupOptions.java x: 5 commits (all time) y: 18 lines of code pulsar-broker/src/main/java/org/apache/pulsar/compaction/StrategicTwoPhaseCompactor.java x: 7 commits (all time) y: 386 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentReplicator.java x: 26 commits (all time) y: 194 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PulsarChannelInitializer.java x: 32 commits (all time) y: 109 lines of code pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/PulsarAdminBuilderImpl.java x: 21 commits (all time) y: 226 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/PulsarAdminTool.java x: 59 commits (all time) y: 253 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/PulsarClientTool.java x: 35 commits (all time) y: 202 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/ClusterDataImpl.java x: 12 commits (all time) y: 385 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/util/DefaultPulsarSslFactory.java x: 1 commits (all time) y: 276 lines of code pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/WorkerServer.java x: 42 commits (all time) y: 280 lines of code pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ServiceChannelInitializer.java x: 26 commits (all time) y: 94 lines of code pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceBaseArguments.java x: 13 commits (all time) y: 80 lines of code pulsar-websocket/src/main/java/org/apache/pulsar/websocket/service/ProxyServer.java x: 28 commits (all time) y: 230 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/util/FieldParser.java x: 21 commits (all time) y: 212 lines of code pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyServiceStarter.java x: 55 commits (all time) y: 386 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/HttpLookupService.java x: 39 commits (all time) y: 206 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/LookupService.java x: 20 commits (all time) y: 32 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/transaction/TransactionCoordinatorClientImpl.java x: 19 commits (all time) y: 226 lines of code pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/FunctionsImpl.java x: 57 commits (all time) y: 644 lines of code pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/PackagesImpl.java x: 14 commits (all time) y: 172 lines of code pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/PulsarAdminImpl.java x: 13 commits (all time) y: 264 lines of code pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/SinksImpl.java x: 16 commits (all time) y: 390 lines of code pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/SourcesImpl.java x: 15 commits (all time) y: 312 lines of code pulsar-metadata/src/main/java/org/apache/pulsar/metadata/coordination/impl/LeaderElectionImpl.java x: 20 commits (all time) y: 294 lines of code docker/pulsar/scripts/gen-yml-from-env.py x: 12 commits (all time) y: 74 lines of code pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/BaseResource.java x: 28 commits (all time) y: 309 lines of code pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/BookiesImpl.java x: 11 commits (all time) y: 65 lines of code pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/ClustersImpl.java x: 21 commits (all time) y: 263 lines of code pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/TenantsImpl.java x: 12 commits (all time) y: 97 lines of code pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/TopicsImpl.java x: 133 commits (all time) y: 2397 lines of code pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/TransactionsImpl.java x: 23 commits (all time) y: 245 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdBase.java x: 19 commits (all time) y: 83 lines of code pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/PulsarZooKeeperClient.java x: 9 commits (all time) y: 1253 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/DelayedDeliveryTracker.java x: 14 commits (all time) y: 53 lines of code pulsar-io/jdbc/core/src/main/java/org/apache/pulsar/io/jdbc/BaseJdbcAutoSchemaSink.java x: 10 commits (all time) y: 252 lines of code pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/PulsarWorkerOpenTelemetry.java x: 2 commits (all time) y: 25 lines of code pulsar-websocket/src/main/java/org/apache/pulsar/websocket/ConsumerHandler.java x: 54 commits (all time) y: 422 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/PatternConsumerUpdateQueue.java x: 1 commits (all time) y: 160 lines of code pulsar-opentelemetry/src/main/java/org/apache/pulsar/opentelemetry/OpenTelemetryService.java x: 7 commits (all time) y: 86 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/OpenTelemetryTopicStats.java x: 3 commits (all time) y: 343 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/TransactionBufferClientImpl.java x: 18 commits (all time) y: 99 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/TransactionBufferClientStatsImpl.java x: 3 commits (all time) y: 141 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/pendingack/PendingAckHandle.java x: 22 commits (all time) y: 32 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/pendingack/impl/PendingAckHandleDisabled.java x: 18 commits (all time) y: 77 lines of code pulsar-transaction/coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/impl/MLTransactionMetadataStore.java x: 35 commits (all time) y: 513 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/OpenTelemetryManagedLedgerCacheStats.java x: 1 commits (all time) y: 113 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerFactoryMBeanImpl.java x: 10 commits (all time) y: 108 lines of code pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/LocalMemoryMetadataStore.java x: 24 commits (all time) y: 212 lines of code pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/RocksdbMetadataStore.java x: 18 commits (all time) y: 521 lines of code pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/batching/AbstractBatchedMetadataStore.java x: 12 commits (all time) y: 169 lines of code pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ContextImpl.java x: 77 commits (all time) y: 627 lines of code pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/sink/PulsarSink.java x: 57 commits (all time) y: 290 lines of code pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/SourceConfigUtils.java x: 57 commits (all time) y: 456 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/OverloadShedder.java x: 20 commits (all time) y: 82 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/transaction/TransactionImpl.java x: 27 commits (all time) y: 212 lines of code pulsar-testclient/src/main/java/org/apache/pulsar/testclient/BrokerMonitor.java x: 15 commits (all time) y: 420 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedCursorContainer.java x: 19 commits (all time) y: 292 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/NonDurableCursorImpl.java x: 24 commits (all time) y: 97 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/TransactionsBase.java x: 26 commits (all time) y: 522 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Subscription.java x: 35 commits (all time) y: 74 lines of code pulsar-transaction/coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/impl/MLTransactionLogImpl.java x: 29 commits (all time) y: 333 lines of code pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/EtcdMetadataStore.java x: 9 commits (all time) y: 439 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/stats/TopicStatsImpl.java x: 23 commits (all time) y: 228 lines of code pulsar-broker/src/main/java/org/apache/pulsar/PulsarStandalone.java x: 63 commits (all time) y: 388 lines of code pulsar-common/src/main/java-templates/org/apache/pulsar/PulsarVersion.java x: 7 commits (all time) y: 58 lines of code pulsar-broker/src/main/java/org/apache/pulsar/PulsarStandaloneStarter.java x: 45 commits (all time) y: 142 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/data/BrokerLoadData.java x: 8 commits (all time) y: 190 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/LeastResourceUsageWithWeight.java x: 11 commits (all time) y: 116 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/BookKeeperClientFactoryImpl.java x: 53 commits (all time) y: 203 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/web/WebExecutorStats.java x: 3 commits (all time) y: 76 lines of code pulsar-broker-common/src/main/java/org/apache/pulsar/bookie/rackawareness/BookieRackAffinityMapping.java x: 14 commits (all time) y: 237 lines of code pulsar-broker/src/main/java/org/apache/pulsar/utils/auth/tokens/TokensCliUtils.java x: 18 commits (all time) y: 267 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/SchemaRegistryService.java x: 16 commits (all time) y: 39 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/SchemaRegistryStats.java x: 5 commits (all time) y: 194 lines of code pulsar-common/src/main/java/org/apache/pulsar/policies/data/loadbalancer/LocalBrokerData.java x: 28 commits (all time) y: 384 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/nar/NarClassLoader.java x: 18 commits (all time) y: 152 lines of code pulsar-client-admin-api/src/main/java/org/apache/pulsar/client/admin/Topics.java x: 54 commits (all time) y: 680 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/FunctionsBase.java x: 65 commits (all time) y: 744 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/SinksBase.java x: 21 commits (all time) y: 539 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/SourcesBase.java x: 23 commits (all time) y: 491 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v3/Packages.java x: 4 commits (all time) y: 214 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/Bookies.java x: 15 commits (all time) y: 169 lines of code pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/PulsarKafkaSinkTaskContext.java x: 8 commits (all time) y: 201 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/AvroSchemaBasedCompatibilityCheck.java x: 13 commits (all time) y: 72 lines of code pulsar-broker-common/src/main/java/org/apache/pulsar/broker/resources/NamespaceResources.java x: 31 commits (all time) y: 307 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/protocol/PulsarDecoder.java x: 22 commits (all time) y: 587 lines of code tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/impl/BlobStoreBackedReadHandleImpl.java x: 24 commits (all time) y: 255 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdSinks.java x: 94 commits (all time) y: 709 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdSources.java x: 82 commits (all time) y: 639 lines of code pulsar-websocket/src/main/java/org/apache/pulsar/websocket/service/WebSocketProxyConfiguration.java x: 40 commits (all time) y: 201 lines of code pulsar-testclient/src/main/java/org/apache/pulsar/testclient/LoadSimulationController.java x: 17 commits (all time) y: 532 lines of code pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceConsumer.java x: 74 commits (all time) y: 473 lines of code pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceProducer.java x: 77 commits (all time) y: 659 lines of code pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceReader.java x: 43 commits (all time) y: 184 lines of code pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceTransaction.java x: 22 commits (all time) y: 556 lines of code pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PulsarPerfTestTool.java x: 1 commits (all time) y: 96 lines of code pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/worker/WorkerConfig.java x: 53 commits (all time) y: 867 lines of code tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/impl/BlobStoreBackedReadHandleImplV2.java x: 10 commits (all time) y: 295 lines of code pulsar-broker/src/main/java/org/apache/pulsar/PulsarBrokerStarter.java x: 52 commits (all time) y: 308 lines of code pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionWorkerStarter.java x: 21 commits (all time) y: 57 lines of code pulsar-websocket/src/main/java/org/apache/pulsar/websocket/service/WebSocketServiceStarter.java x: 18 commits (all time) y: 92 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/UnAckedMessageTracker.java x: 27 commits (all time) y: 252 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/resourcegroup/ResourceGroupService.java x: 23 commits (all time) y: 585 lines of code pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/JavaInstanceStarter.java x: 24 commits (all time) y: 409 lines of code pulsar-broker/src/main/java/org/apache/pulsar/client/impl/RawReaderImpl.java x: 45 commits (all time) y: 225 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CliCommand.java x: 27 commits (all time) y: 122 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdTransactions.java x: 18 commits (all time) y: 217 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CustomCommandsUtils.java x: 3 commits (all time) y: 185 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/PulsarAdminSupplier.java x: 4 commits (all time) y: 88 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/shell/PulsarShell.java x: 10 commits (all time) y: 514 lines of code pulsar-websocket/src/main/java/org/apache/pulsar/websocket/ProducerHandler.java x: 34 commits (all time) y: 435 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/transaction/TransactionBuilderImpl.java x: 13 commits (all time) y: 50 lines of code testmocks/src/main/java/org/apache/bookkeeper/client/TestStatsProvider.java x: 5 commits (all time) y: 213 lines of code buildtools/src/main/resources/log4j2.xml x: 9 commits (all time) y: 18 lines of code pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionActioner.java x: 82 commits (all time) y: 620 lines of code pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionRuntimeManager.java x: 115 commits (all time) y: 773 lines of code pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/PulsarWorkerService.java x: 32 commits (all time) y: 544 lines of code pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/ComponentImpl.java x: 79 commits (all time) y: 1601 lines of code pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/FunctionsImpl.java x: 113 commits (all time) y: 654 lines of code pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/SinksImpl.java x: 38 commits (all time) y: 660 lines of code pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/SourcesImpl.java x: 37 commits (all time) y: 606 lines of code tiered-storage/file-system/src/main/java/org/apache/bookkeeper/mledger/offload/filesystem/impl/FileStoreBackedReadHandleImpl.java x: 10 commits (all time) y: 186 lines of code pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/thread/ThreadRuntime.java x: 23 commits (all time) y: 274 lines of code pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/FunctionFilePackage.java x: 1 commits (all time) y: 141 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/store/LoadDataStoreFactory.java x: 2 commits (all time) y: 9 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PulsarCommandSenderImpl.java x: 29 commits (all time) y: 311 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/util/collections/BitSetRecyclable.java x: 5 commits (all time) y: 524 lines of code docker/pulsar/scripts/apply-config-from-env.py x: 15 commits (all time) y: 56 lines of code distribution/server/src/assemble/bin.xml x: 19 commits (all time) y: 105 lines of code pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/state/BKStateStoreImpl.java x: 6 commits (all time) y: 168 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/HierarchyTopicPolicies.java x: 28 commits (all time) y: 73 lines of code pulsar-client-admin-api/src/main/java/org/apache/pulsar/client/admin/TopicPolicies.java x: 9 commits (all time) y: 238 lines of code pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/TopicPoliciesImpl.java x: 12 commits (all time) y: 1074 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/scheduler/UnloadScheduler.java x: 6 commits (all time) y: 190 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/models/UnloadCounter.java x: 4 commits (all time) y: 122 lines of code src/owasp-dependency-check-false-positives.xml x: 16 commits (all time) y: 171 lines of code src/owasp-dependency-check-suppressions.xml x: 26 commits (all time) y: 429 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PublishRateLimiter.java x: 12 commits (all time) y: 8 lines of code pulsar-io/alluxio/src/main/java/org/apache/pulsar/io/alluxio/sink/AlluxioSink.java x: 5 commits (all time) y: 280 lines of code pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaSourceConfig.java x: 15 commits (all time) y: 133 lines of code pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq/RabbitMQSink.java x: 7 commits (all time) y: 73 lines of code pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/state/BKStateStoreProviderImpl.java x: 9 commits (all time) y: 177 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1/PersistentTopics.java x: 93 commits (all time) y: 1063 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/util/keystoretls/KeyStoreSSLContext.java x: 16 commits (all time) y: 287 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1/NonPersistentTopics.java x: 42 commits (all time) y: 264 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/TopicMessageImpl.java x: 27 commits (all time) y: 156 lines of code pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authorization/MultiRolesTokenAuthorizationProvider.java x: 15 commits (all time) y: 250 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1/Namespaces.java x: 92 commits (all time) y: 1651 lines of code pulsar-broker-common/src/main/java/org/apache/pulsar/broker/resources/ClusterResources.java x: 15 commits (all time) y: 191 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/AuthenticationDataTls.java x: 12 commits (all time) y: 121 lines of code pulsar-functions/instance/src/main/python/python_instance_main.py x: 43 commits (all time) y: 233 lines of code pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch/ElasticSearchClient.java x: 15 commits (all time) y: 282 lines of code pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch/ElasticSearchSink.java x: 22 commits (all time) y: 379 lines of code pulsar-metadata/src/main/java/org/apache/pulsar/metadata/bookkeeper/PulsarLedgerUnderreplicationManager.java x: 8 commits (all time) y: 917 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/util/collections/ConcurrentLongHashMap.java x: 14 commits (all time) y: 472 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/util/collections/ConcurrentLongLongPairHashMap.java x: 5 commits (all time) y: 510 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/util/collections/ConcurrentLongPairSet.java x: 15 commits (all time) y: 525 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicsReaderImpl.java x: 18 commits (all time) y: 200 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ReaderImpl.java x: 44 commits (all time) y: 213 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/LinuxBrokerHostUsageImpl.java x: 25 commits (all time) y: 127 lines of code pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisSourceConfig.java x: 8 commits (all time) y: 157 lines of code pulsar-metadata/src/main/java/org/apache/pulsar/metadata/bookkeeper/PulsarRegistrationManager.java x: 6 commits (all time) y: 331 lines of code pulsar-proxy/src/main/java/org/apache/pulsar/proxy/stats/ProxyStats.java x: 7 commits (all time) y: 123 lines of code pulsar-functions/instance/src/main/python/python_instance.py x: 57 commits (all time) y: 482 lines of code pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/kubernetes/KubernetesRuntime.java x: 41 commits (all time) y: 984 lines of code pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/kubernetes/KubernetesRuntimeFactory.java x: 26 commits (all time) y: 488 lines of code buildtools/src/main/resources/pulsar/suppressions.xml x: 17 commits (all time) y: 45 lines of code pulsar-websocket/src/main/java/org/apache/pulsar/websocket/ReaderHandler.java x: 29 commits (all time) y: 286 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/MessageIdImpl.java x: 24 commits (all time) y: 139 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/strategy/DefaultNamespaceBundleSplitStrategyImpl.java x: 5 commits (all time) y: 246 lines of code pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/FunctionsImplV2.java x: 16 commits (all time) y: 207 lines of code pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/v2/FunctionsApiV2Resource.java x: 8 commits (all time) y: 284 lines of code pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/v3/FunctionsApiV3Resource.java x: 18 commits (all time) y: 377 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/AcknowledgmentsGroupingTracker.java x: 13 commits (all time) y: 16 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/BatchMessageIdImpl.java x: 22 commits (all time) y: 84 lines of code pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/schema/PulsarSchemaToKafkaSchema.java x: 7 commits (all time) y: 217 lines of code pulsar-function-go/pb/Function.pb.go x: 7 commits (all time) y: 2010 lines of code pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/schema/KafkaConnectData.java x: 8 commits (all time) y: 333 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/AutoConsumeSchema.java x: 33 commits (all time) y: 305 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/LedgerOffloaderStatsImpl.java x: 5 commits (all time) y: 297 lines of code pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/PulsarSourceConfig.java x: 18 commits (all time) y: 18 lines of code pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/kubernetes/BasicKubernetesManifestCustomizer.java x: 11 commits (all time) y: 214 lines of code pulsar-functions/instance/src/main/python/util.py x: 14 commits (all time) y: 70 lines of code pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/FaultInjectionMetadataStore.java x: 9 commits (all time) y: 173 lines of code pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch/client/RestClient.java x: 7 commits (all time) y: 214 lines of code pulsar-transaction/coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/impl/TxnLogBufferedWriter.java x: 11 commits (all time) y: 410 lines of code pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/Worker.java x: 58 commits (all time) y: 93 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerStatsRecorderImpl.java x: 21 commits (all time) y: 278 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/util/ProtectedObjectMapper.java x: 1 commits (all time) y: 349 lines of code pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/SchedulerManager.java x: 51 commits (all time) y: 690 lines of code pulsar-io/http/src/main/java/org/apache/pulsar/io/http/JsonConverter.java x: 1 commits (all time) y: 206 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/ManagedLedgerException.java x: 21 commits (all time) y: 156 lines of code pulsar-client-admin-api/src/main/java/org/apache/pulsar/client/admin/PulsarAdminException.java x: 5 commits (all time) y: 156 lines of code pulsar-client-api/src/main/java/org/apache/pulsar/client/internal/DefaultImplementation.java x: 24 commits (all time) y: 18 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/AbstractStructSchema.java x: 8 commits (all time) y: 160 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/StructSchema.java x: 18 commits (all time) y: 21 lines of code pulsar-common/src/main/java/org/apache/pulsar/client/impl/schema/KeyValueSchemaInfo.java x: 4 commits (all time) y: 164 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/util/collections/GrowablePriorityLongPairQueue.java x: 7 commits (all time) y: 254 lines of code pulsar-config-validation/src/main/java/org/apache/pulsar/config/validation/ValidatorImpls.java x: 4 commits (all time) y: 287 lines of code pulsar-functions/api-java/src/main/java/org/apache/pulsar/functions/api/Context.java x: 40 commits (all time) y: 35 lines of code pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/InstanceUtils.java x: 19 commits (all time) y: 178 lines of code pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/SinkRecord.java x: 16 commits (all time) y: 68 lines of code pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/batch/BatchSourceExecutor.java x: 10 commits (all time) y: 269 lines of code pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/process/ProcessRuntime.java x: 16 commits (all time) y: 354 lines of code pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionAssignmentTailer.java x: 21 commits (all time) y: 130 lines of code pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/MembershipManager.java x: 30 commits (all time) y: 180 lines of code pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/WorkerService.java x: 54 commits (all time) y: 32 lines of code pulsar-io/core/src/main/java/org/apache/pulsar/io/core/Sink.java x: 11 commits (all time) y: 11 lines of code pulsar-io/core/src/main/java/org/apache/pulsar/io/core/SourceContext.java x: 14 commits (all time) y: 18 lines of code pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/AbstractHdfsConnector.java x: 7 commits (all time) y: 160 lines of code pulsar-io/twitter/src/main/java/org/apache/pulsar/io/twitter/TwitterFireHose.java x: 17 commits (all time) y: 126 lines of code pulsar-metadata/src/main/java/org/apache/pulsar/metadata/bookkeeper/PulsarLedgerIdGenerator.java x: 6 commits (all time) y: 221 lines of code pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/BrokerDiscoveryProvider.java x: 24 commits (all time) y: 61 lines of code pulsar-transaction/coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/impl/MLTransactionMetadataStoreProvider.java x: 17 commits (all time) y: 60 lines of code tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/impl/OffloadIndexBlockImpl.java x: 13 commits (all time) y: 278 lines of code tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/provider/JCloudBlobStoreProvider.java x: 15 commits (all time) y: 349 lines of code pulsar-functions/instance/src/main/python/function_stats.py x: 12 commits (all time) y: 150 lines of code pulsar-function-go/pb/InstanceCommunication.pb.go x: 4 commits (all time) y: 1022 lines of code pulsar-functions/proto/src/main/proto/InstanceCommunication.proto x: 24 commits (all time) y: 111 lines of code
4990.0
lines of code
  min: 1.0
  average: 113.8
  25th percentile: 10.0
  median: 36.0
  75th percentile: 97.0
  max: 4990.0
0 522.0
commits (all time)
min: 1.0 | average: 10.64 | 25th percentile: 2.0 | median: 4.0 | 75th percentile: 9.0 | max: 522.0

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

pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractTopic.java x: 61 contributors (all time) y: 1176 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/PolicyHierarchyValue.java x: 4 contributors (all time) y: 54 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedCursorImpl.java x: 64 contributors (all time) y: 3144 lines of code pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/AbstractKafkaConnectSource.java x: 11 contributors (all time) y: 260 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/GeoReplicationProducerImpl.java x: 1 contributors (all time) y: 189 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/HandlerState.java x: 9 contributors (all time) y: 70 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java x: 67 contributors (all time) y: 2134 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarClientImplementationBindingImpl.java x: 6 contributors (all time) y: 267 lines of code pulsar-common/src/main/java/org/apache/pulsar/client/impl/schema/SchemaInfoImpl.java x: 5 contributors (all time) y: 70 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java x: 104 contributors (all time) y: 3094 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/metrics/ObserverGauge.java x: 5 contributors (all time) y: 79 lines of code pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java x: 111 contributors (all time) y: 3475 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/TopicPolicies.java x: 20 contributors (all time) y: 143 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/stats/NonPersistentTopicStatsImpl.java x: 7 contributors (all time) y: 142 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/AckSetState.java x: 2 contributors (all time) y: 9 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java x: 82 contributors (all time) y: 3837 lines of code pulsar-broker-auth-oidc/src/main/java/org/apache/pulsar/broker/authentication/oidc/OpenIDProviderMetadataCache.java x: 3 contributors (all time) y: 155 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/NamespacesBase.java x: 81 contributors (all time) y: 2569 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java x: 101 contributors (all time) y: 4990 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v3/Transactions.java x: 11 contributors (all time) y: 452 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/bucket/BookkeeperBucketSnapshotStorage.java x: 5 contributors (all time) y: 244 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace/NamespaceEphemeralData.java x: 6 contributors (all time) y: 42 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace/NamespaceService.java x: 58 contributors (all time) y: 1456 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractBaseDispatcher.java x: 31 contributors (all time) y: 403 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ConsumerHashAssignmentsSnapshot.java x: 1 contributors (all time) y: 161 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/EntryAndMetadata.java x: 4 contributors (all time) y: 92 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/SystemTopicBasedTopicPoliciesService.java x: 31 contributors (all time) y: 641 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentMessageExpiryMonitor.java x: 20 contributors (all time) y: 223 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java x: 110 contributors (all time) y: 3740 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/SystemTopic.java x: 14 contributors (all time) y: 81 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/BookkeeperSchemaStorage.java x: 28 contributors (all time) y: 654 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/BookkeeperSchemaStorageFactory.java x: 5 contributors (all time) y: 12 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/SchemaRegistryServiceImpl.java x: 29 contributors (all time) y: 603 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/web/PulsarWebResource.java x: 50 contributors (all time) y: 1107 lines of code pulsar-broker/src/main/java/org/apache/pulsar/compaction/CompactedTopicImpl.java x: 17 contributors (all time) y: 338 lines of code pulsar-broker/src/main/java/org/apache/pulsar/compaction/CompactedTopicUtils.java x: 3 contributors (all time) y: 77 lines of code pulsar-broker/src/main/java/org/apache/pulsar/compaction/PulsarCompactionServiceFactory.java x: 3 contributors (all time) y: 58 lines of code pulsar-broker/src/main/java/org/apache/pulsar/compaction/PulsarTopicCompactionService.java x: 2 contributors (all time) y: 102 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ControlledClusterFailover.java x: 6 contributors (all time) y: 210 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicsConsumerImpl.java x: 64 contributors (all time) y: 1405 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/PersistentAcknowledgmentsGroupingTracker.java x: 23 contributors (all time) y: 596 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarClientImpl.java x: 60 contributors (all time) y: 1119 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/util/FutureUtil.java x: 14 contributors (all time) y: 236 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/util/collections/GrowableArrayBlockingQueue.java x: 6 contributors (all time) y: 364 lines of code pulsar-io/azure-data-explorer/src/main/java/org/apache/pulsar/io/azuredataexplorer/ADXSink.java x: 2 contributors (all time) y: 246 lines of code pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/KafkaConnectSource.java x: 11 contributors (all time) y: 249 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/TransactionMetaStoreHandler.java x: 16 contributors (all time) y: 736 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/rest/TopicsBase.java x: 11 contributors (all time) y: 699 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/ManagedLedger.java x: 33 contributors (all time) y: 123 lines of code managed-ledger/src/main/proto/MLDataFormats.proto x: 13 contributors (all time) y: 134 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentMessageFinder.java x: 11 contributors (all time) y: 124 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/HealthChecker.java x: 1 contributors (all time) y: 257 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/TenantsBase.java x: 24 contributors (all time) y: 317 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/AdminResource.java x: 62 contributors (all time) y: 837 lines of code pulsar-client-admin-api/src/main/java/org/apache/pulsar/common/policies/data/BacklogQuota.java x: 6 contributors (all time) y: 32 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/channel/ServiceUnitStateChannelImpl.java x: 6 contributors (all time) y: 1699 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java x: 80 contributors (all time) y: 1759 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/BrokersBase.java x: 36 contributors (all time) y: 478 lines of code pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ConsumerBuilder.java x: 40 contributors (all time) y: 77 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/conf/ConsumerConfigurationData.java x: 36 contributors (all time) y: 377 lines of code pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/PulsarOffsetBackingStore.java x: 9 contributors (all time) y: 223 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/OffloadPoliciesImpl.java x: 11 contributors (all time) y: 539 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/util/Backoff.java x: 3 contributors (all time) y: 88 lines of code pulsar-metadata/src/main/java/org/apache/pulsar/metadata/api/MetadataCacheConfig.java x: 4 contributors (all time) y: 30 lines of code pulsar-metadata/src/main/java/org/apache/pulsar/metadata/tableview/impl/MetadataStoreTableViewImpl.java x: 1 contributors (all time) y: 283 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/validator/SchemaDataValidator.java x: 5 contributors (all time) y: 58 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/validator/StructSchemaDataValidator.java x: 6 contributors (all time) y: 65 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/generic/GenericSchemaImpl.java x: 9 contributors (all time) y: 44 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ClientCnx.java x: 44 contributors (all time) y: 1279 lines of code pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/LookupProxyHandler.java x: 20 contributors (all time) y: 379 lines of code pulsar-broker-common/src/main/java/org/apache/pulsar/bookie/rackawareness/IsolatedBookieEnsemblePlacementPolicy.java x: 12 contributors (all time) y: 240 lines of code pulsar-client-admin-api/src/main/java/org/apache/pulsar/common/functions/MessagePayloadProcessorConfig.java x: 1 contributors (all time) y: 16 lines of code pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/JavaInstanceRunnable.java x: 37 contributors (all time) y: 963 lines of code pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/PulsarSource.java x: 20 contributors (all time) y: 164 lines of code pulsar-functions/proto/src/main/proto/Function.proto x: 17 contributors (all time) y: 227 lines of code pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/FunctionConfigUtils.java x: 29 contributors (all time) y: 977 lines of code pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/MessagePayloadProcessorUtils.java x: 1 contributors (all time) y: 65 lines of code pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/SinkConfigUtils.java x: 25 contributors (all time) y: 674 lines of code pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/ValidatorUtils.java x: 9 contributors (all time) y: 155 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Consumer.java x: 61 contributors (all time) y: 1024 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Producer.java x: 39 contributors (all time) y: 740 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerImpl.java x: 95 contributors (all time) y: 2716 lines of code testmocks/src/main/java/org/apache/zookeeper/MockZooKeeper.java x: 15 contributors (all time) y: 1034 lines of code testmocks/src/main/java/org/apache/zookeeper/MockZooKeeperSession.java x: 5 contributors (all time) y: 334 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/scheduler/TransferShedder.java x: 3 contributors (all time) y: 665 lines of code pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ProducerBuilder.java x: 20 contributors (all time) y: 52 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerBuilderImpl.java x: 24 contributors (all time) y: 299 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/protocol/Commands.java x: 45 contributors (all time) y: 1733 lines of code pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/DirectProxyHandler.java x: 25 contributors (all time) y: 418 lines of code pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyClientCnx.java x: 13 contributors (all time) y: 69 lines of code pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyConnection.java x: 26 contributors (all time) y: 693 lines of code pulsar-client-api/src/main/java/org/apache/pulsar/client/api/PulsarClientException.java x: 20 contributors (all time) y: 506 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentSubscription.java x: 29 contributors (all time) y: 441 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumers.java x: 46 contributors (all time) y: 1168 lines of code pulsar-function-go/pf/instance.go x: 13 contributors (all time) y: 622 lines of code pulsar-function-go/pf/context.go x: 7 contributors (all time) y: 129 lines of code pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/Utils.java x: 7 contributors (all time) y: 217 lines of code pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/json/JsonConverter.java x: 3 contributors (all time) y: 194 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/EntryCountEstimator.java x: 1 contributors (all time) y: 103 lines of code pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/KafkaConnectSink.java x: 9 contributors (all time) y: 435 lines of code pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaAbstractSink.java x: 10 contributors (all time) y: 95 lines of code pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaBytesSource.java x: 9 contributors (all time) y: 178 lines of code pulsar-broker/src/main/java/org/apache/pulsar/PulsarClusterMetadataTeardown.java x: 10 contributors (all time) y: 228 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/oauth2/ClientCredentialsFlow.java x: 9 contributors (all time) y: 113 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/PatternMultiTopicsConsumerImpl.java x: 17 contributors (all time) y: 323 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Dispatcher.java x: 17 contributors (all time) y: 99 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentSubscription.java x: 55 contributors (all time) y: 1302 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/AggregatedNamespaceStats.java x: 21 contributors (all time) y: 188 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/AggregatedSubscriptionStats.java x: 13 contributors (all time) y: 41 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/NamespaceStatsAggregator.java x: 39 contributors (all time) y: 510 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/TopicStats.java x: 33 contributors (all time) y: 519 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/stats/SubscriptionStatsImpl.java x: 19 contributors (all time) y: 178 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerBuilderImpl.java x: 42 contributors (all time) y: 539 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentReplicator.java x: 36 contributors (all time) y: 575 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/MessageDeduplication.java x: 25 contributors (all time) y: 558 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/util/RetryMessageUtil.java x: 5 contributors (all time) y: 20 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PulsarMetadataEventSynchronizer.java x: 4 contributors (all time) y: 281 lines of code pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/AbstractMetadataStore.java x: 17 contributors (all time) y: 494 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace/OwnedBundle.java x: 11 contributors (all time) y: 89 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentTopic.java x: 77 contributors (all time) y: 1024 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/BatchMessageContainerBase.java x: 7 contributors (all time) y: 16 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/BatchMessageContainerImpl.java x: 22 contributors (all time) y: 294 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerMBeanImpl.java x: 14 contributors (all time) y: 299 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java x: 94 contributors (all time) y: 3241 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/TopicListService.java x: 7 contributors (all time) y: 202 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/ThresholdShedder.java x: 18 contributors (all time) y: 189 lines of code pulsar-client-admin-api/src/main/java/org/apache/pulsar/common/functions/BatchingConfig.java x: 1 contributors (all time) y: 21 lines of code pulsar-client-admin-api/src/main/java/org/apache/pulsar/common/functions/ProducerConfig.java x: 3 contributors (all time) y: 21 lines of code pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ProducerBuilderFactory.java x: 2 contributors (all time) y: 146 lines of code pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/BatchingUtils.java x: 1 contributors (all time) y: 57 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/api/raw/RawMessageImpl.java x: 11 contributors (all time) y: 177 lines of code pulsar-client-api/src/main/java/org/apache/pulsar/client/api/DeadLetterPolicy.java x: 8 contributors (all time) y: 23 lines of code pulsar-broker-common/src/main/java/org/apache/pulsar/broker/stats/prometheus/PrometheusMetricsServlet.java x: 5 contributors (all time) y: 146 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/PulsarPrometheusMetricsServlet.java x: 4 contributors (all time) y: 153 lines of code pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/FunctionsMetricsResource.java x: 8 contributors (all time) y: 66 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/TypedMessageBuilderImpl.java x: 20 contributors (all time) y: 262 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/InMemoryDelayedDeliveryTracker.java x: 13 contributors (all time) y: 171 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/GeoPersistentReplicator.java x: 8 contributors (all time) y: 182 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/ShadowReplicator.java x: 8 contributors (all time) y: 89 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/BrokerRegistryImpl.java x: 7 contributors (all time) y: 243 lines of code pulsar-client-admin-api/src/main/java/org/apache/pulsar/common/policies/data/OffloadPolicies.java x: 4 contributors (all time) y: 69 lines of code tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/JCloudLedgerOffloaderFactory.java x: 10 contributors (all time) y: 47 lines of code tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/impl/BlobStoreManagedLedgerOffloader.java x: 19 contributors (all time) y: 636 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/qos/AsyncTokenBucket.java x: 1 contributors (all time) y: 122 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/resourcegroup/ResourceGroup.java x: 8 contributors (all time) y: 499 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PublishRateLimiterImpl.java x: 5 contributors (all time) y: 126 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentDispatcherSingleActiveConsumer.java x: 22 contributors (all time) y: 82 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/DispatchRateLimiter.java x: 21 contributors (all time) y: 122 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumersClassic.java x: 2 contributors (all time) y: 1050 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherSingleActiveConsumer.java x: 42 contributors (all time) y: 501 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/SubscribeRateLimiter.java x: 12 contributors (all time) y: 151 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/util/RateLimitFunction.java x: 3 contributors (all time) y: 4 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdPersistentTopics.java x: 23 contributors (all time) y: 559 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdTopics.java x: 60 contributors (all time) y: 2527 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/bucket/BucketDelayedDeliveryTracker.java x: 5 contributors (all time) y: 629 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractReplicator.java x: 18 contributors (all time) y: 397 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Topic.java x: 48 contributors (all time) y: 181 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/TransportCnx.java x: 14 contributors (all time) y: 42 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/conf/ProducerConfigurationData.java x: 23 contributors (all time) y: 220 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/protocol/Markers.java x: 11 contributors (all time) y: 225 lines of code pulsar-common/src/main/proto/PulsarApi.proto x: 47 contributors (all time) y: 928 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerBase.java x: 53 contributors (all time) y: 1092 lines of code pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/ZKMetadataStore.java x: 18 contributors (all time) y: 565 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/LoadManagerShared.java x: 21 contributors (all time) y: 593 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/ModularLoadManagerImpl.java x: 44 contributors (all time) y: 902 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ShadowManagedLedgerImpl.java x: 7 contributors (all time) y: 321 lines of code pulsar-broker/src/main/java/org/apache/pulsar/client/impl/RawBatchMessageContainerImpl.java x: 3 contributors (all time) y: 131 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/MessageImpl.java x: 38 contributors (all time) y: 673 lines of code pulsar-metadata/src/main/java/org/apache/pulsar/metadata/bookkeeper/PulsarRegistrationClient.java x: 8 contributors (all time) y: 281 lines of code pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyConfiguration.java x: 38 contributors (all time) y: 879 lines of code pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/WebServer.java x: 22 contributors (all time) y: 373 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/MetaStoreImpl.java x: 18 contributors (all time) y: 467 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentStickyKeyDispatcherMultipleConsumers.java x: 27 contributors (all time) y: 527 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/util/RangeCache.java x: 14 contributors (all time) y: 321 lines of code pulsar-client-auth-athenz/src/main/java/org/apache/pulsar/client/impl/auth/AuthenticationAthenz.java x: 12 contributors (all time) y: 219 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/Namespaces.java x: 63 contributors (all time) y: 2968 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/PersistentTopics.java x: 76 contributors (all time) y: 4831 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/TopicTransactionBuffer.java x: 15 contributors (all time) y: 662 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ClientBuilderImpl.java x: 27 contributors (all time) y: 388 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/SameAuthParamsLookupAutoClusterFailover.java x: 2 contributors (all time) y: 302 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/ManagedLedgerFactoryConfig.java x: 15 contributors (all time) y: 37 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerFactoryImpl.java x: 36 contributors (all time) y: 1272 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/ManagedLedgerClientFactory.java x: 23 contributors (all time) y: 191 lines of code pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/JavaExecutionResult.java x: 6 contributors (all time) y: 8 lines of code pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/JavaInstance.java x: 16 contributors (all time) y: 175 lines of code pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/stats/ComponentStatsManager.java x: 10 contributors (all time) y: 103 lines of code pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/stats/FunctionStatsManager.java x: 10 contributors (all time) y: 351 lines of code pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/stats/SinkStatsManager.java x: 10 contributors (all time) y: 266 lines of code pulsar-functions/instance/src/main/resources/findbugsExclude.xml x: 5 contributors (all time) y: 543 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdFunctions.java x: 33 contributors (all time) y: 1176 lines of code testmocks/src/main/java/org/apache/bookkeeper/client/PulsarMockBookKeeper.java x: 11 contributors (all time) y: 395 lines of code testmocks/src/main/java/org/apache/bookkeeper/client/PulsarMockLedgerHandle.java x: 8 contributors (all time) y: 225 lines of code testmocks/src/main/java/org/apache/bookkeeper/client/PulsarMockReadHandle.java x: 4 contributors (all time) y: 102 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/ManagedLedgerConfig.java x: 24 contributors (all time) y: 364 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/RangeSetWrapper.java x: 10 contributors (all time) y: 154 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConnectionHandler.java x: 19 contributors (all time) y: 201 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractDispatcherMultipleConsumers.java x: 14 contributors (all time) y: 116 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/DrainingHashesTracker.java x: 1 contributors (all time) y: 296 lines of code pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authentication/AuthenticationService.java x: 17 contributors (all time) y: 187 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/ReplicatedSubscriptionsController.java x: 16 contributors (all time) y: 264 lines of code pulsar-client/src/main/resources/findbugsExclude.xml x: 8 contributors (all time) y: 1006 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/ManagedCursor.java x: 26 contributors (all time) y: 162 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/OpAddEntry.java x: 26 contributors (all time) y: 326 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/systopic/TransactionBufferSnapshotBaseSystemTopicClient.java x: 4 contributors (all time) y: 169 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/SnapshotSegmentAbortedTxnProcessorImpl.java x: 8 contributors (all time) y: 605 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/impl/TableView.java x: 2 contributors (all time) y: 70 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/systopic/TopicPoliciesSystemTopicClient.java x: 10 contributors (all time) y: 174 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentStickyKeyDispatcherMultipleConsumersClassic.java x: 2 contributors (all time) y: 469 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/NegativeAcksTracker.java x: 13 contributors (all time) y: 147 lines of code pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/http/AsyncHttpConnector.java x: 22 contributors (all time) y: 483 lines of code pulsar-client-api/src/main/java/org/apache/pulsar/client/api/Authentication.java x: 7 contributors (all time) y: 36 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/CmdConsume.java x: 18 contributors (all time) y: 251 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/CmdProduce.java x: 21 contributors (all time) y: 476 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/CmdRead.java x: 3 contributors (all time) y: 254 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarChannelInitializer.java x: 16 contributors (all time) y: 188 lines of code pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/AdminProxyHandler.java x: 17 contributors (all time) y: 356 lines of code pulsar-testclient/src/main/java/org/apache/pulsar/proxy/socket/client/PerformanceClient.java x: 19 contributors (all time) y: 366 lines of code pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authentication/AuthenticationProviderList.java x: 12 contributors (all time) y: 301 lines of code pulsar-client-api/src/main/java/org/apache/pulsar/client/api/KeySharedPolicy.java x: 7 contributors (all time) y: 81 lines of code pulsar-client-api/src/main/java/org/apache/pulsar/client/api/Range.java x: 7 contributors (all time) y: 73 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/conf/ReaderConfigurationData.java x: 17 contributors (all time) y: 152 lines of code pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisSink.java x: 17 contributors (all time) y: 252 lines of code pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/KinesisSinkConfig.java x: 13 contributors (all time) y: 111 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/OpReadEntry.java x: 21 contributors (all time) y: 169 lines of code pulsar-broker-common/src/main/java/org/apache/pulsar/broker/resources/BaseResources.java x: 10 contributors (all time) y: 196 lines of code pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ClientBuilder.java x: 24 contributors (all time) y: 76 lines of code pulsar-broker-auth-oidc/src/main/java/org/apache/pulsar/broker/authentication/oidc/AuthenticationProviderOpenID.java x: 4 contributors (all time) y: 358 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/oauth2/protocol/TokenClient.java x: 9 contributors (all time) y: 94 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerStatsRecorderImpl.java x: 18 contributors (all time) y: 295 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdTopicPolicies.java x: 18 contributors (all time) y: 1606 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/intercept/BrokerInterceptorWithClassLoader.java x: 12 contributors (all time) y: 262 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/web/WebService.java x: 27 contributors (all time) y: 409 lines of code pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authorization/AuthorizationService.java x: 21 contributors (all time) y: 636 lines of code pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authorization/PulsarAuthorizationProvider.java x: 31 contributors (all time) y: 744 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/ClustersBase.java x: 22 contributors (all time) y: 997 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/PolicyName.java x: 10 contributors (all time) y: 37 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/MessagesImpl.java x: 7 contributors (all time) y: 58 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/PrometheusMetricsGenerator.java x: 25 contributors (all time) y: 448 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/lookup/TopicLookupBase.java x: 25 contributors (all time) y: 316 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace/OwnershipCache.java x: 25 contributors (all time) y: 204 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/util/KeyManagerProxy.java x: 5 contributors (all time) y: 115 lines of code pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerfClientUtils.java x: 13 contributors (all time) y: 92 lines of code pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/windowing/WindowContextImpl.java x: 6 contributors (all time) y: 131 lines of code pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/windowing/WindowFunctionExecutor.java x: 9 contributors (all time) y: 268 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractDispatcherSingleActiveConsumer.java x: 20 contributors (all time) y: 236 lines of code tiered-storage/file-system/src/main/java/org/apache/bookkeeper/mledger/offload/filesystem/impl/FileSystemManagedLedgerOffloader.java x: 13 contributors (all time) y: 354 lines of code testmocks/src/main/java/org/apache/bookkeeper/client/BookKeeperTestClient.java x: 6 contributors (all time) y: 99 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConnectionPool.java x: 23 contributors (all time) y: 394 lines of code pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyService.java x: 30 contributors (all time) y: 458 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/PartitionedProducerImpl.java x: 29 contributors (all time) y: 422 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdClusters.java x: 14 contributors (all time) y: 386 lines of code pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ReaderBuilder.java x: 13 contributors (all time) y: 39 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/ExtensibleLoadManagerImpl.java x: 8 contributors (all time) y: 953 lines of code pulsar-broker/src/main/java/org/apache/pulsar/zookeeper/LocalBookkeeperEnsemble.java x: 5 contributors (all time) y: 482 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/BinaryProtoLookupService.java x: 25 contributors (all time) y: 410 lines of code pulsar-broker/src/main/java/org/apache/pulsar/compaction/CompactorTool.java x: 18 contributors (all time) y: 149 lines of code deployment/terraform-ansible/deploy-pulsar.yaml x: 11 contributors (all time) y: 163 lines of code distribution/io/src/assemble/io.xml x: 20 contributors (all time) y: 59 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/offload/OffloaderUtils.java x: 12 contributors (all time) y: 114 lines of code pulsar-broker-common/src/main/java/org/apache/pulsar/broker/web/plugin/servlet/AdditionalServletUtils.java x: 7 contributors (all time) y: 105 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/plugin/EntryFilterProvider.java x: 8 contributors (all time) y: 208 lines of code pulsar-functions/localrun/src/main/java/org/apache/pulsar/functions/LocalRunner.java x: 19 contributors (all time) y: 704 lines of code pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/io/ConnectorUtils.java x: 9 contributors (all time) y: 135 lines of code pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/service/WorkerServiceLoader.java x: 8 contributors (all time) y: 107 lines of code pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/NamespacesImpl.java x: 38 contributors (all time) y: 1689 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/conf/ClientConfigurationData.java x: 38 contributors (all time) y: 395 lines of code pulsar-client-admin-api/src/main/java/org/apache/pulsar/common/policies/data/ConsumerStats.java x: 9 contributors (all time) y: 34 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/stats/ConsumerStatsImpl.java x: 12 contributors (all time) y: 87 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/AbstractDelayedDeliveryTracker.java x: 2 contributors (all time) y: 93 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/HashRangeAutoSplitStickyKeyConsumerSelector.java x: 11 contributors (all time) y: 144 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/HashRangeExclusiveStickyKeyConsumerSelector.java x: 8 contributors (all time) y: 142 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PendingAcksMap.java x: 1 contributors (all time) y: 249 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentStickyKeyDispatcherMultipleConsumers.java x: 14 contributors (all time) y: 164 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/TransactionMetadataStoreService.java x: 18 contributors (all time) y: 438 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdNamespaces.java x: 58 contributors (all time) y: 2346 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ReaderBuilderImpl.java x: 19 contributors (all time) y: 226 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/SchemasResourceBase.java x: 14 contributors (all time) y: 212 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/SchemasResource.java x: 16 contributors (all time) y: 326 lines of code pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/SchemasImpl.java x: 15 contributors (all time) y: 310 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/util/collections/OpenLongPairRangeSet.java x: 3 contributors (all time) y: 347 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/TableViewImpl.java x: 11 contributors (all time) y: 340 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/util/SecurityUtility.java x: 20 contributors (all time) y: 466 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/ExtensibleLoadManagerWrapper.java x: 3 contributors (all time) y: 110 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/store/TableViewLoadDataStoreImpl.java x: 3 contributors (all time) y: 223 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/AbstractCmdConsume.java x: 4 contributors (all time) y: 227 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerBase.java x: 17 contributors (all time) y: 130 lines of code pulsar-websocket/src/main/java/org/apache/pulsar/websocket/WebSocketService.java x: 23 contributors (all time) y: 264 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/NonPersistentTopics.java x: 41 contributors (all time) y: 599 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/TransactionAggregator.java x: 9 contributors (all time) y: 243 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/channel/ServiceUnitStateTableViewSyncer.java x: 1 contributors (all time) y: 219 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/store/LoadDataStore.java x: 2 contributors (all time) y: 24 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/LoadManager.java x: 17 contributors (all time) y: 77 lines of code pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch/client/opensearch/OpenSearchHighLevelRestClient.java x: 4 contributors (all time) y: 300 lines of code pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ConsumerInterceptor.java x: 8 contributors (all time) y: 19 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/ManagedLedgerFactory.java x: 16 contributors (all time) y: 50 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerOfflineBacklog.java x: 11 contributors (all time) y: 77 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/OpFindNewest.java x: 11 contributors (all time) y: 117 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ReadOnlyCursorImpl.java x: 8 contributors (all time) y: 50 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BacklogQuotaManager.java x: 28 contributors (all time) y: 216 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/pendingack/impl/MLPendingAckStore.java x: 10 contributors (all time) y: 440 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/pendingack/impl/PendingAckHandleImpl.java x: 16 contributors (all time) y: 942 lines of code pulsar-broker/src/main/java/org/apache/pulsar/compaction/AbstractTwoPhaseCompactor.java x: 2 contributors (all time) y: 373 lines of code pulsar-broker/src/main/java/org/apache/pulsar/compaction/EventTimeOrderCompactor.java x: 2 contributors (all time) y: 127 lines of code pulsar-broker/src/main/java/org/apache/pulsar/PulsarClusterMetadataSetup.java x: 28 contributors (all time) y: 409 lines of code pulsar-client-messagecrypto-bc/src/main/java/org/apache/pulsar/client/impl/crypto/MessageCryptoBc.java x: 12 contributors (all time) y: 427 lines of code pulsar-broker-auth-oidc/src/main/java/org/apache/pulsar/broker/authentication/oidc/JwksCache.java x: 2 contributors (all time) y: 189 lines of code pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authentication/AuthenticationProviderBasic.java x: 9 contributors (all time) y: 166 lines of code pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authentication/AuthenticationProviderToken.java x: 19 contributors (all time) y: 344 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/buffer/TransactionBuffer.java x: 12 contributors (all time) y: 33 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/SimpleLoadManagerImpl.java x: 25 contributors (all time) y: 1163 lines of code pulsar-broker/src/main/java/org/apache/pulsar/compaction/StrategicTwoPhaseCompactor.java x: 3 contributors (all time) y: 386 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PulsarChannelInitializer.java x: 21 contributors (all time) y: 109 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/PulsarAdminTool.java x: 32 contributors (all time) y: 253 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/PulsarClientTool.java x: 23 contributors (all time) y: 202 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/ClusterDataImpl.java x: 10 contributors (all time) y: 385 lines of code pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/WorkerServer.java x: 19 contributors (all time) y: 280 lines of code pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ServiceChannelInitializer.java x: 18 contributors (all time) y: 94 lines of code pulsar-websocket/src/main/java/org/apache/pulsar/websocket/service/ProxyServer.java x: 16 contributors (all time) y: 230 lines of code pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyServiceStarter.java x: 34 contributors (all time) y: 386 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/LookupService.java x: 11 contributors (all time) y: 32 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/transaction/TransactionCoordinatorClientImpl.java x: 14 contributors (all time) y: 226 lines of code pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/FunctionsImpl.java x: 17 contributors (all time) y: 644 lines of code pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/PackagesImpl.java x: 7 contributors (all time) y: 172 lines of code pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/SinksImpl.java x: 12 contributors (all time) y: 390 lines of code pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/SourcesImpl.java x: 11 contributors (all time) y: 312 lines of code pulsar-metadata/src/main/java/org/apache/pulsar/metadata/coordination/impl/LeaderElectionImpl.java x: 10 contributors (all time) y: 294 lines of code pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/BaseResource.java x: 16 contributors (all time) y: 309 lines of code pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/BookiesImpl.java x: 10 contributors (all time) y: 65 lines of code pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/TopicsImpl.java x: 52 contributors (all time) y: 2397 lines of code pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/TransactionsImpl.java x: 8 contributors (all time) y: 245 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdBase.java x: 15 contributors (all time) y: 83 lines of code pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/PulsarZooKeeperClient.java x: 8 contributors (all time) y: 1253 lines of code pulsar-opentelemetry/src/main/java/org/apache/pulsar/opentelemetry/OpenTelemetryAttributes.java x: 1 contributors (all time) y: 138 lines of code pulsar-io/jdbc/core/src/main/java/org/apache/pulsar/io/jdbc/BaseJdbcAutoSchemaSink.java x: 6 contributors (all time) y: 252 lines of code pulsar-websocket/src/main/java/org/apache/pulsar/websocket/ConsumerHandler.java x: 26 contributors (all time) y: 422 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/OpenTelemetryTopicStats.java x: 1 contributors (all time) y: 343 lines of code pulsar-transaction/coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/impl/MLTransactionMetadataStore.java x: 13 contributors (all time) y: 513 lines of code pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/LocalMemoryMetadataStore.java x: 15 contributors (all time) y: 212 lines of code pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/RocksdbMetadataStore.java x: 15 contributors (all time) y: 521 lines of code pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ContextImpl.java x: 27 contributors (all time) y: 627 lines of code pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/sink/PulsarSink.java x: 25 contributors (all time) y: 290 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/transaction/TransactionImpl.java x: 9 contributors (all time) y: 212 lines of code pulsar-testclient/src/main/java/org/apache/pulsar/testclient/BrokerMonitor.java x: 13 contributors (all time) y: 420 lines of code pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/RuntimeUtils.java x: 22 contributors (all time) y: 463 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/EntryImpl.java x: 12 contributors (all time) y: 168 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedCursorContainer.java x: 15 contributors (all time) y: 292 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/TransactionsBase.java x: 10 contributors (all time) y: 522 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Subscription.java x: 19 contributors (all time) y: 74 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/pendingack/PendingAckStore.java x: 4 contributors (all time) y: 17 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/transaction/pendingack/impl/MLPendingAckReplyCallBack.java x: 6 contributors (all time) y: 95 lines of code pulsar-transaction/coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/impl/MLTransactionLogImpl.java x: 11 contributors (all time) y: 333 lines of code pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/EtcdMetadataStore.java x: 8 contributors (all time) y: 439 lines of code pulsar-metadata/src/main/java/org/apache/pulsar/metadata/bookkeeper/BKCluster.java x: 8 contributors (all time) y: 303 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/data/BrokerLoadData.java x: 4 contributors (all time) y: 190 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/manager/UnloadManager.java x: 5 contributors (all time) y: 183 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/BookKeeperClientFactoryImpl.java x: 22 contributors (all time) y: 203 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/OpenTelemetryConsumerStats.java x: 1 contributors (all time) y: 97 lines of code pulsar-broker/src/main/java/org/apache/pulsar/utils/auth/tokens/TokensCliUtils.java x: 14 contributors (all time) y: 267 lines of code pulsar-common/src/main/java/org/apache/pulsar/policies/data/loadbalancer/LocalBrokerData.java x: 18 contributors (all time) y: 384 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/nar/NarClassLoader.java x: 15 contributors (all time) y: 152 lines of code pulsar-client-admin-api/src/main/java/org/apache/pulsar/client/admin/Topics.java x: 26 contributors (all time) y: 680 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/FunctionsBase.java x: 21 contributors (all time) y: 744 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/SinksBase.java x: 16 contributors (all time) y: 539 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/SourcesBase.java x: 17 contributors (all time) y: 491 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/ResourceQuotas.java x: 8 contributors (all time) y: 137 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v3/Packages.java x: 4 contributors (all time) y: 214 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/AvroSchemaBasedCompatibilityCheck.java x: 12 contributors (all time) y: 72 lines of code pulsar-broker-common/src/main/java/org/apache/pulsar/broker/resources/NamespaceResources.java x: 20 contributors (all time) y: 307 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/protocol/PulsarDecoder.java x: 16 contributors (all time) y: 587 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdSinks.java x: 28 contributors (all time) y: 709 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdSources.java x: 25 contributors (all time) y: 639 lines of code pulsar-websocket/src/main/java/org/apache/pulsar/websocket/service/WebSocketProxyConfiguration.java x: 24 contributors (all time) y: 201 lines of code pulsar-broker/src/main/java/org/apache/pulsar/common/naming/NamespaceBundleFactory.java x: 18 contributors (all time) y: 330 lines of code pulsar-testclient/src/main/java/org/apache/pulsar/testclient/LoadSimulationController.java x: 12 contributors (all time) y: 532 lines of code pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceConsumer.java x: 38 contributors (all time) y: 473 lines of code pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceProducer.java x: 41 contributors (all time) y: 659 lines of code pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceReader.java x: 27 contributors (all time) y: 184 lines of code pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceTopicListArguments.java x: 2 contributors (all time) y: 43 lines of code pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceTransaction.java x: 12 contributors (all time) y: 556 lines of code pulsar-broker-common/src/main/java/org/apache/pulsar/broker/web/JettyRequestLogFactory.java x: 3 contributors (all time) y: 168 lines of code pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/worker/WorkerConfig.java x: 31 contributors (all time) y: 867 lines of code tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/impl/BlobStoreBackedReadHandleImplV2.java x: 10 contributors (all time) y: 295 lines of code pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaAbstractSource.java x: 18 contributors (all time) y: 270 lines of code pulsar-broker/src/main/java/org/apache/pulsar/PulsarBrokerStarter.java x: 26 contributors (all time) y: 308 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/util/collections/ConcurrentBitSet.java x: 7 contributors (all time) y: 371 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/resourcegroup/ResourceGroupConfigListener.java x: 6 contributors (all time) y: 143 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/resourcegroup/ResourceGroupService.java x: 10 contributors (all time) y: 585 lines of code pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/JavaInstanceStarter.java x: 16 contributors (all time) y: 409 lines of code pulsar-broker/src/main/java/org/apache/pulsar/client/impl/RawReaderImpl.java x: 27 contributors (all time) y: 225 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CliCommand.java x: 16 contributors (all time) y: 122 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdBrokers.java x: 16 contributors (all time) y: 140 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/shell/PulsarShell.java x: 3 contributors (all time) y: 514 lines of code pulsar-websocket/src/main/java/org/apache/pulsar/websocket/ProducerHandler.java x: 19 contributors (all time) y: 435 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/AutoClusterFailover.java x: 6 contributors (all time) y: 314 lines of code pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionActioner.java x: 19 contributors (all time) y: 620 lines of code pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/FunctionRuntimeManager.java x: 25 contributors (all time) y: 773 lines of code pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/PulsarWorkerService.java x: 19 contributors (all time) y: 544 lines of code pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/ComponentImpl.java x: 25 contributors (all time) y: 1601 lines of code pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/FunctionsImpl.java x: 24 contributors (all time) y: 654 lines of code pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/SinksImpl.java x: 19 contributors (all time) y: 660 lines of code pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/SourcesImpl.java x: 19 contributors (all time) y: 606 lines of code pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/thread/ThreadRuntime.java x: 15 contributors (all time) y: 274 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/util/collections/BitSetRecyclable.java x: 5 contributors (all time) y: 524 lines of code pulsar-common/src/main/java/org/apache/pulsar/policies/data/loadbalancer/LoadReport.java x: 7 contributors (all time) y: 380 lines of code docker/pulsar/scripts/apply-config-from-env.py x: 12 contributors (all time) y: 56 lines of code pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/state/BKStateStoreImpl.java x: 6 contributors (all time) y: 168 lines of code pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/TopicPoliciesImpl.java x: 11 contributors (all time) y: 1074 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/intercept/BrokerInterceptors.java x: 13 contributors (all time) y: 230 lines of code pulsar-io/alluxio/src/main/java/org/apache/pulsar/io/alluxio/sink/AlluxioSink.java x: 3 contributors (all time) y: 280 lines of code pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io/dynamodb/DynamoDBSourceConfig.java x: 6 contributors (all time) y: 180 lines of code pulsar-io/jdbc/core/src/main/java/org/apache/pulsar/io/jdbc/JdbcAbstractSink.java x: 6 contributors (all time) y: 320 lines of code pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaSourceConfig.java x: 14 contributors (all time) y: 133 lines of code pulsar-io/mongo/src/main/java/org/apache/pulsar/io/mongodb/MongoSink.java x: 8 contributors (all time) y: 161 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1/PersistentTopics.java x: 47 contributors (all time) y: 1063 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/util/keystoretls/KeyStoreSSLContext.java x: 9 contributors (all time) y: 287 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1/NonPersistentTopics.java x: 29 contributors (all time) y: 264 lines of code pulsar-client-auth-sasl/src/main/java/org/apache/pulsar/client/impl/auth/AuthenticationSasl.java x: 8 contributors (all time) y: 269 lines of code pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authorization/MultiRolesTokenAuthorizationProvider.java x: 13 contributors (all time) y: 250 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v1/Namespaces.java x: 40 contributors (all time) y: 1651 lines of code pulsar-broker-common/src/main/java/org/apache/pulsar/broker/resources/ClusterResources.java x: 7 contributors (all time) y: 191 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/auth/AuthenticationDataTls.java x: 10 contributors (all time) y: 121 lines of code pulsar-metadata/src/main/java/org/apache/pulsar/metadata/bookkeeper/PulsarLedgerManager.java x: 5 contributors (all time) y: 383 lines of code pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch/ElasticSearchSink.java x: 16 contributors (all time) y: 379 lines of code pulsar-metadata/src/main/java/org/apache/pulsar/metadata/bookkeeper/PulsarLedgerUnderreplicationManager.java x: 6 contributors (all time) y: 917 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/util/collections/ConcurrentLongHashMap.java x: 10 contributors (all time) y: 472 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/util/collections/ConcurrentLongLongPairHashMap.java x: 4 contributors (all time) y: 510 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/util/collections/ConcurrentLongPairSet.java x: 11 contributors (all time) y: 525 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/LinuxBrokerHostUsageImpl.java x: 15 contributors (all time) y: 127 lines of code pulsar-metadata/src/main/java/org/apache/pulsar/metadata/bookkeeper/LongHierarchicalLedgerRangeIterator.java x: 4 contributors (all time) y: 122 lines of code pulsar-metadata/src/main/java/org/apache/pulsar/metadata/bookkeeper/PulsarRegistrationManager.java x: 5 contributors (all time) y: 331 lines of code pulsar-functions/instance/src/main/python/python_instance.py x: 11 contributors (all time) y: 482 lines of code pulsar-io/core/src/main/java/org/apache/pulsar/io/core/PushSource.java x: 10 contributors (all time) y: 12 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PackagesBase.java x: 5 contributors (all time) y: 169 lines of code pulsar-package-management/core/src/main/java/org/apache/pulsar/packages/management/core/impl/PackagesManagementImpl.java x: 5 contributors (all time) y: 221 lines of code tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/impl/BlockAwareSegmentInputStreamImpl.java x: 10 contributors (all time) y: 253 lines of code pulsar-websocket/src/main/java/org/apache/pulsar/websocket/ReaderHandler.java x: 16 contributors (all time) y: 286 lines of code pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/auth/KubernetesSecretsTokenAuthProvider.java x: 13 contributors (all time) y: 330 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/bucket/MutableBucket.java x: 2 contributors (all time) y: 175 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/MessageIdImpl.java x: 14 contributors (all time) y: 139 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/Functions.java x: 12 contributors (all time) y: 287 lines of code pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/WorkerImpl.java x: 13 contributors (all time) y: 275 lines of code pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/v2/FunctionsApiV2Resource.java x: 7 contributors (all time) y: 284 lines of code pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/v3/FunctionsApiV3Resource.java x: 13 contributors (all time) y: 377 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ZeroQueueConsumerImpl.java x: 18 contributors (all time) y: 164 lines of code pulsar-function-go/pb/Function.pb.go x: 7 contributors (all time) y: 2010 lines of code pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/schema/KafkaConnectData.java x: 4 contributors (all time) y: 333 lines of code pulsar-functions/instance/src/main/python/contextimpl.py x: 12 contributors (all time) y: 179 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/AutoConsumeSchema.java x: 17 contributors (all time) y: 305 lines of code pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/PulsarSourceConfig.java x: 9 contributors (all time) y: 18 lines of code pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/kubernetes/BasicKubernetesManifestCustomizer.java x: 10 contributors (all time) y: 214 lines of code pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch/client/RestClient.java x: 3 contributors (all time) y: 214 lines of code pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/WorkerUtils.java x: 16 contributors (all time) y: 367 lines of code pulsar-transaction/coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/impl/TxnLogBufferedWriter.java x: 5 contributors (all time) y: 410 lines of code pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/Worker.java x: 17 contributors (all time) y: 93 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerStatsRecorderImpl.java x: 18 contributors (all time) y: 278 lines of code pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/SchedulerManager.java x: 15 contributors (all time) y: 690 lines of code pulsar-io/http/src/main/java/org/apache/pulsar/io/http/JsonConverter.java x: 1 contributors (all time) y: 206 lines of code pulsar-client-api/src/main/java/org/apache/pulsar/client/internal/DefaultImplementation.java x: 18 contributors (all time) y: 18 lines of code pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/batch/BatchSourceExecutor.java x: 5 contributors (all time) y: 269 lines of code pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/process/ProcessRuntime.java x: 12 contributors (all time) y: 354 lines of code pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/WorkerService.java x: 16 contributors (all time) y: 32 lines of code pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch/JsonConverter.java x: 5 contributors (all time) y: 206 lines of code tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/impl/OffloadIndexBlockImpl.java x: 11 contributors (all time) y: 278 lines of code tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/impl/OffloadIndexBlockV2Impl.java x: 3 contributors (all time) y: 295 lines of code pulsar-function-go/pf/stats.go x: 7 contributors (all time) y: 300 lines of code pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/node/AbstractConfigurationProvider.java x: 3 contributors (all time) y: 471 lines of code pulsar-function-go/pb/InstanceCommunication.pb.go x: 4 contributors (all time) y: 1022 lines of code
4990.0
lines of code
  min: 1.0
  average: 113.8
  25th percentile: 10.0
  median: 36.0
  75th percentile: 97.0
  max: 4990.0
0 111.0
contributors (all time)
min: 1.0 | average: 6.23 | 25th percentile: 2.0 | median: 3.0 | 75th percentile: 7.0 | max: 111.0

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

pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractTopic.java x: 3 commits (30d) y: 1176 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/PolicyHierarchyValue.java x: 1 commits (30d) y: 54 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedCursorImpl.java x: 2 commits (30d) y: 3144 lines of code pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/AbstractKafkaConnectSource.java x: 2 commits (30d) y: 260 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/GeoReplicationProducerImpl.java x: 1 commits (30d) y: 189 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/HandlerState.java x: 1 commits (30d) y: 70 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java x: 3 commits (30d) y: 2134 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarClientImplementationBindingImpl.java x: 1 commits (30d) y: 267 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java x: 5 commits (30d) y: 3094 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/metrics/ObserverGauge.java x: 1 commits (30d) y: 79 lines of code pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java x: 5 commits (30d) y: 3475 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/TopicPolicies.java x: 1 commits (30d) y: 143 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/AckSetState.java x: 1 commits (30d) y: 9 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java x: 2 commits (30d) y: 3837 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/NamespacesBase.java x: 2 commits (30d) y: 2569 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java x: 3 commits (30d) y: 4990 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v3/Transactions.java x: 1 commits (30d) y: 452 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/bucket/BookkeeperBucketSnapshotStorage.java x: 1 commits (30d) y: 244 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace/NamespaceService.java x: 2 commits (30d) y: 1456 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractBaseDispatcher.java x: 1 commits (30d) y: 403 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ConsumerHashAssignmentsSnapshot.java x: 1 commits (30d) y: 161 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/SystemTopicBasedTopicPoliciesService.java x: 1 commits (30d) y: 641 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentMessageExpiryMonitor.java x: 1 commits (30d) y: 223 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java x: 5 commits (30d) y: 3740 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/BookkeeperSchemaStorage.java x: 1 commits (30d) y: 654 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/SchemaRegistryServiceImpl.java x: 1 commits (30d) y: 603 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/web/PulsarWebResource.java x: 1 commits (30d) y: 1107 lines of code pulsar-broker/src/main/java/org/apache/pulsar/compaction/CompactedTopicImpl.java x: 3 commits (30d) y: 338 lines of code pulsar-broker/src/main/java/org/apache/pulsar/compaction/PulsarTopicCompactionService.java x: 1 commits (30d) y: 102 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ControlledClusterFailover.java x: 1 commits (30d) y: 210 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicsConsumerImpl.java x: 1 commits (30d) y: 1405 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarClientImpl.java x: 2 commits (30d) y: 1119 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/util/collections/GrowableArrayBlockingQueue.java x: 1 commits (30d) y: 364 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/TransactionMetaStoreHandler.java x: 1 commits (30d) y: 736 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/rest/TopicsBase.java x: 1 commits (30d) y: 699 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/ManagedLedger.java x: 1 commits (30d) y: 123 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/TenantsBase.java x: 1 commits (30d) y: 317 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/AdminResource.java x: 1 commits (30d) y: 837 lines of code pulsar-client-admin-api/src/main/java/org/apache/pulsar/common/policies/data/BacklogQuota.java x: 1 commits (30d) y: 32 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/channel/ServiceUnitStateChannelImpl.java x: 3 commits (30d) y: 1699 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java x: 1 commits (30d) y: 1759 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/BrokersBase.java x: 1 commits (30d) y: 478 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/conf/ConsumerConfigurationData.java x: 1 commits (30d) y: 377 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/OffloadPoliciesImpl.java x: 1 commits (30d) y: 539 lines of code pulsar-metadata/src/main/java/org/apache/pulsar/metadata/tableview/impl/MetadataStoreTableViewImpl.java x: 1 commits (30d) y: 283 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ClientCnx.java x: 2 commits (30d) y: 1279 lines of code pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/JavaInstanceRunnable.java x: 1 commits (30d) y: 963 lines of code pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/SinkConfigUtils.java x: 1 commits (30d) y: 674 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Consumer.java x: 1 commits (30d) y: 1024 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerImpl.java x: 1 commits (30d) y: 2716 lines of code testmocks/src/main/java/org/apache/zookeeper/MockZooKeeperSession.java x: 1 commits (30d) y: 334 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerBuilderImpl.java x: 1 commits (30d) y: 299 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/protocol/Commands.java x: 1 commits (30d) y: 1733 lines of code pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/DirectProxyHandler.java x: 1 commits (30d) y: 418 lines of code pulsar-client-api/src/main/java/org/apache/pulsar/client/api/PulsarClientException.java x: 1 commits (30d) y: 506 lines of code
4990.0
lines of code
  min: 8.0
  average: 649.83
  25th percentile: 77.0
  median: 257.0
  75th percentile: 717.5
  max: 4990.0
0 5.0
commits (30d)
min: 1.0 | average: 1.3 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 5.0

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

pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractTopic.java x: 3 contributors (30d) y: 1176 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/PolicyHierarchyValue.java x: 1 contributors (30d) y: 54 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedCursorImpl.java x: 1 contributors (30d) y: 3144 lines of code pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/AbstractKafkaConnectSource.java x: 2 contributors (30d) y: 260 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/GeoReplicationProducerImpl.java x: 1 contributors (30d) y: 189 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/HandlerState.java x: 1 contributors (30d) y: 70 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java x: 2 contributors (30d) y: 2134 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarClientImplementationBindingImpl.java x: 1 contributors (30d) y: 267 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java x: 3 contributors (30d) y: 3094 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/metrics/ObserverGauge.java x: 1 contributors (30d) y: 79 lines of code pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java x: 5 contributors (30d) y: 3475 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/TopicPolicies.java x: 1 contributors (30d) y: 143 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/AckSetState.java x: 1 contributors (30d) y: 9 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java x: 2 contributors (30d) y: 3837 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/NamespacesBase.java x: 2 contributors (30d) y: 2569 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java x: 3 contributors (30d) y: 4990 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v3/Transactions.java x: 1 contributors (30d) y: 452 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/bucket/BookkeeperBucketSnapshotStorage.java x: 1 contributors (30d) y: 244 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace/NamespaceService.java x: 2 contributors (30d) y: 1456 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractBaseDispatcher.java x: 1 contributors (30d) y: 403 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ConsumerHashAssignmentsSnapshot.java x: 1 contributors (30d) y: 161 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/SystemTopicBasedTopicPoliciesService.java x: 1 contributors (30d) y: 641 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentMessageExpiryMonitor.java x: 1 contributors (30d) y: 223 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java x: 2 contributors (30d) y: 3740 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/BookkeeperSchemaStorage.java x: 1 contributors (30d) y: 654 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/SchemaRegistryServiceImpl.java x: 1 contributors (30d) y: 603 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/web/PulsarWebResource.java x: 1 contributors (30d) y: 1107 lines of code pulsar-broker/src/main/java/org/apache/pulsar/compaction/CompactedTopicImpl.java x: 2 contributors (30d) y: 338 lines of code pulsar-broker/src/main/java/org/apache/pulsar/compaction/PulsarTopicCompactionService.java x: 1 contributors (30d) y: 102 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ControlledClusterFailover.java x: 1 contributors (30d) y: 210 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicsConsumerImpl.java x: 1 contributors (30d) y: 1405 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarClientImpl.java x: 2 contributors (30d) y: 1119 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/util/collections/GrowableArrayBlockingQueue.java x: 1 contributors (30d) y: 364 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/TransactionMetaStoreHandler.java x: 1 contributors (30d) y: 736 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/rest/TopicsBase.java x: 1 contributors (30d) y: 699 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/ManagedLedger.java x: 1 contributors (30d) y: 123 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/TenantsBase.java x: 1 contributors (30d) y: 317 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/AdminResource.java x: 1 contributors (30d) y: 837 lines of code pulsar-client-admin-api/src/main/java/org/apache/pulsar/common/policies/data/BacklogQuota.java x: 1 contributors (30d) y: 32 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/channel/ServiceUnitStateChannelImpl.java x: 1 contributors (30d) y: 1699 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java x: 1 contributors (30d) y: 1759 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/BrokersBase.java x: 1 contributors (30d) y: 478 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/conf/ConsumerConfigurationData.java x: 1 contributors (30d) y: 377 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/OffloadPoliciesImpl.java x: 1 contributors (30d) y: 539 lines of code pulsar-metadata/src/main/java/org/apache/pulsar/metadata/tableview/impl/MetadataStoreTableViewImpl.java x: 1 contributors (30d) y: 283 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ClientCnx.java x: 2 contributors (30d) y: 1279 lines of code pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/JavaInstanceRunnable.java x: 1 contributors (30d) y: 963 lines of code pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/SinkConfigUtils.java x: 1 contributors (30d) y: 674 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Consumer.java x: 1 contributors (30d) y: 1024 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerImpl.java x: 1 contributors (30d) y: 2716 lines of code testmocks/src/main/java/org/apache/zookeeper/MockZooKeeperSession.java x: 1 contributors (30d) y: 334 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerBuilderImpl.java x: 1 contributors (30d) y: 299 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/protocol/Commands.java x: 1 contributors (30d) y: 1733 lines of code pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/DirectProxyHandler.java x: 1 contributors (30d) y: 418 lines of code pulsar-client-api/src/main/java/org/apache/pulsar/client/api/PulsarClientException.java x: 1 contributors (30d) y: 506 lines of code
4990.0
lines of code
  min: 8.0
  average: 649.83
  25th percentile: 77.0
  median: 257.0
  75th percentile: 717.5
  max: 4990.0
0 5.0
contributors (30d)
min: 1.0 | average: 1.19 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 5.0

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

pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractTopic.java x: 6 commits (90d) y: 1176 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/PolicyHierarchyValue.java x: 1 commits (90d) y: 54 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedCursorImpl.java x: 5 commits (90d) y: 3144 lines of code pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/AbstractKafkaConnectSource.java x: 3 commits (90d) y: 260 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/GeoReplicationProducerImpl.java x: 2 commits (90d) y: 189 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/HandlerState.java x: 1 commits (90d) y: 70 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java x: 10 commits (90d) y: 2134 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarClientImplementationBindingImpl.java x: 1 commits (90d) y: 267 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java x: 11 commits (90d) y: 3094 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/metrics/ObserverGauge.java x: 1 commits (90d) y: 79 lines of code pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java x: 8 commits (90d) y: 3475 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/TopicPolicies.java x: 2 commits (90d) y: 143 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/stats/NonPersistentTopicStatsImpl.java x: 1 commits (90d) y: 142 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/AckSetState.java x: 1 commits (90d) y: 9 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java x: 7 commits (90d) y: 3837 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/NamespacesBase.java x: 3 commits (90d) y: 2569 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java x: 5 commits (90d) y: 4990 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v3/Transactions.java x: 1 commits (90d) y: 452 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/bucket/BookkeeperBucketSnapshotStorage.java x: 1 commits (90d) y: 244 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace/NamespaceService.java x: 3 commits (90d) y: 1456 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractBaseDispatcher.java x: 3 commits (90d) y: 403 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ConsumerHashAssignmentsSnapshot.java x: 1 commits (90d) y: 161 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/SystemTopicBasedTopicPoliciesService.java x: 2 commits (90d) y: 641 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentMessageExpiryMonitor.java x: 2 commits (90d) y: 223 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java x: 10 commits (90d) y: 3740 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/BookkeeperSchemaStorage.java x: 1 commits (90d) y: 654 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/SchemaRegistryServiceImpl.java x: 1 commits (90d) y: 603 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/web/PulsarWebResource.java x: 2 commits (90d) y: 1107 lines of code pulsar-broker/src/main/java/org/apache/pulsar/compaction/CompactedTopicImpl.java x: 3 commits (90d) y: 338 lines of code pulsar-broker/src/main/java/org/apache/pulsar/compaction/PulsarTopicCompactionService.java x: 1 commits (90d) y: 102 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ControlledClusterFailover.java x: 1 commits (90d) y: 210 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicsConsumerImpl.java x: 1 commits (90d) y: 1405 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarClientImpl.java x: 3 commits (90d) y: 1119 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/util/collections/GrowableArrayBlockingQueue.java x: 2 commits (90d) y: 364 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/TransactionMetaStoreHandler.java x: 1 commits (90d) y: 736 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/rest/TopicsBase.java x: 1 commits (90d) y: 699 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/ManagedLedger.java x: 1 commits (90d) y: 123 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentMessageFinder.java x: 2 commits (90d) y: 124 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/HealthChecker.java x: 2 commits (90d) y: 257 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/TenantsBase.java x: 1 commits (90d) y: 317 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/AdminResource.java x: 3 commits (90d) y: 837 lines of code pulsar-client-admin-api/src/main/java/org/apache/pulsar/common/policies/data/BacklogQuota.java x: 1 commits (90d) y: 32 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/channel/ServiceUnitStateChannelImpl.java x: 3 commits (90d) y: 1699 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java x: 3 commits (90d) y: 1759 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/BrokersBase.java x: 1 commits (90d) y: 478 lines of code pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ConsumerBuilder.java x: 2 commits (90d) y: 77 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/conf/ConsumerConfigurationData.java x: 1 commits (90d) y: 377 lines of code pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/PulsarOffsetBackingStore.java x: 1 commits (90d) y: 223 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/OffloadPoliciesImpl.java x: 2 commits (90d) y: 539 lines of code pulsar-metadata/src/main/java/org/apache/pulsar/metadata/tableview/impl/MetadataStoreTableViewImpl.java x: 1 commits (90d) y: 283 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ClientCnx.java x: 5 commits (90d) y: 1279 lines of code pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/JavaInstanceRunnable.java x: 2 commits (90d) y: 963 lines of code pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/SinkConfigUtils.java x: 1 commits (90d) y: 674 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Consumer.java x: 3 commits (90d) y: 1024 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Producer.java x: 3 commits (90d) y: 740 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerImpl.java x: 7 commits (90d) y: 2716 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/naming/Metadata.java x: 2 commits (90d) y: 21 lines of code testmocks/src/main/java/org/apache/zookeeper/MockZooKeeper.java x: 2 commits (90d) y: 1034 lines of code testmocks/src/main/java/org/apache/zookeeper/MockZooKeeperSession.java x: 2 commits (90d) y: 334 lines of code pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ProducerBuilder.java x: 2 commits (90d) y: 52 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerBuilderImpl.java x: 1 commits (90d) y: 299 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/protocol/Commands.java x: 3 commits (90d) y: 1733 lines of code pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/DirectProxyHandler.java x: 1 commits (90d) y: 418 lines of code pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyConnection.java x: 2 commits (90d) y: 693 lines of code pulsar-client-api/src/main/java/org/apache/pulsar/client/api/PulsarClientException.java x: 2 commits (90d) y: 506 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentSubscription.java x: 2 commits (90d) y: 441 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumers.java x: 4 commits (90d) y: 1168 lines of code pulsar-function-go/pf/instance.go x: 2 commits (90d) y: 622 lines of code pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/json/JsonConverter.java x: 1 commits (90d) y: 194 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/EntryCountEstimator.java x: 3 commits (90d) y: 103 lines of code pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/KafkaConnectSink.java x: 1 commits (90d) y: 435 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentSubscription.java x: 1 commits (90d) y: 1302 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/NamespaceStatsAggregator.java x: 1 commits (90d) y: 510 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/TopicStats.java x: 1 commits (90d) y: 519 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentReplicator.java x: 3 commits (90d) y: 575 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/MessageDeduplication.java x: 2 commits (90d) y: 558 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PulsarMetadataEventSynchronizer.java x: 2 commits (90d) y: 281 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/BatchMessageContainerImpl.java x: 3 commits (90d) y: 294 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java x: 4 commits (90d) y: 3241 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/ShadowReplicator.java x: 2 commits (90d) y: 89 lines of code tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/impl/BlobStoreManagedLedgerOffloader.java x: 1 commits (90d) y: 636 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/qos/AsyncTokenBucketBuilder.java x: 2 commits (90d) y: 19 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumersClassic.java x: 2 commits (90d) y: 1050 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherSingleActiveConsumer.java x: 3 commits (90d) y: 501 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdPersistentTopics.java x: 1 commits (90d) y: 559 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdTopics.java x: 1 commits (90d) y: 2527 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractReplicator.java x: 1 commits (90d) y: 397 lines of code pulsar-common/src/main/proto/PulsarApi.proto x: 1 commits (90d) y: 928 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerBase.java x: 1 commits (90d) y: 1092 lines of code pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/ZKMetadataStore.java x: 3 commits (90d) y: 565 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/ModularLoadManagerImpl.java x: 1 commits (90d) y: 902 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ShadowManagedLedgerImpl.java x: 2 commits (90d) y: 321 lines of code pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyConfiguration.java x: 2 commits (90d) y: 879 lines of code pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/WebServer.java x: 1 commits (90d) y: 373 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/Namespaces.java x: 1 commits (90d) y: 2968 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/PersistentTopics.java x: 1 commits (90d) y: 4831 lines of code
4990.0
lines of code
  min: 4.0
  average: 498.78
  25th percentile: 69.0
  median: 213.5
  75th percentile: 553.25
  max: 4990.0
0 11.0
commits (90d)
min: 1.0 | average: 1.66 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 11.0

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

pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractTopic.java x: 5 contributors (90d) y: 1176 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/PolicyHierarchyValue.java x: 1 contributors (90d) y: 54 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedCursorImpl.java x: 3 contributors (90d) y: 3144 lines of code pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/AbstractKafkaConnectSource.java x: 3 contributors (90d) y: 260 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/GeoReplicationProducerImpl.java x: 1 contributors (90d) y: 189 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/HandlerState.java x: 1 contributors (90d) y: 70 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java x: 6 contributors (90d) y: 2134 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarClientImplementationBindingImpl.java x: 1 contributors (90d) y: 267 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java x: 7 contributors (90d) y: 3094 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/metrics/ObserverGauge.java x: 1 contributors (90d) y: 79 lines of code pulsar-broker-common/src/main/java/org/apache/pulsar/broker/ServiceConfiguration.java x: 8 contributors (90d) y: 3475 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/TopicPolicies.java x: 2 contributors (90d) y: 143 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/stats/NonPersistentTopicStatsImpl.java x: 1 contributors (90d) y: 142 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/AckSetState.java x: 1 contributors (90d) y: 9 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java x: 4 contributors (90d) y: 3837 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/NamespacesBase.java x: 3 contributors (90d) y: 2569 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java x: 5 contributors (90d) y: 4990 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v3/Transactions.java x: 1 contributors (90d) y: 452 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/delayed/bucket/BookkeeperBucketSnapshotStorage.java x: 1 contributors (90d) y: 244 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/namespace/NamespaceService.java x: 2 contributors (90d) y: 1456 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractBaseDispatcher.java x: 2 contributors (90d) y: 403 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ConsumerHashAssignmentsSnapshot.java x: 1 contributors (90d) y: 161 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/SystemTopicBasedTopicPoliciesService.java x: 2 contributors (90d) y: 641 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentMessageExpiryMonitor.java x: 2 contributors (90d) y: 223 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java x: 6 contributors (90d) y: 3740 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/BookkeeperSchemaStorage.java x: 1 contributors (90d) y: 654 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/schema/SchemaRegistryServiceImpl.java x: 1 contributors (90d) y: 603 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/web/PulsarWebResource.java x: 1 contributors (90d) y: 1107 lines of code pulsar-broker/src/main/java/org/apache/pulsar/compaction/CompactedTopicImpl.java x: 2 contributors (90d) y: 338 lines of code pulsar-broker/src/main/java/org/apache/pulsar/compaction/PulsarTopicCompactionService.java x: 1 contributors (90d) y: 102 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ControlledClusterFailover.java x: 1 contributors (90d) y: 210 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicsConsumerImpl.java x: 1 contributors (90d) y: 1405 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/PulsarClientImpl.java x: 3 contributors (90d) y: 1119 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/util/collections/GrowableArrayBlockingQueue.java x: 2 contributors (90d) y: 364 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/TransactionMetaStoreHandler.java x: 1 contributors (90d) y: 736 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/rest/TopicsBase.java x: 1 contributors (90d) y: 699 lines of code managed-ledger/src/main/java/org/apache/bookkeeper/mledger/ManagedLedger.java x: 1 contributors (90d) y: 123 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentMessageFinder.java x: 2 contributors (90d) y: 124 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/TenantsBase.java x: 1 contributors (90d) y: 317 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/AdminResource.java x: 3 contributors (90d) y: 837 lines of code pulsar-client-admin-api/src/main/java/org/apache/pulsar/common/policies/data/BacklogQuota.java x: 1 contributors (90d) y: 32 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/channel/ServiceUnitStateChannelImpl.java x: 1 contributors (90d) y: 1699 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java x: 2 contributors (90d) y: 1759 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/BrokersBase.java x: 1 contributors (90d) y: 478 lines of code pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ConsumerBuilder.java x: 2 contributors (90d) y: 77 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/conf/ConsumerConfigurationData.java x: 1 contributors (90d) y: 377 lines of code pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/PulsarOffsetBackingStore.java x: 1 contributors (90d) y: 223 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/policies/data/OffloadPoliciesImpl.java x: 1 contributors (90d) y: 539 lines of code pulsar-metadata/src/main/java/org/apache/pulsar/metadata/tableview/impl/MetadataStoreTableViewImpl.java x: 1 contributors (90d) y: 283 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ClientCnx.java x: 3 contributors (90d) y: 1279 lines of code pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/JavaInstanceRunnable.java x: 1 contributors (90d) y: 963 lines of code pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/SinkConfigUtils.java x: 1 contributors (90d) y: 674 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Consumer.java x: 3 contributors (90d) y: 1024 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Producer.java x: 3 contributors (90d) y: 740 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerImpl.java x: 5 contributors (90d) y: 2716 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/naming/Metadata.java x: 2 contributors (90d) y: 21 lines of code testmocks/src/main/java/org/apache/zookeeper/MockZooKeeper.java x: 1 contributors (90d) y: 1034 lines of code testmocks/src/main/java/org/apache/zookeeper/MockZooKeeperSession.java x: 1 contributors (90d) y: 334 lines of code pulsar-client-api/src/main/java/org/apache/pulsar/client/api/ProducerBuilder.java x: 2 contributors (90d) y: 52 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerBuilderImpl.java x: 1 contributors (90d) y: 299 lines of code pulsar-common/src/main/java/org/apache/pulsar/common/protocol/Commands.java x: 1 contributors (90d) y: 1733 lines of code pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/DirectProxyHandler.java x: 1 contributors (90d) y: 418 lines of code pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyConnection.java x: 2 contributors (90d) y: 693 lines of code pulsar-client-api/src/main/java/org/apache/pulsar/client/api/PulsarClientException.java x: 1 contributors (90d) y: 506 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentSubscription.java x: 2 contributors (90d) y: 441 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumers.java x: 4 contributors (90d) y: 1168 lines of code pulsar-function-go/pf/instance.go x: 2 contributors (90d) y: 622 lines of code pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/KafkaConnectSink.java x: 1 contributors (90d) y: 435 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentSubscription.java x: 1 contributors (90d) y: 1302 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/stats/prometheus/TopicStats.java x: 1 contributors (90d) y: 519 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerBuilderImpl.java x: 2 contributors (90d) y: 539 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentReplicator.java x: 3 contributors (90d) y: 575 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/MessageDeduplication.java x: 2 contributors (90d) y: 558 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentTopic.java x: 2 contributors (90d) y: 1024 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/BatchMessageContainerImpl.java x: 3 contributors (90d) y: 294 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java x: 3 contributors (90d) y: 3241 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/GeoPersistentReplicator.java x: 2 contributors (90d) y: 182 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/ShadowReplicator.java x: 2 contributors (90d) y: 89 lines of code tiered-storage/jcloud/src/main/java/org/apache/bookkeeper/mledger/offload/jcloud/impl/BlobStoreManagedLedgerOffloader.java x: 1 contributors (90d) y: 636 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumersClassic.java x: 2 contributors (90d) y: 1050 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherSingleActiveConsumer.java x: 2 contributors (90d) y: 501 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdPersistentTopics.java x: 1 contributors (90d) y: 559 lines of code pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdTopics.java x: 1 contributors (90d) y: 2527 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractReplicator.java x: 1 contributors (90d) y: 397 lines of code pulsar-common/src/main/proto/PulsarApi.proto x: 1 contributors (90d) y: 928 lines of code pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerBase.java x: 1 contributors (90d) y: 1092 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/impl/ModularLoadManagerImpl.java x: 1 contributors (90d) y: 902 lines of code pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/ProxyConfiguration.java x: 2 contributors (90d) y: 879 lines of code pulsar-proxy/src/main/java/org/apache/pulsar/proxy/server/WebServer.java x: 1 contributors (90d) y: 373 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/Namespaces.java x: 1 contributors (90d) y: 2968 lines of code pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/v2/PersistentTopics.java x: 1 contributors (90d) y: 4831 lines of code
4990.0
lines of code
  min: 4.0
  average: 498.78
  25th percentile: 69.0
  median: 213.5
  75th percentile: 553.25
  max: 4990.0
0 8.0
contributors (90d)
min: 1.0 | average: 1.4 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 8.0