Huang Wei created FLINK-2534:
--------------------------------
Summary: Improve execution code in CompactingHashTable.java
Key: FLINK-2534
URL: https://issues.apache.org/jira/browse/FLINK-2534
Project: Flink
Issue Type: Improvement
Components: Local Runtime
Affects Versions: 0.10
Reporter: Huang Wei
Fix For: 0.10
I found some improved code in CompactingHashTable.java since this code will
execute many times when flink runs.
In my opinion, some codes in "for" and "while" can be optimized to reduce the
times of execution and it is effective to increase the performance.
For example, the code following:
'while(numBuckets % numPartitions != 0) {
numBuckets++;
}'
can be optimized into a formula:
numBuckets += numPartitions - (numBuckets % numPartitions);
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
