The connection manager manages physical connections for the (logical) remote input channels at runtime.
Channel handler to read and write network messages on client side.
Simple wrapper for the partition readerQueue iterator, which increments a sequence number for each returned buffer and remembers the receiver ID.
A connection manager implementation to bypass setup overhead for task managers running in local execution mode.
Network I/O components of each
The task event dispatcher dispatches events flowing backwards from a consuming task to the task producing the consumed result.
Defines how the data exchange between two specific operators happens.
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.