flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Hequn Cheng (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-8550) Iterate over entryset instead of keys
Date Fri, 02 Feb 2018 09:21:00 GMT
Hequn Cheng created FLINK-8550:
----------------------------------

             Summary: Iterate over entryset instead of keys
                 Key: FLINK-8550
                 URL: https://issues.apache.org/jira/browse/FLINK-8550
             Project: Flink
          Issue Type: Improvement
          Components: Table API &amp; SQL
            Reporter: Hequn Cheng
            Assignee: Hequn Cheng


Iterate over entrysets instead of keys when we want to get both key and value. 

For example, in \{{ProcTimeBoundedRangeOver}}:
{code:java}
// code placeholder
val iter = rowMapState.keys.iterator
val markToRemove = new ArrayList[Long]()
while (iter.hasNext) {
    val elementKey = iter.next
    if (elementKey < limit) {
        ...
        val elementsRemove = rowMapState.get(elementKey)
        ...
    }
}
{code}
 



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Mime
View raw message