...
Code Block | ||
---|---|---|
| ||
interface ShuffleMaster<T extends ShuffleDescriptor> extends AutoCloseable interface ShuffleMaster<T extends ShuffleDescriptor> extends AutoCloseable { // other methods /** * Get all partitions and their metrics, the metrics mainly includes the meta information of partition(partition bytes, etc). * @param jobId ID of the target job @param jobId ID of the target job * @return All partitions belongs to the target job and their metrics @return All partitions belongs to the target job and their metrics */ Collection<PartitionWithMetrics> getAllPartitionWithMetrics(JobID jobId CompletableFuture<Collection<PartitionWithMetrics>> getAllPartitionWithMetrics(JobID jobId); interface PartitionWithMetrics interface PartitionWithMetrics { ShuffleMetrics ShuffleMetrics getPartitionMetricsgetPartitionMetrics(); ShuffleDescriptor getPartition ShuffleDescriptor getPartition(); } interface ShuffleMetrics interface ShuffleMetrics { ResultPartitionBytes getPartitionBytes ResultPartitionBytes getPartitionBytes(); } } |
Compatibility, Deprecation, and Migration Plan
...