docs: public static int calOperatorParallelism(double rowCount, Configuration tableConf) {
  		int maxParallelism = getOperatorMaxParallelism(tableConf);
  		int minParallelism = getOperatorMinParallelism(tableConf);
  		int resultParallelism = (int) (rowCount / getRowCountPerPartition(tableConf));
  		return Math.max(Math.min(resultParallelism, maxParallelism), minParallelism);
  	}