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

	@Override
	public void stopTrackingAndReleaseClusterPartitions(Collection<IntermediateDataSetID> dataSetsToRelease) {
		for (IntermediateDataSetID dataSetID : dataSetsToRelease) {
			final DataSetEntry dataSetEntry = clusterPartitions.remove(dataSetID);
			final Set<ResultPartitionID> partitionIds = dataSetEntry.getPartitionIds();
			shuffleEnvironment.releasePartitionsLocally(partitionIds);
		}
	}

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

}