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 & 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 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)

This message was sent by Atlassian JIRA

Reply via email to