What is the correct behavior for an operator when it receives an
IterOutcome.STOP from upstream:
1. should it just stop right away and return STOP downstream ?, or
2. should it cleanup it's resources before returning STOP downstream ?

Some operators follow 1 and others (like OrderedPartitionRecordBatch)
follow 2.

-- 

Abdelhakim Deneche

Software Engineer

  <http://www.mapr.com/>


Now Available - Free Hadoop On-Demand Training
<http://www.mapr.com/training?utm_source=Email&utm_medium=Signature&utm_campaign=Free%20available>

Reply via email to