[
https://issues.apache.org/jira/browse/FLINK-1870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15089649#comment-15089649
]
ASF GitHub Bot commented on FLINK-1870:
---------------------------------------
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1483#issuecomment-170083592
I am big time skeptic when it comes to putting this into the
`RuntimeContext`.
If we really need to expose that beyond the `StreamInputProcessor`, it
would probably be best to pass this into the operator, as part of the
"processRecord()" method.
Since StormBolts are implemented as custom operators, they should be able
to pick it up from there.
> 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
> Assignee: Matthias J. Sax
> 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)
