Architecture Report

parallel-collectors — version HEAD — recovered with pkg

97
Entities
30
Dependencies
97
Components
0
Smells

Quality Metrics

Core ARCADE Metrics

0.000
RCI
0.000
TurboMQ
0.000
BasicMQ
0.000
IntraConnectivity
1.000
InterConnectivity
0.000
TwoWayPairRatio

Balanced / Principle-aligned Scores

0.450
DependencyHealth
1.000
ComponentBalance
0.896
HubBalance
1.000
BoundaryClarity
0.132
DependencyDistribution
1.000
SmellDiscipline
0.850
PrincipleAlignmentScore
0.448
BalancedArchitectureScore

Architecture Diagram

graph TD
    Abstractparallelcollector["Abstractparallelcollector\n(1 entities)"]
    Abstractparallelcollector2["Abstractparallelcollector2\n(1 entities)"]
    Accumulator["Accumulator\n(1 entities)"]
    Characteristics["Characteristics\n(1 entities)"]
    Combiner["Combiner\n(1 entities)"]
    Finalizer["Finalizer\n(1 entities)"]
    Finisher["Finisher\n(1 entities)"]
    Supplier["Supplier\n(1 entities)"]
    Asyncparallelcollector["Asyncparallelcollector\n(1 entities)"]
    Asyncparallelcollector2["Asyncparallelcollector2\n(1 entities)"]
    Finalizer2["Finalizer2\n(1 entities)"]
    Asyncparallelstreamingcollector["Asyncparallelstreamingcollector\n(1 entities)"]
    Asyncparallelstreamingcollector2["Asyncparallelstreamingcollector2\n(1 entities)"]
    Characteristics2["Characteristics2\n(1 entities)"]
    Finalizer3["Finalizer3\n(1 entities)"]
    Joininterruptibly["Joininterruptibly\n(1 entities)"]
    Joinwithin["Joinwithin\n(1 entities)"]
    Orderedstream["Orderedstream\n(1 entities)"]
    Batchingspliterator["Batchingspliterator\n(1 entities)"]
    Batchingspliterator2["Batchingspliterator2\n(1 entities)"]
    Assingletonliststream["Assingletonliststream\n(1 entities)"]
    Batching["Batching\n(1 entities)"]
    Characteristics3["Characteristics3\n(1 entities)"]
    Estimatesize["Estimatesize\n(1 entities)"]
    Partitioned["Partitioned\n(1 entities)"]
    Tryadvance["Tryadvance\n(1 entities)"]
    Trysplit["Trysplit\n(1 entities)"]
    Collectingconfigurer["Collectingconfigurer\n(1 entities)"]
    Collectingconfigurer2["Collectingconfigurer2\n(1 entities)"]
    Addonce["Addonce\n(1 entities)"]
    Batching2["Batching2\n(1 entities)"]
    Executor["Executor\n(1 entities)"]
    Executordecorator["Executordecorator\n(1 entities)"]
    Getconfig["Getconfig\n(1 entities)"]
    Parallelism["Parallelism\n(1 entities)"]
    Taskdecorator["Taskdecorator\n(1 entities)"]
    Validate["Validate\n(1 entities)"]
    Completionorderspliterator["Completionorderspliterator\n(1 entities)"]
    Completionorderspliterator2["Completionorderspliterator2\n(1 entities)"]
    Characteristics4["Characteristics4\n(1 entities)"]
    Estimatesize2["Estimatesize2\n(1 entities)"]
    Nextcompleted["Nextcompleted\n(1 entities)"]
    Tryadvance2["Tryadvance2\n(1 entities)"]
    Trysplit2["Trysplit2\n(1 entities)"]
    Completionstrategy["Completionstrategy\n(1 entities)"]
    Configprocessor["Configprocessor\n(1 entities)"]
    Process["Process\n(1 entities)"]
    Tohumanreadablestring["Tohumanreadablestring\n(1 entities)"]
    Deadline["Deadline\n(1 entities)"]
    Deadline2["Deadline2\n(1 entities)"]
    Remainingnanos["Remainingnanos\n(1 entities)"]
    Dispatcher["Dispatcher\n(1 entities)"]
    Dispatcher2["Dispatcher2\n(1 entities)"]
    Abort["Abort\n(1 entities)"]
    Registerterminationguard["Registerterminationguard\n(1 entities)"]
    Retry["Retry\n(1 entities)"]
    Start["Start\n(1 entities)"]
    Stop["Stop\n(1 entities)"]
    Submit["Submit\n(1 entities)"]
    Wasshutdown["Wasshutdown\n(1 entities)"]
    Wasstarted["Wasstarted\n(1 entities)"]
    Factory["Factory\n(1 entities)"]
    Factory2["Factory2\n(1 entities)"]
    Collecting["Collecting\n(1 entities)"]
    Collectingby["Collectingby\n(1 entities)"]
    Select["Select\n(1 entities)"]
    Streaming["Streaming\n(1 entities)"]
    Streamingby["Streamingby\n(1 entities)"]
    Futurecollectors["Futurecollectors\n(1 entities)"]
    Tofuture["Tofuture\n(1 entities)"]
    Interruptiblecompletablefuture["Interruptiblecompletablefuture\n(1 entities)"]
    Cancel["Cancel\n(1 entities)"]
    Completedby["Completedby\n(1 entities)"]
    Parallelcollectors["Parallelcollectors\n(1 entities)"]
    Parallelcollectors2["Parallelcollectors2\n(1 entities)"]
    Parallel["Parallel\n(1 entities)"]
    Parallelby["Parallelby\n(1 entities)"]
    Paralleltostream["Paralleltostream\n(1 entities)"]
    Paralleltostreamby["Paralleltostreamby\n(1 entities)"]
    Tofuture2["Tofuture2\n(1 entities)"]
    Preconditions["Preconditions\n(1 entities)"]
    Preconditions2["Preconditions2\n(1 entities)"]
    Requirevalidexecutor["Requirevalidexecutor\n(1 entities)"]
    Requirevalidparallelism["Requirevalidparallelism\n(1 entities)"]
    Requirevalidtimeout["Requirevalidtimeout\n(1 entities)"]
    Streamingconfigurer["Streamingconfigurer\n(1 entities)"]
    Streamingconfigurer2["Streamingconfigurer2\n(1 entities)"]
    Addonce2["Addonce2\n(1 entities)"]
    Batching3["Batching3\n(1 entities)"]
    Executor2["Executor2\n(1 entities)"]
    Executordecorator2["Executordecorator2\n(1 entities)"]
    Getconfig2["Getconfig2\n(1 entities)"]
    Ordered["Ordered\n(1 entities)"]
    Parallelism2["Parallelism2\n(1 entities)"]
    Taskdecorator2["Taskdecorator2\n(1 entities)"]
    Timeout["Timeout\n(1 entities)"]
    Validate2["Validate2\n(1 entities)"]
    Abort --> Requirevalidexecutor
    Asyncparallelcollector --> Batching
    Asyncparallelcollector --> Partitioned
    Asyncparallelcollector2 --> Batching
    Asyncparallelcollector2 --> Partitioned
    Asyncparallelstreamingcollector --> Batching
    Asyncparallelstreamingcollector --> Partitioned
    Asyncparallelstreamingcollector2 --> Batching
    Asyncparallelstreamingcollector2 --> Partitioned
    Characteristics2 --> Batching
    Characteristics2 --> Partitioned
    Dispatcher --> Requirevalidexecutor
    Dispatcher2 --> Requirevalidexecutor
    Finalizer2 --> Batching
    Finalizer2 --> Partitioned
    Finalizer3 --> Batching
    Finalizer3 --> Partitioned
    Joininterruptibly --> Batching
    Joininterruptibly --> Partitioned
    Joinwithin --> Batching
    Joinwithin --> Partitioned
    Orderedstream --> Batching
    Orderedstream --> Partitioned
    Registerterminationguard --> Requirevalidexecutor
    Retry --> Requirevalidexecutor
    Start --> Requirevalidexecutor
    Stop --> Requirevalidexecutor
    Submit --> Requirevalidexecutor
    Wasshutdown --> Requirevalidexecutor
    Wasstarted --> Requirevalidexecutor
        
