[jira] [Created] (FLINK-1870) Reintroduce Indexed reader functionality to streaming

[Shang Yuanchun (Jira)]

Gyula Fora created FLINK-1870:
---------------------------------

             Summary: Reintroduce Indexed reader functionality to streaming
                 Key: FLINK-1870
                 URL: https://issues.apache.org/jira/browse/FLINK-1870
             Project: Flink
          Issue Type: Task
          Components: Streaming
            Reporter: Gyula Fora
            Priority: Minor


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.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)