[FLINK-6544] Expose State Backend Interface for UDAGG

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Abandoned
• Component/s: Table SQL / API
• Assignee: Kaibo Zhou
• Reporter: Kaibo Zhou
• Created: 11/May/17 13:35
• Updated: 30/Jan/19 14:37
• Resolved: 30/Jan/19 10:28

Description

Currently UDAGG users can not access state, it's necessary to provide users with a convenient and efficient way to access the state within the UDAGG.

This is the design doc: https://docs.google.com/document/d/1g-wHOuFj5pMaYMJg90kVIO2IHbiQiO26nWscLIOn50c/edit#

Proposed Changes:
1. Implementation of DataView to support state access for UDAGG
2. Support getAccumulatorType when use DataView
3. Refactor build-in agg(MaxWithRetractAccumulator and MinWithRetractAccumulator) using the DataView
4. Support DataView in Java and Scala Tuples and Case classes or as the accumulator of AggregateFunction itself.

Issue Links

• links to: Design doc

Sub-Tasks

• Support DataView in Java and Scala Tuples and case classes or as the accumulator of AggregateFunction itself: Open