class TaskExecutorPartitionTrackerImpl extends AbstractPartitionTracker<JobID, TaskExecutorPartitionInfo> implements TaskExecutorPartitionTracker {

	@Override
	public ClusterPartitionReport createClusterPartitionReport() {
		List<ClusterPartitionReport.ClusterPartitionReportEntry> reportEntries = clusterPartitions.entrySet().stream().map(entry ->
			new ClusterPartitionReport.ClusterPartitionReportEntry(
				entry.getKey(),
				entry.getValue().getPartitionIds(),
				entry.getValue().getTotalNumberOfPartitions()))
			.collect(Collectors.toList());

		return new ClusterPartitionReport(reportEntries);
	}

	public  TaskExecutorPartitionTrackerImpl(ShuffleEnvironment<?, ?> shuffleEnvironment);

}