[
https://issues.apache.org/jira/browse/TEZ-844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Siddharth Seth updated TEZ-844:
-------------------------------
Attachment: TEZ-844.3.txt
bq. am just saying from what I see in the input code changes for all inputs in
the patch.
All input code needs to change to handle these methods - which is where the
additional method comes in. 857 may allow additional non Processor facing APIs
which can be called by the framework - such as a check on isInputReady(), or
waitForInputReady.
Updated patch with fixes etc. Added a unit test for the loop bug.
> Processors should have a mechanism to know when an Input is ready for
> consumption
> ---------------------------------------------------------------------------------
>
> Key: TEZ-844
> URL: https://issues.apache.org/jira/browse/TEZ-844
> Project: Apache Tez
> Issue Type: Improvement
> Reporter: Siddharth Seth
> Assignee: Siddharth Seth
> Attachments: TEZ-844.1.wip.txt, TEZ-844.2.txt, TEZ-844.3.txt
>
>
> Instead of polling, or blocking on a specific Reader, Processors should be
> able to find out when a specific Input is ready.
--
This message was sent by Atlassian JIRA
(v6.1.5#6160)
