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% | 30% | 35% | 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% | 31% | 34% | 34%
xml0% | 0% | 0% | 100% | 0%
toml0% | 0% | 0% | 0% | 100%
adoc0% | 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% | 12% | 38% | 48%
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%
ROOT0% | 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
204 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
DefaultReactiveMessagePipeline.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api
152 7
ReactiveMessageSenderBuilder.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api
146 29
ReactiveMessagePipelineE2ETest.java
in pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter
142 2
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
114 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
103 6
DefaultMessageSpecBuilder.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api
101 14
ProducerCacheEntry.java
in pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter
101 11
ReactiveProducerAdapter.java
in pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter
95 7
ImmutableReactiveMessageReaderSpec.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api
80 11
ReactiveMessageSenderE2ETest.java
in pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter
73 3
ReactiveMessageReaderBuilder.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api
70 13
63 -
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 -
ReactiveMessageConsumerSpec.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api
50 -
AdaptedReactiveMessageReaderBuilder.java
in pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter
50 6
ImmutableReactiveMessageSenderSpecMixin.java
in pulsar-client-reactive-jackson/src/main/java/org/apache/pulsar/reactive/client/jackson
46 -
CaffeineProducerCacheProvider.java
in pulsar-client-reactive-producer-cache-caffeine/src/main/java/org/apache/pulsar/reactive/client/producercache
44 6
43 -
CaffeineShadedProducerCacheProvider.java
in pulsar-client-reactive-producer-cache-caffeine-shaded/src/main/java/org/apache/pulsar/reactive/client/producercache
42 5
ReactiveMessageSenderSpec.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api
41 -
ReactiveMessageConsumerE2ETest.java
in pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter
41 1
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
ProducerCacheKey.java
in pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter
37 2
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
ApiImplementationFactory.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api
34 8
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
GroupOrderedMessageProcessors.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api
32 3
ReactiveMessageReaderE2ETest.java
in pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter
32 1
InstantStartAtSpec.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api
31 5
StartAtSpec.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api
30 6
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
ImmutableReactiveMessageReaderSpec.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api
80 11
ProducerCacheEntry.java
in pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter
101 11
AdaptedReactiveMessageSenderBuilder.java
in pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter
113 11
PulsarReactiveClientModule.java
in pulsar-client-reactive-jackson/src/main/java/org/apache/pulsar/reactive/client/jackson
137 9
PulsarFutureAdapter.java
in pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter
59 9
DeadLetterPolicyConf.java
in pulsar-client-reactive-jackson/src/main/java/org/apache/pulsar/reactive/client/jackson
32 8
ApiImplementationFactory.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api
34 8
AdaptedReactiveMessageConsumer.java
in pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter
204 8
DefaultReactiveMessagePipeline.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api
152 7
MessageSendResult.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api
40 7
ProducerCache.java
in pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter
57 7
ReactiveProducerAdapter.java
in pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter
95 7
ConverterUtils.java
in pulsar-client-reactive-jackson/src/main/java/org/apache/pulsar/reactive/client/jackson
103 6
StartAtSpec.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api
30 6
MessageIdStartAtSpec.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api
36 6
MessageResult.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api
30 6
CaffeineProducerCacheProvider.java
in pulsar-client-reactive-producer-cache-caffeine/src/main/java/org/apache/pulsar/reactive/client/producercache
44 6
AdapterImplementationFactory.java
in pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter
39 6
AdaptedReactiveMessageReaderBuilder.java
in pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter
50 6
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
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
42 5
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
DefaultMessageSpec.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api
120 4
SingletonPulsarContainer.java
in pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter
21 4
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
DefaultMessageResult.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api
25 3
ValueOnlyMessageSpec.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api
20 3
EmptyMessageResult.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api
23 3
GroupOrderedMessageProcessors.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api
32 3
MessageSpec.java
in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api
14 3
ReactiveMessageSenderE2ETest.java
in pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter
73 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
ReactiveReaderAdapter.java
in pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter
30 3
Files With Long Lines (Top 5)

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

