flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Huang Wei (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-2534) Improve execution code in CompactingHashTable.java
Date Mon, 17 Aug 2015 03:02:45 GMT
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)

Mime
View raw message