apache / pulsar-client-reactive
File Size

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

Intro
Learn more...
File Size Overall
0% | 0% | 26% | 38% | 34%
Legend:
1001+
501-1000
201-500
101-200
1-100


explore: grouped by folders | grouped by size | sunburst | 3D view
File Size per Extension
1001+
501-1000
201-500
101-200
1-100
java0% | 0% | 27% | 37% | 34%
xml0% | 0% | 0% | 100% | 0%
toml0% | 0% | 0% | 0% | 100%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
pulsar-client-reactive-api0% | 0% | 46% | 30% | 23%
pulsar-client-reactive-adapter0% | 0% | 0% | 50% | 49%
pulsar-client-reactive-jackson0% | 0% | 0% | 53% | 46%
idea0% | 0% | 0% | 100% | 0%
gradle0% | 0% | 0% | 0% | 100%
pulsar-client-reactive-producer-cache-caffeine0% | 0% | 0% | 0% | 100%
pulsar-client-reactive-producer-cache-caffeine-shaded0% | 0% | 0% | 0% | 100%
Longest Files (Top 50)
File# lines# units
MutableReactiveMessageConsumerSpec.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api
424 69
MutableReactiveMessageSenderSpec.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api
340 55
ImmutableReactiveMessageConsumerSpec.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api
271 35
InflightLimiter.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api
228 22
ImmutableReactiveMessageSenderSpec.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api
215 28
AdaptedReactiveMessageConsumer.java
in pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter
200 8
ReactiveMessageConsumerBuilder.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api
192 39
AdaptedReactiveMessageSender.java
in pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter
166 4
ReactiveMessagePipelineE2ETests.java
in pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter
159 2
DefaultReactiveMessagePipeline.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api
157 7
ReactiveMessageSenderBuilder.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api
146 29
PulsarReactiveClientModule.java
in pulsar-client-reactive-jackson/src/main/java/org/apache/pulsar/reactive/client/jackson
137 9
128 -
MutableReactiveMessageReaderSpec.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api
123 21
DefaultMessageSpec.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api
120 4
DefaultReactiveMessagePipelineBuilder.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api
118 12
AdaptedReactiveMessageReader.java
in pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter
115 2
AdaptedReactiveMessageSenderBuilder.java
in pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter
113 11
ConverterUtils.java
in pulsar-client-reactive-jackson/src/main/java/org/apache/pulsar/reactive/client/jackson
105 6
ProducerCacheEntry.java
in pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter
103 11
DefaultMessageSpecBuilder.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api
101 14
ReactiveProducerAdapter.java
in pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter
95 7
ReactiveMessageSenderE2ETests.java
in pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter
81 3
ImmutableReactiveMessageReaderSpec.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api
80 11
71 -
ReactiveMessageReaderBuilder.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api
70 13
PulsarFutureAdapter.java
in pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter
59 9
ProducerCache.java
in pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter
57 7
ImmutableReactiveMessageConsumerSpecMixin.java
in pulsar-client-reactive-jackson/src/main/java/org/apache/pulsar/reactive/client/jackson
56 -
AdaptedReactiveMessageReaderBuilder.java
in pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter
50 6
ReactiveMessageConsumerSpec.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api
50 -
ReactiveMessageConsumerE2ETests.java
in pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter
49 1
CaffeineProducerCacheProvider.java
in pulsar-client-reactive-producer-cache-caffeine/src/main/java/org/apache/pulsar/reactive/client/producercache
48 6
CaffeineShadedProducerCacheProvider.java
in pulsar-client-reactive-producer-cache-caffeine-shaded/src/main/java/org/apache/pulsar/reactive/client/producercache
47 5
ProducerCacheKey.java
in pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter
46 3
ImmutableReactiveMessageSenderSpecMixin.java
in pulsar-client-reactive-jackson/src/main/java/org/apache/pulsar/reactive/client/jackson
46 -
ReactiveMessageSenderSpec.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api
41 -
MessageSendResult.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api
40 7
AdapterImplementationFactory.java
in pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter
39 6
MessageIdStartAtSpec.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api
36 6
AdaptedReactiveMessageConsumerBuilder.java
in pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter
35 4
ReactiveMessageReaderE2ETests.java
in pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter
35 1
ApiImplementationFactory.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api
34 8
GroupOrderedMessageProcessors.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api
34 3
ConcurrentHashMapProducerCacheProvider.java
in pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter
33 3
ReactiveConsumerAdapter.java
in pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter
33 3
DeadLetterPolicyConf.java
in pulsar-client-reactive-jackson/src/main/java/org/apache/pulsar/reactive/client/jackson
32 8
InstantStartAtSpec.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api
31 5
ReactivePulsarResourceAdapter.java
in pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter
30 4
ReactiveReaderAdapter.java
in pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter
30 3
Files With Most Units (Top 50)
File# lines# units
MutableReactiveMessageConsumerSpec.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api
424 69
MutableReactiveMessageSenderSpec.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api
340 55
ReactiveMessageConsumerBuilder.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api
192 39
ImmutableReactiveMessageConsumerSpec.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api
271 35
ReactiveMessageSenderBuilder.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api
146 29
ImmutableReactiveMessageSenderSpec.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api
215 28
InflightLimiter.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api
228 22
MutableReactiveMessageReaderSpec.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api
123 21
DefaultMessageSpecBuilder.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api
101 14
ReactiveMessageReaderBuilder.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api
70 13
DefaultReactiveMessagePipelineBuilder.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api
118 12
ProducerCacheEntry.java
in pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter
103 11
AdaptedReactiveMessageSenderBuilder.java
in pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter
113 11
ImmutableReactiveMessageReaderSpec.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api
80 11
PulsarFutureAdapter.java
in pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter
59 9
PulsarReactiveClientModule.java
in pulsar-client-reactive-jackson/src/main/java/org/apache/pulsar/reactive/client/jackson
137 9
AdaptedReactiveMessageConsumer.java
in pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter
200 8
ApiImplementationFactory.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api
34 8
DeadLetterPolicyConf.java
in pulsar-client-reactive-jackson/src/main/java/org/apache/pulsar/reactive/client/jackson
32 8
ReactiveProducerAdapter.java
in pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter
95 7
ProducerCache.java
in pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter
57 7
MessageSendResult.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api
40 7
DefaultReactiveMessagePipeline.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api
157 7
AdaptedReactiveMessageReaderBuilder.java
in pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter
50 6
AdapterImplementationFactory.java
in pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter
39 6
CaffeineProducerCacheProvider.java
in pulsar-client-reactive-producer-cache-caffeine/src/main/java/org/apache/pulsar/reactive/client/producercache
48 6
MessageIdStartAtSpec.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api
36 6
StartAtSpec.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api
30 6
MessageResult.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api
30 6
ConverterUtils.java
in pulsar-client-reactive-jackson/src/main/java/org/apache/pulsar/reactive/client/jackson
105 6
AdaptedReactivePulsarClientFactory.java
in pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/adapter
24 5
CaffeineShadedProducerCacheProvider.java
in pulsar-client-reactive-producer-cache-caffeine-shaded/src/main/java/org/apache/pulsar/reactive/client/producercache
47 5
InstantStartAtSpec.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api
31 5
ReactiveMessageSendingException.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api
23 5
ReactivePulsarResourceAdapter.java
in pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter
30 4
AdaptedReactiveMessageConsumerBuilder.java
in pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter
35 4
AdaptedReactiveMessageSender.java
in pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter
166 4
SingletonPulsarContainer.java
in pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter
22 4
DefaultMessageSpec.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api
120 4
ClassConf.java
in pulsar-client-reactive-jackson/src/main/java/org/apache/pulsar/reactive/client/jackson
19 4
RangeConf.java
in pulsar-client-reactive-jackson/src/main/java/org/apache/pulsar/reactive/client/jackson
18 4
ConcurrentHashMapProducerCacheProvider.java
in pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter
33 3
ProducerCacheKey.java
in pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter
46 3
ReactiveConsumerAdapter.java
in pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter
33 3
ReactivePulsarResourceAdapterPulsarClient.java
in pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter
24 3
ReactiveReaderAdapter.java
in pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter
30 3
ReactiveMessageSenderE2ETests.java
in pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter
81 3
MessageSpec.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api
14 3
GroupOrderedMessageProcessors.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api
34 3
EmptyMessageResult.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api
23 3
Files With Long Lines (Top 4)

