[FLINK-1870] Reintroduce Indexed reader functionality to streaming

• Type: Improvement
• Status: Closed
• Priority: Minor
• Resolution: Not A Problem
• Assignee: Matthias J. Sax
• Reporter: Gyula Fora
• Created: 10/Apr/15 16:24
• Updated: 27/Apr/21 18:04
• Resolved: 07/Feb/16 22:37

Description

The Indexed record reader classes (IndexedReaderIterator, IndexedMutableReader) were introduced to allow the streaming operators to access the index of the last read channel from the input gate. This was a necessary step toward future input sorting operators.

Unfortunately this untested feature was patched away by the following commit:

https://github.com/apache/flink/commit/5232c56b13b7e13e2cf10dbe818c221f5557426d

At some point we need to reimplement these features with proper tests.