class BatchShuffleStageParallelismCalculator {

	public void calculate(Collection<ShuffleStage> shuffleStages) {
		Set<ShuffleStage> shuffleStageSet = new HashSet<>(shuffleStages);
		shuffleStageSet.forEach(this::calculate);
	}

	public  BatchShuffleStageParallelismCalculator(Configuration tableConf, int envParallelism);

}