There are 4 files with lines longer than 120 characters. In total, there are 5 long lines.

File# lines# units# long lines
71 - 2
ReactiveMessagePipelineE2ETests.java
in pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter
159 2 1
ImmutableReactiveMessageConsumerSpecMixin.java
in pulsar-client-reactive-jackson/src/main/java/org/apache/pulsar/reactive/client/jackson
56 - 1
ImmutableReactiveMessageSenderSpecMixin.java
in pulsar-client-reactive-jackson/src/main/java/org/apache/pulsar/reactive/client/jackson
46 - 1
Correlations

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

gradle/libs.versions.toml x: 43 commits (all time) y: 71 lines of code pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/SingletonPulsarContainer.java x: 19 commits (all time) y: 22 lines of code pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/ReactiveMessageConsumerE2ETests.java x: 1 commits (all time) y: 49 lines of code pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/ReactiveMessagePipelineE2ETests.java x: 1 commits (all time) y: 159 lines of code pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/ReactiveMessageReaderE2ETests.java x: 1 commits (all time) y: 35 lines of code pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/ReactiveMessageSenderE2ETests.java x: 1 commits (all time) y: 81 lines of code pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/AdaptedReactiveMessageConsumer.java x: 6 commits (all time) y: 200 lines of code pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/AdaptedReactiveMessageReader.java x: 3 commits (all time) y: 115 lines of code pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/AdaptedReactiveMessageSender.java x: 8 commits (all time) y: 166 lines of code pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/AdapterImplementationFactory.java x: 4 commits (all time) y: 39 lines of code pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/ProducerCache.java x: 4 commits (all time) y: 57 lines of code pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/ProducerCacheEntry.java x: 4 commits (all time) y: 103 lines of code pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/ReactiveProducerAdapter.java x: 5 commits (all time) y: 95 lines of code pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/ReactiveReaderAdapter.java x: 2 commits (all time) y: 30 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ImmutableReactiveMessageSenderSpec.java x: 6 commits (all time) y: 215 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MutableReactiveMessageSenderSpec.java x: 6 commits (all time) y: 340 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageSenderBuilder.java x: 11 commits (all time) y: 146 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/DefaultReactiveMessagePipeline.java x: 5 commits (all time) y: 157 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/DefaultReactiveMessagePipelineBuilder.java x: 6 commits (all time) y: 118 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/GroupOrderedMessageProcessors.java x: 4 commits (all time) y: 34 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/InflightLimiter.java x: 6 commits (all time) y: 228 lines of code pulsar-client-reactive-jackson/src/main/java/org/apache/pulsar/reactive/client/jackson/ConverterUtils.java x: 4 commits (all time) y: 105 lines of code pulsar-client-reactive-jackson/src/main/java/org/apache/pulsar/reactive/client/jackson/PulsarReactiveClientModule.java x: 5 commits (all time) y: 137 lines of code pulsar-client-reactive-producer-cache-caffeine-shaded/src/main/java/org/apache/pulsar/reactive/client/producercache/CaffeineShadedProducerCacheProvider.java x: 2 commits (all time) y: 47 lines of code pulsar-client-reactive-producer-cache-caffeine/src/main/java/org/apache/pulsar/reactive/client/producercache/CaffeineProducerCacheProvider.java x: 4 commits (all time) y: 48 lines of code pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/ProducerCacheKey.java x: 4 commits (all time) y: 46 lines of code pulsar-client-reactive-producer-cache-caffeine-shaded/src/main/java/org/apache/pulsar/reactive/client/producercache/CaffeineShadedProducerCacheProviderFactory.java x: 1 commits (all time) y: 9 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MessageSpec.java x: 5 commits (all time) y: 14 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/DefaultMessageSpec.java x: 5 commits (all time) y: 120 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/ValueOnlyMessageSpec.java x: 5 commits (all time) y: 20 lines of code pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/AdaptedReactiveMessageSenderBuilder.java x: 6 commits (all time) y: 113 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MessageSendResult.java x: 2 commits (all time) y: 40 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageSender.java x: 7 commits (all time) y: 9 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MessageSpecBuilder.java x: 6 commits (all time) y: 22 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageSendingException.java x: 1 commits (all time) y: 23 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/DefaultMessageSpecBuilder.java x: 5 commits (all time) y: 101 lines of code idea/codeStyleConfig.xml x: 2 commits (all time) y: 128 lines of code pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/adapter/AdaptedReactivePulsarClientFactory.java x: 3 commits (all time) y: 24 lines of code pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/adapter/ProducerCacheProvider.java x: 3 commits (all time) y: 8 lines of code pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/adapter/ProducerCacheProviderFactory.java x: 3 commits (all time) y: 4 lines of code pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/AdaptedReactiveMessageReaderBuilder.java x: 3 commits (all time) y: 50 lines of code pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/ConcurrentHashMapProducerCacheProvider.java x: 4 commits (all time) y: 33 lines of code pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/PulsarFutureAdapter.java x: 3 commits (all time) y: 59 lines of code pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/ReactiveConsumerAdapter.java x: 1 commits (all time) y: 33 lines of code pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/ReactiveConsumerAdapterFactory.java x: 2 commits (all time) y: 14 lines of code pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/ReactiveProducerAdapterFactory.java x: 2 commits (all time) y: 19 lines of code pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/ReactivePulsarResourceAdapterPulsarClient.java x: 1 commits (all time) y: 24 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ImmutableReactiveMessageConsumerSpec.java x: 6 commits (all time) y: 271 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ImmutableReactiveMessageReaderSpec.java x: 5 commits (all time) y: 80 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/InstantStartAtSpec.java x: 4 commits (all time) y: 31 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MessageIdStartAtSpec.java x: 4 commits (all time) y: 36 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MessageResult.java x: 4 commits (all time) y: 30 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MutableReactiveMessageConsumerSpec.java x: 6 commits (all time) y: 424 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MutableReactiveMessageReaderSpec.java x: 4 commits (all time) y: 123 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageConsumer.java x: 7 commits (all time) y: 15 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageConsumerBuilder.java x: 12 commits (all time) y: 192 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageConsumerSpec.java x: 5 commits (all time) y: 50 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessagePipeline.java x: 3 commits (all time) y: 9 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessagePipelineBuilder.java x: 5 commits (all time) y: 27 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageReader.java x: 4 commits (all time) y: 8 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageReaderBuilder.java x: 5 commits (all time) y: 70 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageReaderSpec.java x: 3 commits (all time) y: 17 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageSenderCache.java x: 2 commits (all time) y: 3 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageSenderSpec.java x: 4 commits (all time) y: 41 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/StartAtSpec.java x: 3 commits (all time) y: 30 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/EmptyMessageResult.java x: 3 commits (all time) y: 23 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/InternalMessageSpec.java x: 3 commits (all time) y: 6 lines of code pulsar-client-reactive-jackson/src/main/java/org/apache/pulsar/reactive/client/jackson/DeadLetterPolicyConf.java x: 2 commits (all time) y: 32 lines of code pulsar-client-reactive-jackson/src/main/java/org/apache/pulsar/reactive/client/jackson/ImmutableReactiveMessageConsumerSpecMixin.java x: 3 commits (all time) y: 56 lines of code pulsar-client-reactive-jackson/src/main/java/org/apache/pulsar/reactive/client/jackson/ImmutableReactiveMessageReaderSpecMixin.java x: 2 commits (all time) y: 23 lines of code pulsar-client-reactive-jackson/src/main/java/org/apache/pulsar/reactive/client/jackson/ImmutableReactiveMessageSenderSpecMixin.java x: 2 commits (all time) y: 46 lines of code pulsar-client-reactive-jackson/src/main/java/org/apache/pulsar/reactive/client/jackson/MutableReactiveMessageConsumerSpecMixin.java x: 2 commits (all time) y: 6 lines of code pulsar-client-reactive-jackson/src/main/java/org/apache/pulsar/reactive/client/jackson/RangeConf.java x: 2 commits (all time) y: 18 lines of code
424.0
lines of code
  min: 3.0
  average: 64.53
  25th percentile: 18.0
  median: 34.0
  75th percentile: 95.0
  max: 424.0
