flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-1870) Reintroduce Indexed reader functionality to streaming
Date Fri, 08 Jan 2016 18:31:39 GMT

    [ 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:

    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

View raw message