Package-based grouping (depth=4 after common prefix 'com.pivovarit.collectors').

Components

Component Responsibility # Entities
Abstractparallelcollector Entities in AbstractParallelCollector 1 com.pivovarit.collectors.AbstractParallelCollector
Abstractparallelcollector2 Entities in AbstractParallelCollector.AbstractParallelCollector 1 com.pivovarit.collectors.AbstractParallelCollector.AbstractParallelCollector
Accumulator Entities in AbstractParallelCollector.accumulator 1 com.pivovarit.collectors.AbstractParallelCollector.accumulator
Characteristics Entities in AbstractParallelCollector.characteristics 1 com.pivovarit.collectors.AbstractParallelCollector.characteristics
Combiner Entities in AbstractParallelCollector.combiner 1 com.pivovarit.collectors.AbstractParallelCollector.combiner
Finalizer Entities in AbstractParallelCollector.finalizer 1 com.pivovarit.collectors.AbstractParallelCollector.finalizer
Finisher Entities in AbstractParallelCollector.finisher 1 com.pivovarit.collectors.AbstractParallelCollector.finisher
Supplier Entities in AbstractParallelCollector.supplier 1 com.pivovarit.collectors.AbstractParallelCollector.supplier
Asyncparallelcollector Entities in AsyncParallelCollector 1 com.pivovarit.collectors.AsyncParallelCollector
Asyncparallelcollector2 Entities in AsyncParallelCollector.AsyncParallelCollector 1 com.pivovarit.collectors.AsyncParallelCollector.AsyncParallelCollector
Finalizer2 Entities in AsyncParallelCollector.finalizer 1 com.pivovarit.collectors.AsyncParallelCollector.finalizer
Asyncparallelstreamingcollector Entities in AsyncParallelStreamingCollector 1 com.pivovarit.collectors.AsyncParallelStreamingCollector
Asyncparallelstreamingcollector2 Entities in AsyncParallelStreamingCollector.AsyncParallelStreamingCollector 1 com.pivovarit.collectors.AsyncParallelStreamingCollector.AsyncParallelStreamingCollector
Characteristics2 Entities in AsyncParallelStreamingCollector.characteristics 1 com.pivovarit.collectors.AsyncParallelStreamingCollector.characteristics
Finalizer3 Entities in AsyncParallelStreamingCollector.finalizer 1 com.pivovarit.collectors.AsyncParallelStreamingCollector.finalizer
Joininterruptibly Entities in AsyncParallelStreamingCollector.joinInterruptibly 1 com.pivovarit.collectors.AsyncParallelStreamingCollector.joinInterruptibly
Joinwithin Entities in AsyncParallelStreamingCollector.joinWithin 1 com.pivovarit.collectors.AsyncParallelStreamingCollector.joinWithin
Orderedstream Entities in AsyncParallelStreamingCollector.orderedStream 1 com.pivovarit.collectors.AsyncParallelStreamingCollector.orderedStream
Batchingspliterator Entities in BatchingSpliterator 1 com.pivovarit.collectors.BatchingSpliterator
Batchingspliterator2 Entities in BatchingSpliterator.BatchingSpliterator 1 com.pivovarit.collectors.BatchingSpliterator.BatchingSpliterator
Assingletonliststream Entities in BatchingSpliterator.asSingletonListStream 1 com.pivovarit.collectors.BatchingSpliterator.asSingletonListStream
Batching Entities in BatchingSpliterator.batching 1 com.pivovarit.collectors.BatchingSpliterator.batching
Characteristics3 Entities in BatchingSpliterator.characteristics 1 com.pivovarit.collectors.BatchingSpliterator.characteristics
Estimatesize Entities in BatchingSpliterator.estimateSize 1 com.pivovarit.collectors.BatchingSpliterator.estimateSize
Partitioned Entities in BatchingSpliterator.partitioned 1 com.pivovarit.collectors.BatchingSpliterator.partitioned
Tryadvance Entities in BatchingSpliterator.tryAdvance 1 com.pivovarit.collectors.BatchingSpliterator.tryAdvance
Trysplit Entities in BatchingSpliterator.trySplit 1 com.pivovarit.collectors.BatchingSpliterator.trySplit
Collectingconfigurer Entities in CollectingConfigurer 1 com.pivovarit.collectors.CollectingConfigurer
Collectingconfigurer2 Entities in CollectingConfigurer.CollectingConfigurer 1 com.pivovarit.collectors.CollectingConfigurer.CollectingConfigurer
Addonce Entities in CollectingConfigurer.addOnce 1 com.pivovarit.collectors.CollectingConfigurer.addOnce
Batching2 Entities in CollectingConfigurer.batching 1 com.pivovarit.collectors.CollectingConfigurer.batching
Executor Entities in CollectingConfigurer.executor 1 com.pivovarit.collectors.CollectingConfigurer.executor
Executordecorator Entities in CollectingConfigurer.executorDecorator 1 com.pivovarit.collectors.CollectingConfigurer.executorDecorator
Getconfig Entities in CollectingConfigurer.getConfig 1 com.pivovarit.collectors.CollectingConfigurer.getConfig
Parallelism Entities in CollectingConfigurer.parallelism 1 com.pivovarit.collectors.CollectingConfigurer.parallelism
Taskdecorator Entities in CollectingConfigurer.taskDecorator 1 com.pivovarit.collectors.CollectingConfigurer.taskDecorator
Validate Entities in CollectingConfigurer.validate 1 com.pivovarit.collectors.CollectingConfigurer.validate
Completionorderspliterator Entities in CompletionOrderSpliterator 1 com.pivovarit.collectors.CompletionOrderSpliterator
Completionorderspliterator2 Entities in CompletionOrderSpliterator.CompletionOrderSpliterator 1 com.pivovarit.collectors.CompletionOrderSpliterator.CompletionOrderSpliterator
Characteristics4 Entities in CompletionOrderSpliterator.characteristics 1 com.pivovarit.collectors.CompletionOrderSpliterator.characteristics
Estimatesize2 Entities in CompletionOrderSpliterator.estimateSize 1 com.pivovarit.collectors.CompletionOrderSpliterator.estimateSize
Nextcompleted Entities in CompletionOrderSpliterator.nextCompleted 1 com.pivovarit.collectors.CompletionOrderSpliterator.nextCompleted
Tryadvance2 Entities in CompletionOrderSpliterator.tryAdvance 1 com.pivovarit.collectors.CompletionOrderSpliterator.tryAdvance
Trysplit2 Entities in CompletionOrderSpliterator.trySplit 1 com.pivovarit.collectors.CompletionOrderSpliterator.trySplit
Completionstrategy Entities in CompletionStrategy 1 com.pivovarit.collectors.CompletionStrategy
Configprocessor Entities in ConfigProcessor 1 com.pivovarit.collectors.ConfigProcessor
Process Entities in ConfigProcessor.process 1 com.pivovarit.collectors.ConfigProcessor.process
Tohumanreadablestring Entities in ConfigProcessor.toHumanReadableString 1 com.pivovarit.collectors.ConfigProcessor.toHumanReadableString
Deadline Entities in Deadline 1 com.pivovarit.collectors.Deadline
Deadline2 Entities in Deadline.Deadline 1 com.pivovarit.collectors.Deadline.Deadline
Remainingnanos Entities in Deadline.remainingNanos 1 com.pivovarit.collectors.Deadline.remainingNanos
Dispatcher Entities in Dispatcher 1 com.pivovarit.collectors.Dispatcher
Dispatcher2 Entities in Dispatcher.Dispatcher 1 com.pivovarit.collectors.Dispatcher.Dispatcher
Abort Entities in Dispatcher.abort 1 com.pivovarit.collectors.Dispatcher.abort
Registerterminationguard Entities in Dispatcher.registerTerminationGuard 1 com.pivovarit.collectors.Dispatcher.registerTerminationGuard
Retry Entities in Dispatcher.retry 1 com.pivovarit.collectors.Dispatcher.retry
Start Entities in Dispatcher.start 1 com.pivovarit.collectors.Dispatcher.start
Stop Entities in Dispatcher.stop 1 com.pivovarit.collectors.Dispatcher.stop
Submit Entities in Dispatcher.submit 1 com.pivovarit.collectors.Dispatcher.submit
Wasshutdown Entities in Dispatcher.wasShutdown 1 com.pivovarit.collectors.Dispatcher.wasShutdown
Wasstarted Entities in Dispatcher.wasStarted 1 com.pivovarit.collectors.Dispatcher.wasStarted
Factory Entities in Factory 1 com.pivovarit.collectors.Factory
Factory2 Entities in Factory.Factory 1 com.pivovarit.collectors.Factory.Factory
Collecting Entities in Factory.collecting 1 com.pivovarit.collectors.Factory.collecting
Collectingby Entities in Factory.collectingBy 1 com.pivovarit.collectors.Factory.collectingBy
Select Entities in Factory.select 1 com.pivovarit.collectors.Factory.select
Streaming Entities in Factory.streaming 1 com.pivovarit.collectors.Factory.streaming
Streamingby Entities in Factory.streamingBy 1 com.pivovarit.collectors.Factory.streamingBy
Futurecollectors Entities in FutureCollectors 1 com.pivovarit.collectors.FutureCollectors
Tofuture Entities in FutureCollectors.toFuture 1 com.pivovarit.collectors.FutureCollectors.toFuture
Interruptiblecompletablefuture Entities in InterruptibleCompletableFuture 1 com.pivovarit.collectors.InterruptibleCompletableFuture
Cancel Entities in InterruptibleCompletableFuture.cancel 1 com.pivovarit.collectors.InterruptibleCompletableFuture.cancel
Completedby Entities in InterruptibleCompletableFuture.completedBy 1 com.pivovarit.collectors.InterruptibleCompletableFuture.completedBy
Parallelcollectors Entities in ParallelCollectors 1 com.pivovarit.collectors.ParallelCollectors
Parallelcollectors2 Entities in ParallelCollectors.ParallelCollectors 1 com.pivovarit.collectors.ParallelCollectors.ParallelCollectors
Parallel Entities in ParallelCollectors.parallel 1 com.pivovarit.collectors.ParallelCollectors.parallel
Parallelby Entities in ParallelCollectors.parallelBy 1 com.pivovarit.collectors.ParallelCollectors.parallelBy
Paralleltostream Entities in ParallelCollectors.parallelToStream 1 com.pivovarit.collectors.ParallelCollectors.parallelToStream
Paralleltostreamby Entities in ParallelCollectors.parallelToStreamBy 1 com.pivovarit.collectors.ParallelCollectors.parallelToStreamBy
Tofuture2 Entities in ParallelCollectors.toFuture 1 com.pivovarit.collectors.ParallelCollectors.toFuture
Preconditions Entities in Preconditions 1 com.pivovarit.collectors.Preconditions
Preconditions2 Entities in Preconditions.Preconditions 1 com.pivovarit.collectors.Preconditions.Preconditions
Requirevalidexecutor Entities in Preconditions.requireValidExecutor 1 com.pivovarit.collectors.Preconditions.requireValidExecutor
Requirevalidparallelism Entities in Preconditions.requireValidParallelism 1 com.pivovarit.collectors.Preconditions.requireValidParallelism
Requirevalidtimeout Entities in Preconditions.requireValidTimeout 1 com.pivovarit.collectors.Preconditions.requireValidTimeout
Streamingconfigurer Entities in StreamingConfigurer 1 com.pivovarit.collectors.StreamingConfigurer
Streamingconfigurer2 Entities in StreamingConfigurer.StreamingConfigurer 1 com.pivovarit.collectors.StreamingConfigurer.StreamingConfigurer
Addonce2 Entities in StreamingConfigurer.addOnce 1 com.pivovarit.collectors.StreamingConfigurer.addOnce
Batching3 Entities in StreamingConfigurer.batching 1 com.pivovarit.collectors.StreamingConfigurer.batching
Executor2 Entities in StreamingConfigurer.executor 1 com.pivovarit.collectors.StreamingConfigurer.executor
Executordecorator2 Entities in StreamingConfigurer.executorDecorator 1 com.pivovarit.collectors.StreamingConfigurer.executorDecorator
Getconfig2 Entities in StreamingConfigurer.getConfig 1 com.pivovarit.collectors.StreamingConfigurer.getConfig
Ordered Entities in StreamingConfigurer.ordered 1 com.pivovarit.collectors.StreamingConfigurer.ordered
Parallelism2 Entities in StreamingConfigurer.parallelism 1 com.pivovarit.collectors.StreamingConfigurer.parallelism
Taskdecorator2 Entities in StreamingConfigurer.taskDecorator 1 com.pivovarit.collectors.StreamingConfigurer.taskDecorator
Timeout Entities in StreamingConfigurer.timeout 1 com.pivovarit.collectors.StreamingConfigurer.timeout
Validate2 Entities in StreamingConfigurer.validate 1 com.pivovarit.collectors.StreamingConfigurer.validate

Architectural Smells (0)

No architectural smells detected. The architecture appears well-structured.

Dependency Summary

PackageEntities
com.pivovarit.collectors 124