0 43.0
commits (all time)
min: 1.0 | average: 4.37 | 25th percentile: 2.0 | median: 4.0 | 75th percentile: 5.0 | max: 43.0

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

gradle/libs.versions.toml x: 7 contributors (all time) y: 71 lines of code pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/SingletonPulsarContainer.java x: 5 contributors (all time) y: 22 lines of code pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/ReactiveMessageConsumerE2ETests.java x: 1 contributors (all time) y: 49 lines of code pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/ReactiveMessagePipelineE2ETests.java x: 1 contributors (all time) y: 159 lines of code pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/ReactiveMessageReaderE2ETests.java x: 1 contributors (all time) y: 35 lines of code pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/ReactiveMessageSenderE2ETests.java x: 1 contributors (all time) y: 81 lines of code pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/AdaptedReactiveMessageConsumer.java x: 2 contributors (all time) y: 200 lines of code pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/AdaptedReactiveMessageReader.java x: 1 contributors (all time) y: 115 lines of code pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/AdaptedReactiveMessageSender.java x: 2 contributors (all time) y: 166 lines of code pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/AdapterImplementationFactory.java x: 3 contributors (all time) y: 39 lines of code pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/ProducerCache.java x: 2 contributors (all time) y: 57 lines of code pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/ProducerCacheEntry.java x: 2 contributors (all time) y: 103 lines of code pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/ReactiveProducerAdapter.java x: 2 contributors (all time) y: 95 lines of code pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/ReactiveReaderAdapter.java x: 1 contributors (all time) y: 30 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ImmutableReactiveMessageSenderSpec.java x: 3 contributors (all time) y: 215 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MutableReactiveMessageSenderSpec.java x: 3 contributors (all time) y: 340 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageSenderBuilder.java x: 3 contributors (all time) y: 146 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/DefaultReactiveMessagePipeline.java x: 2 contributors (all time) y: 157 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/DefaultReactiveMessagePipelineBuilder.java x: 2 contributors (all time) y: 118 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/GroupOrderedMessageProcessors.java x: 3 contributors (all time) y: 34 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/InflightLimiter.java x: 3 contributors (all time) y: 228 lines of code pulsar-client-reactive-jackson/src/main/java/org/apache/pulsar/reactive/client/jackson/ConverterUtils.java x: 3 contributors (all time) y: 105 lines of code pulsar-client-reactive-jackson/src/main/java/org/apache/pulsar/reactive/client/jackson/PulsarReactiveClientModule.java x: 3 contributors (all time) y: 137 lines of code pulsar-client-reactive-producer-cache-caffeine-shaded/src/main/java/org/apache/pulsar/reactive/client/producercache/CaffeineShadedProducerCacheProvider.java x: 2 contributors (all time) y: 47 lines of code pulsar-client-reactive-producer-cache-caffeine/src/main/java/org/apache/pulsar/reactive/client/producercache/CaffeineProducerCacheProvider.java x: 3 contributors (all time) y: 48 lines of code pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/ProducerCacheKey.java x: 3 contributors (all time) y: 46 lines of code pulsar-client-reactive-producer-cache-caffeine-shaded/src/main/java/org/apache/pulsar/reactive/client/producercache/CaffeineShadedProducerCacheProviderFactory.java x: 1 contributors (all time) y: 9 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MessageSpec.java x: 3 contributors (all time) y: 14 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/DefaultMessageSpec.java x: 3 contributors (all time) y: 120 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/ValueOnlyMessageSpec.java x: 3 contributors (all time) y: 20 lines of code pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/AdaptedReactiveMessageSenderBuilder.java x: 2 contributors (all time) y: 113 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MessageSendResult.java x: 1 contributors (all time) y: 40 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageSender.java x: 3 contributors (all time) y: 9 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MessageSpecBuilder.java x: 3 contributors (all time) y: 22 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageSendingException.java x: 1 contributors (all time) y: 23 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/DefaultMessageSpecBuilder.java x: 3 contributors (all time) y: 101 lines of code idea/codeStyleConfig.xml x: 1 contributors (all time) y: 128 lines of code pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/adapter/AdaptedReactivePulsarClientFactory.java x: 3 contributors (all time) y: 24 lines of code pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/adapter/ProducerCacheProvider.java x: 3 contributors (all time) y: 8 lines of code pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/adapter/ProducerCacheProviderFactory.java x: 3 contributors (all time) y: 4 lines of code pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/AdaptedReactiveMessageConsumerBuilder.java x: 2 contributors (all time) y: 35 lines of code pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/AdaptedReactiveMessageReaderBuilder.java x: 2 contributors (all time) y: 50 lines of code pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/ConcurrentHashMapProducerCacheProvider.java x: 3 contributors (all time) y: 33 lines of code pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/PulsarFutureAdapter.java x: 3 contributors (all time) y: 59 lines of code pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/ReactiveConsumerAdapter.java x: 1 contributors (all time) y: 33 lines of code pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/ReactiveConsumerAdapterFactory.java x: 2 contributors (all time) y: 14 lines of code pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/ReactiveProducerAdapterFactory.java x: 1 contributors (all time) y: 19 lines of code pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/ReactivePulsarResourceAdapter.java x: 2 contributors (all time) y: 30 lines of code pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/ReactivePulsarResourceAdapterPulsarClient.java x: 1 contributors (all time) y: 24 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ImmutableReactiveMessageConsumerSpec.java x: 3 contributors (all time) y: 271 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ImmutableReactiveMessageReaderSpec.java x: 3 contributors (all time) y: 80 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/InstantStartAtSpec.java x: 3 contributors (all time) y: 31 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MessageIdStartAtSpec.java x: 3 contributors (all time) y: 36 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MessageResult.java x: 3 contributors (all time) y: 30 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MutableReactiveMessageConsumerSpec.java x: 3 contributors (all time) y: 424 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MutableReactiveMessageReaderSpec.java x: 3 contributors (all time) y: 123 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageConsumerBuilder.java x: 3 contributors (all time) y: 192 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageConsumerSpec.java x: 3 contributors (all time) y: 50 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessagePipelineBuilder.java x: 3 contributors (all time) y: 27 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageReaderBuilder.java x: 3 contributors (all time) y: 70 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageReaderSpec.java x: 3 contributors (all time) y: 17 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageSenderCache.java x: 2 contributors (all time) y: 3 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageSenderSpec.java x: 3 contributors (all time) y: 41 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/InternalMessageSpec.java x: 3 contributors (all time) y: 6 lines of code pulsar-client-reactive-jackson/src/main/java/org/apache/pulsar/reactive/client/jackson/ClassConf.java x: 2 contributors (all time) y: 19 lines of code pulsar-client-reactive-jackson/src/main/java/org/apache/pulsar/reactive/client/jackson/DeadLetterPolicyConf.java x: 2 contributors (all time) y: 32 lines of code pulsar-client-reactive-jackson/src/main/java/org/apache/pulsar/reactive/client/jackson/ImmutableReactiveMessageConsumerSpecMixin.java x: 2 contributors (all time) y: 56 lines of code pulsar-client-reactive-jackson/src/main/java/org/apache/pulsar/reactive/client/jackson/ImmutableReactiveMessageReaderSpecMixin.java x: 2 contributors (all time) y: 23 lines of code pulsar-client-reactive-jackson/src/main/java/org/apache/pulsar/reactive/client/jackson/ImmutableReactiveMessageSenderSpecMixin.java x: 2 contributors (all time) y: 46 lines of code pulsar-client-reactive-jackson/src/main/java/org/apache/pulsar/reactive/client/jackson/MutableReactiveMessageConsumerSpecMixin.java x: 2 contributors (all time) y: 6 lines of code pulsar-client-reactive-jackson/src/main/java/org/apache/pulsar/reactive/client/jackson/RangeConf.java x: 2 contributors (all time) y: 18 lines of code
424.0
lines of code
  min: 3.0
  average: 64.53
  25th percentile: 18.0
  median: 34.0
  75th percentile: 95.0
  max: 424.0
