Responder for checkpoint acknowledge and decline messages in the
Actions which can be performed on a
Interface to access
A wrapper of result partition writer for handling the logic of consumable notification.
Thread factory that creates threads with a given name, associates them with a given thread group, and set them to daemon mode.
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.
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.