Package | Description |
---|---|
org.apache.flink.runtime.io.network.partition | |
org.apache.flink.runtime.taskexecutor |
Modifier and Type | Method and Description |
---|---|
ClusterPartitionReport |
TaskExecutorPartitionTracker.createClusterPartitionReport()
Creates a
ClusterPartitionReport , describing which cluster partitions are currently
available. |
ClusterPartitionReport |
TaskExecutorPartitionTrackerImpl.createClusterPartitionReport() |
Modifier and Type | Method and Description |
---|---|
void |
ResourceManagerPartitionTracker.processTaskExecutorClusterPartitionReport(ResourceID taskExecutorId,
ClusterPartitionReport clusterPartitionReport)
Processes
ClusterPartitionReport of a task executor. |
void |
ResourceManagerPartitionTrackerImpl.processTaskExecutorClusterPartitionReport(ResourceID taskExecutorId,
ClusterPartitionReport clusterPartitionReport) |
Modifier and Type | Method and Description |
---|---|
ClusterPartitionReport |
TaskExecutorHeartbeatPayload.getClusterPartitionReport() |
Constructor and Description |
---|
TaskExecutorHeartbeatPayload(SlotReport slotReport,
ClusterPartitionReport clusterPartitionReport) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.