File# lines# units# long lines
43 - 13
63 - 2
ImmutableReactiveMessageSenderSpecMixin.java
in pulsar-client-reactive-jackson/src/main/java/org/apache/pulsar/reactive/client/jackson
46 - 1
ImmutableReactiveMessageConsumerSpecMixin.java
in pulsar-client-reactive-jackson/src/main/java/org/apache/pulsar/reactive/client/jackson
56 - 1
ReactiveMessagePipelineE2ETest.java
in pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter
142 2 1
Correlations

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

gradle/libs.versions.toml x: 11 commits (all time) y: 63 lines of code pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/SingletonPulsarContainer.java x: 6 commits (all time) y: 21 lines of code pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/ReactiveMessageSenderE2ETest.java x: 7 commits (all time) y: 73 lines of code pulsar-client-reactive-producer-cache-caffeine-shaded/src/main/java/org/apache/pulsar/reactive/client/producercache/CaffeineShadedProducerCacheProvider.java x: 1 commits (all time) y: 42 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-jackson/src/main/java/org/apache/pulsar/reactive/client/jackson/ConverterUtils.java x: 3 commits (all time) y: 103 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/AdaptedReactiveMessageSender.java x: 7 commits (all time) y: 166 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/ReactiveMessageSenderBuilder.java x: 10 commits (all time) y: 146 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 CONTRIBUTING.adoc x: 2 commits (all time) y: 43 lines of code idea/codeStyleConfig.xml x: 2 commits (all time) y: 128 lines of code pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/ReactiveMessageConsumerE2ETest.java x: 4 commits (all time) y: 41 lines of code pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/ReactiveMessagePipelineE2ETest.java x: 7 commits (all time) y: 142 lines of code pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/ReactiveMessageReaderE2ETest.java x: 4 commits (all time) y: 32 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/AdaptedReactiveMessageConsumer.java x: 5 commits (all time) y: 204 lines of code pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/AdaptedReactiveMessageConsumerBuilder.java x: 4 commits (all time) y: 35 lines of code pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/AdaptedReactiveMessageReader.java x: 2 commits (all time) y: 114 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/AdapterImplementationFactory.java x: 3 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: 3 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: 3 commits (all time) y: 101 lines of code pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/ProducerCacheKey.java x: 3 commits (all time) y: 37 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/ReactiveProducerAdapter.java x: 4 commits (all time) y: 95 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/ReactivePulsarResourceAdapter.java x: 2 commits (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 commits (all time) y: 24 lines of code pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/ReactiveReaderAdapter.java x: 1 commits (all time) y: 30 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/ImmutableReactiveMessageSenderSpec.java x: 5 commits (all time) y: 215 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/MutableReactiveMessageSenderSpec.java x: 5 commits (all time) y: 340 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/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/DefaultReactiveMessagePipeline.java x: 4 commits (all time) y: 152 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/DefaultReactiveMessagePipelineBuilder.java x: 5 commits (all time) y: 118 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/GroupOrderedMessageProcessors.java x: 3 commits (all time) y: 32 lines of code pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/InflightLimiter.java x: 5 commits (all time) y: 228 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/PulsarReactiveClientModule.java x: 4 commits (all time) y: 137 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 pulsar-client-reactive-producer-cache-caffeine/src/main/java/org/apache/pulsar/reactive/client/producercache/CaffeineProducerCacheProvider.java x: 3 commits (all time) y: 44 lines of code
424.0
lines of code
  min: 3.0
  average: 63.48
  25th percentile: 18.25
  median: 33.0
  75th percentile: 91.25
  max: 424.0
0 12.0
commits (all time)
min: 1.0 | average: 3.81 | 25th percentile: 2.0 | median: 3.0 | 75th percentile: 5.0 | max: 12.0

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

gradle/libs.versions.toml x: 5 contributors (all time) y: 63 lines of code pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/SingletonPulsarContainer.java x: 4 contributors (all time) y: 21 lines of code pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/ReactiveMessageSenderE2ETest.java x: 4 contributors (all time) y: 73 lines of code pulsar-client-reactive-producer-cache-caffeine-shaded/src/main/java/org/apache/pulsar/reactive/client/producercache/CaffeineShadedProducerCacheProvider.java x: 1 contributors (all time) y: 42 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-jackson/src/main/java/org/apache/pulsar/reactive/client/jackson/ConverterUtils.java x: 3 contributors (all time) y: 103 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/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/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/ReactiveMessageSenderBuilder.java x: 3 contributors (all time) y: 146 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 CONTRIBUTING.adoc x: 2 contributors (all time) y: 43 lines of code idea/codeStyleConfig.xml x: 1 contributors (all time) y: 128 lines of code pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/ReactiveMessageConsumerE2ETest.java x: 3 contributors (all time) y: 41 lines of code pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/ReactiveMessagePipelineE2ETest.java x: 3 contributors (all time) y: 142 lines of code pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/ReactiveMessageReaderE2ETest.java x: 3 contributors (all time) y: 32 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/AdaptedReactiveMessageConsumer.java x: 2 contributors (all time) y: 204 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/AdaptedReactiveMessageReader.java x: 1 contributors (all time) y: 114 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/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: 101 lines of code pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/ProducerCacheKey.java x: 2 contributors (all time) y: 37 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/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/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-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/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/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/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/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/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/internal/api/ApiImplementationFactory.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/DefaultReactiveMessagePipeline.java x: 2 contributors (all time) y: 152 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/InflightLimiter.java x: 3 contributors (all time) y: 228 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/PulsarReactiveClientModule.java x: 3 contributors (all time) y: 137 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 pulsar-client-reactive-producer-cache-caffeine/src/main/java/org/apache/pulsar/reactive/client/producercache/CaffeineProducerCacheProvider.java x: 3 contributors (all time) y: 44 lines of code
424.0
lines of code
  min: 3.0
  average: 63.48
  25th percentile: 18.25
  median: 33.0
  75th percentile: 91.25
  max: 424.0
0 5.0
contributors (all time)
min: 1.0 | average: 2.53 | 25th percentile: 2.0 | median: 3.0 | 75th percentile: 3.0 | max: 5.0

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

gradle/libs.versions.toml x: 1 commits (30d) y: 63 lines of code pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/SingletonPulsarContainer.java x: 1 commits (30d) y: 21 lines of code
63.0
lines of code
  min: 21.0
  average: 42.0
  25th percentile: 21.0
  median: 42.0
  75th percentile: 63.0
  max: 63.0
0 1.0
commits (30d)
min: 1.0 | average: 1.0 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 1.0

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

gradle/libs.versions.toml x: 1 contributors (30d) y: 63 lines of code pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/SingletonPulsarContainer.java x: 1 contributors (30d) y: 21 lines of code
63.0
lines of code
  min: 21.0
  average: 42.0
  25th percentile: 21.0
  median: 42.0
  75th percentile: 63.0
  max: 63.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: 1 commits (90d) y: 63 lines of code pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/SingletonPulsarContainer.java x: 1 commits (90d) y: 21 lines of code
63.0
lines of code
  min: 21.0
  average: 42.0
  25th percentile: 21.0
  median: 42.0
  75th percentile: 63.0
  max: 63.0
0 1.0
commits (90d)
min: 1.0 | average: 1.0 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 1.0

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

gradle/libs.versions.toml x: 1 contributors (90d) y: 63 lines of code pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/SingletonPulsarContainer.java x: 1 contributors (90d) y: 21 lines of code
63.0
lines of code
  min: 21.0
  average: 42.0
  25th percentile: 21.0
  median: 42.0
  75th percentile: 63.0
  max: 63.0
0 1.0
contributors (90d)
min: 1.0 | average: 1.0 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 1.0