• Type: Sub-task Sub-task
    • Status: Closed
    • Priority: Major Major
    • Resolution: Fixed
    • Affects Version/s: tez-branch
    • Fix Version/s: tez-branch
    • Component/s: tez
    • Labels:


      To support algebraic UDFs and others, combiner is required. To start with, I am proposing the following initial implementation-

      • In Tez, combiner runs as part of ShuffledMergedInput in edges, so multiple combine plans (one per edge) need to be registered in a destination vertex. Each vertex is mapped to a TezOperator in Tez plan, so an array of combine plans will be stored in the TezOperator that maps to a destination vertex.
      • To register combine plans in a TezOperator, we will run a CombinerOptimizer on the Tez plan after TezCompiler generates it but before TezDagBuilder converts it into DAG.
      • Finally, TezDagBuilder will insert combine plans into the payload of ShuffledMergedInput while constructing a destination vertex.

      This initial implementation will allow us to run algebraic UDFs. In the future, we can implement more optimizations for limit, order-by, etc on top of this.

      1. PIG-3555-4.patch
        127 kB
        Cheolsoo Park
      2. PIG-3555-3.patch
        126 kB
        Cheolsoo Park
      3. PIG-3555-2.patch
        115 kB
        Cheolsoo Park
      4. PIG-3555-1.patch
        114 kB
        Cheolsoo Park


        No work has yet been logged on this issue.


          • Assignee:
            Cheolsoo Park
            Cheolsoo Park
          • Votes:
            0 Vote for this issue
            2 Start watching this issue


            • Created: