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.
Client to send messages or task events via network for
The task event publisher is used for publishing the event to the registered
A connection manager implementation to bypass setup overhead for task managers running in local execution mode.
The implementation of
Netty based shuffle service implementation.
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–2021 The Apache Software Foundation. All rights reserved.