[
https://issues.apache.org/jira/browse/PIG-3937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rohini Palaniswamy updated PIG-3937:
------------------------------------
Attachment: PIG-3937-2.patch
Attached patch addressing review comment. Slight change to logic is needed
though as you cannot do readers.next() and then do readers.hasNext().
{code}
do {
if (currentReader.next()) {
Tuple origTuple = (Tuple) currentReader.getCurrentValue();
Tuple copy = mTupleFactory.newTuple(origTuple.getAll());
return new Result(POStatus.STATUS_OK, copy);
}
currentReader = readers.hasNext() ? readers.next() : null;
} while (currentReader != null);
{code}
> Use unsorted shuffle in Union
> -----------------------------
>
> Key: PIG-3937
> URL: https://issues.apache.org/jira/browse/PIG-3937
> Project: Pig
> Issue Type: Sub-task
> Reporter: Rohini Palaniswamy
> Assignee: Rohini Palaniswamy
> Fix For: tez-branch
>
> Attachments: PIG-3937-1.patch, PIG-3937-2.patch
>
>
> TEZ-661 provides unsorted shuffle
--
This message was sent by Atlassian JIRA
(v6.2#6252)