| Package | Description |
|---|---|
| org.apache.flink.runtime.executiongraph | |
| org.apache.flink.runtime.profiling | |
| org.apache.flink.runtime.profiling.impl |
| Modifier and Type | Method and Description |
|---|---|
ExecutionGraph |
ExecutionVertex.getExecutionGraph() |
ExecutionGraph |
ExecutionJobVertex.getGraph() |
| Constructor and Description |
|---|
ExecutionJobVertex(ExecutionGraph graph,
AbstractJobVertex jobVertex,
int defaultParallelism,
scala.concurrent.duration.FiniteDuration timeout) |
ExecutionJobVertex(ExecutionGraph graph,
AbstractJobVertex jobVertex,
int defaultParallelism,
scala.concurrent.duration.FiniteDuration timeout,
long createTimestamp) |
| Modifier and Type | Method and Description |
|---|---|
void |
JobManagerProfiler.registerProfilingJob(ExecutionGraph executionGraph)
Registers the given
ExecutionGraph for profiling. |
void |
JobManagerProfiler.unregisterProfilingJob(ExecutionGraph executionGraph)
Unregisters the given
ExecutionGraph from profiling. |
| Modifier and Type | Method and Description |
|---|---|
ExecutionGraph |
JobProfilingData.getExecutionGraph() |
| Constructor and Description |
|---|
JobProfilingData(ExecutionGraph executionGraph) |
Copyright © 2014–2015 The Apache Software Foundation. All rights reserved.