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 ) ; }
Calculates operator parallelism based on rowcount of the operator .