Partitioning

The topology is being partitioned wherever it is capable of. By default all Beans are partiotionable, some that are not partiotinable implement interface io.wavebeans.lib.SinglePartitionBean:

Partitioning Topology

Splitting stream into partitions, processing them independently, and merging partitioned streams back to one solid stream:

Partitioning the stream

[TODO provide text with more explanation]