-
class
DeMuxExchange is opposite of MuxExchange.
class
Multiplexing Exchange (MuxExchange) is used when results from multiple minor fragments belonging to the same
major fragment running on a node need to be collected at one fragment on the same node before distributing the
results further.
class
class
class
class
OrderedMuxExchange is a version of MuxExchange where the incoming batches are sorted
merge operation is performed to produced a sorted stream as output.
class
class
class
class
class
UnorderedDeMuxExchange is a version of DeMuxExchange where the incoming batches are not sorted.
class
UnorderedMuxExchange is a version of MuxExchange where the incoming batches are not sorted.