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 Collection<ThreadInfoSample> |
ThreadInfoSample.from(Collection<ThreadInfo> threadInfos)
Constructs a collection of
ThreadInfoSample s from a collection of ThreadInfo
samples. |
static Optional<ThreadInfoSample> |
ThreadInfoSample.from(ThreadInfo threadInfo)
Constructs a
ThreadInfoSample from ThreadInfo . |
Collection<ThreadInfoSample> |
TaskThreadInfoResponse.getSamples()
Returns a collection of ThreadInfoSample.
|
Constructor and Description |
---|
TaskThreadInfoResponse(Collection<ThreadInfoSample> samples)
Creates a response to the request to collect thread details samples.
|
Modifier and Type | Method and Description |
---|---|
static Collection<ThreadInfoSample> |
JvmUtils.createThreadInfoSample(Collection<Long> threadIds,
int maxStackTraceDepth)
Creates a
ThreadInfoSample for a specific thread. |
static Optional<ThreadInfoSample> |
JvmUtils.createThreadInfoSample(long threadId,
int maxStackTraceDepth)
Creates a
ThreadInfoSample for a specific thread. |
Modifier and Type | Method and Description |
---|---|
Map<org.apache.flink.shaded.guava30.com.google.common.collect.ImmutableSet<ExecutionAttemptID>,Collection<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<org.apache.flink.shaded.guava30.com.google.common.collect.ImmutableSet<ExecutionAttemptID>,Collection<ThreadInfoSample>> samplesBySubtask)
Creates a thread details sample.
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.