class FinalParallelismSetter {

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

	private  FinalParallelismSetter(StreamExecutionEnvironment env);

}