refreshNodesInternal() |  | 0% |  | 0% | 23 | 23 | 99 | 99 | 1 | 1 |
pollWorkers() |  | 0% |  | 0% | 5 | 5 | 22 | 22 | 1 | 1 |
DiscoveryNodeManager(ServiceSelector, NodeInfo, FailureDetector, Optional, NodeVersion, HttpClient, DriftClient, InternalCommunicationConfig) |  | 0% | | n/a | 1 | 1 | 19 | 19 | 1 | 1 |
findCurrentNode(List, String, NodeVersion, boolean) |  | 0% |  | 0% | 5 | 5 | 20 | 20 | 1 | 1 |
getNodes(NodeState) |  | 0% |  | 0% | 4 | 4 | 5 | 5 | 1 | 1 |
isNodeShuttingDown(String) |  | 0% |  | 0% | 4 | 4 | 4 | 4 | 1 | 1 |
getRaftPort(ServiceDescriptor) |  | 0% |  | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
lambda$filterRelevantNodes$5(ServiceDescriptor) |  | 0% |  | 0% | 5 | 5 | 4 | 4 | 1 | 1 |
filterRelevantNodes() |  | 0% |  | 0% | 5 | 5 | 3 | 3 | 1 | 1 |
getHttpUri(ServiceDescriptor, boolean) |  | 0% |  | 0% | 3 | 3 | 5 | 5 | 1 | 1 |
addNodeChangeListener(Consumer) |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
getNodeState(InternalNode) |  | 0% |  | 0% | 3 | 3 | 5 | 5 | 1 | 1 |
getThriftServerPort(ServiceDescriptor) |  | 0% |  | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
getNodeVersion(ServiceDescriptor) |  | 0% |  | 0% | 2 | 2 | 2 | 2 | 1 | 1 |
getPoolType(ServiceDescriptor) |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
lambda$filterRelevantNodes$6(ServiceDescriptor) |  | 0% |  | 0% | 4 | 4 | 1 | 1 | 1 | 1 |
startPollingNodeStates() |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
getShuttingDownCoordinator() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
stop() |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
lambda$refreshNodesInternal$1(Set, ServiceDescriptor) |  | 0% |  | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
lambda$startPollingNodeStates$0() |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
static {...} |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
removeNodeChangeListener(Consumer) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
isCoordinator(ServiceDescriptor) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
isResourceManager(ServiceDescriptor) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
isCatalogServer(ServiceDescriptor) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
isCoordinatorSidecar(ServiceDescriptor) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getActiveNodeCount() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getInactiveNodeCount() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getShuttingDownNodeCount() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getActiveResourceManagerCount() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getActiveCoordinatorCount() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getActiveConnectorNodes(ConnectorId) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getAllConnectorNodes(ConnectorId) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$refreshNodesInternal$3(List, AllNodes) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$addNodeChangeListener$4(Consumer, AllNodes) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$null$2(AllNodes, Consumer) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
refreshNodes() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getAllNodes() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getCurrentNode() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getCoordinators() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getResourceManagers() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getCatalogServers() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getCoordinatorSidecars() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |