An interface marking a task as capable of handling exceptions thrown by different threads, other than the one executing the task itself.
Responder for checkpoint acknowledge and decline messages in the
Actions which can be performed on a
Interface for the communication of the
Interface to access
Thread factory that creates threads with a given name, associates them with a given thread group, and set them to daemon mode.
This class wraps
A thread the periodically logs statistics about: Heap and non-heap memory usage Memory pools and pool usage Garbage collection times and counts
Configuration object for the network stack.
A dummy implementation of the
In implementation of the
The Task represents one execution of a parallel subtask on a TaskManager.
This class represents an update about a task's execution state.
This class encapsulates the connection information of a TaskManager.
This Supplier class could retrieve the FQDN host name of the given InetAddress on demand, extract the pure host name and cache the results for later use.
This Supplier class returns the IP address of the given InetAddress directly, therefore no reverse DNS lookup is required.
This class encapsulates the connection information of a TaskManager, without resolving the hostname.
Various operation of notify checkpoint.
The DNS resolution mode for TaskManager's IP address.
An exception for wrapping exceptions that are thrown by an operator in threads other than the main compute thread of that operator.
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.