class BatchFinalParallelismSetter {

	public static Map<ExecNode<?, ?>, Integer> calculate(TableEnvironment tEnv, List<ExecNode<?, ?>> sinkNodes) {
		BatchFinalParallelismSetter setter = new BatchFinalParallelismSetter(tEnv);
		sinkNodes.forEach(setter::calculate);
		return setter.finalParallelismNodeMap;
	}

	private  BatchFinalParallelismSetter(TableEnvironment tEnv);

}