Package | Description |
---|---|
org.apache.flink.runtime.messages |
This package contains the messages that are sent between Flink's distributed components to
coordinate the distributed operations.
|
org.apache.flink.runtime.util | |
org.apache.flink.runtime.webmonitor.threadinfo |
Modifier and Type | Method and Description |
---|---|
static Optional<ThreadInfoSample> |
ThreadInfoSample.from(ThreadInfo threadInfo)
Constructs a
ThreadInfoSample from ThreadInfo . |
List<ThreadInfoSample> |
TaskThreadInfoResponse.getSamples()
Returns a list of ThreadInfoSample.
|
Constructor and Description |
---|
TaskThreadInfoResponse(List<ThreadInfoSample> samples)
Creates a response to the request to collect thread details samples.
|
Modifier and Type | Method and Description |
---|---|
static Optional<ThreadInfoSample> |
JvmUtils.createThreadInfoSample(long threadId,
int maxStackTraceDepth)
Creates a
ThreadInfoSample for a specific thread. |
Modifier and Type | Method and Description |
---|---|
Map<ExecutionAttemptID,List<ThreadInfoSample>> |
JobVertexThreadInfoStats.getSamplesBySubtask()
Returns the a map of thread info samples by subtask (execution ID).
|
Constructor and Description |
---|
JobVertexThreadInfoStats(int requestId,
long startTime,
long endTime,
Map<ExecutionAttemptID,List<ThreadInfoSample>> samplesBySubtask)
Creates a thread details sample.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.