[FLINK-16782] Avoid unnecessary check on expired time state when we set visibility as ReturnExpiredIfNotCleanedUp

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Implemented
• Affects Version/s: 1.10.0
• Fix Version/s: 1.11.0
• Component/s: Runtime / State Backends
• Labels: pull-request-available
• Assignee: Yun Tang
• Reporter: Yun Tang
• Created: 25/Mar/20 17:57
• Updated: 07/May/20 11:50
• Resolved: 07/May/20 11:50

Description

Current implementation of getting unexpired value would always check whether this ttl value is expired first:

// code placeholder
<V> V getUnexpired(TtlValue<V> ttlValue) {
        return ttlValue == null || (expired(ttlValue) && !returnExpired) ? null : ttlValue.getUserValue();
}

However, this check could be avoided if we set return expired time, we could improve the performance by check whether to returnExpired first.

Issue Links

• links to: GitHub Pull Request #11513