Class and Description |
---|
DataExchangeMode
Defines how the data exchange between two specific operators happens.
|
Class and Description |
---|
TaskEventDispatcher
The task event dispatcher dispatches events flowing backwards from a consuming task to the task
producing the consumed result.
|
Class and Description |
---|
ConnectionID
A
ConnectionID identifies a connection to a remote task manager by the socket address and
a connection index. |
ConnectionManager
The connection manager manages physical connections for the (logical) remote input channels at
runtime.
|
DataExchangeMode
Defines how the data exchange between two specific operators happens.
|
NettyShuffleEnvironment
The implementation of
ShuffleEnvironment based on netty network communication, local
memory and disk files. |
PartitionRequestClient
Client to send messages or task events via network for
RemoteInputChannel . |
TaskEventPublisher
The task event publisher is used for publishing the event to the registered
EventListener
instances. |
Class and Description |
---|
ConnectionID
A
ConnectionID identifies a connection to a remote task manager by the socket address and
a connection index. |
ConnectionManager
The connection manager manages physical connections for the (logical) remote input channels at
runtime.
|
PartitionRequestClient
Client to send messages or task events via network for
RemoteInputChannel . |
TaskEventPublisher
The task event publisher is used for publishing the event to the registered
EventListener
instances. |
Class and Description |
---|
ConnectionID
A
ConnectionID identifies a connection to a remote task manager by the socket address and
a connection index. |
ConnectionManager
The connection manager manages physical connections for the (logical) remote input channels at
runtime.
|
TaskEventPublisher
The task event publisher is used for publishing the event to the registered
EventListener
instances. |
Class and Description |
---|
ConnectionID
A
ConnectionID identifies a connection to a remote task manager by the socket address and
a connection index. |
TaskEventPublisher
The task event publisher is used for publishing the event to the registered
EventListener
instances. |
Class and Description |
---|
TaskEventDispatcher
The task event dispatcher dispatches events flowing backwards from a consuming task to the task
producing the consumed result.
|
Class and Description |
---|
TaskEventDispatcher
The task event dispatcher dispatches events flowing backwards from a consuming task to the task
producing the consumed result.
|
Class and Description |
---|
TaskEventDispatcher
The task event dispatcher dispatches events flowing backwards from a consuming task to the task
producing the consumed result.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.