0 7.0
contributors (all time)
min: 1.0 | average: 2.49 | 25th percentile: 2.0 | median: 3.0 | 75th percentile: 3.0 | max: 7.0

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

gradle/libs.versions.toml x: 2 commits (30d) y: 71 lines of code pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/SingletonPulsarContainer.java x: 1 commits (30d) y: 22 lines of code
71.0
lines of code
  min: 22.0
  average: 46.5
  25th percentile: 22.0
  median: 46.5
  75th percentile: 71.0
  max: 71.0
0 2.0
commits (30d)
min: 1.0 | average: 1.5 | 25th percentile: 1.0 | median: 1.5 | 75th percentile: 2.0 | max: 2.0

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

gradle/libs.versions.toml x: 1 contributors (30d) y: 71 lines of code pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/SingletonPulsarContainer.java x: 1 contributors (30d) y: 22 lines of code
71.0
lines of code
  min: 22.0
  average: 46.5
  25th percentile: 22.0
  median: 46.5
  75th percentile: 71.0
  max: 71.0
0 1.0
contributors (30d)
min: 1.0 | average: 1.0 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 1.0

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

gradle/libs.versions.toml x: 5 commits (90d) y: 71 lines of code pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/SingletonPulsarContainer.java x: 3 commits (90d) y: 22 lines of code
71.0
lines of code
  min: 22.0
  average: 46.5
  25th percentile: 22.0
  median: 46.5
  75th percentile: 71.0
  max: 71.0
0 5.0
commits (90d)
min: 3.0 | average: 4.0 | 25th percentile: 3.0 | median: 4.0 | 75th percentile: 5.0 | max: 5.0

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

gradle/libs.versions.toml x: 2 contributors (90d) y: 71 lines of code pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/SingletonPulsarContainer.java x: 2 contributors (90d) y: 22 lines of code
71.0
lines of code
  min: 22.0
  average: 46.5
  25th percentile: 22.0
  median: 46.5
  75th percentile: 71.0
  max: 71.0
0 2.0
contributors (90d)
min: 2.0 | average: 2.0 | 25th percentile: 2.0 | median: 2.0 | 75th percentile: 2.0 | max: 2.0