Details

    • Type: Bug Bug
    • Status: Closed
    • Priority: Major Major
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 0.9.0
    • Component/s: None
    • Labels:
      None
    • Release Note:
      Docs updated. See PIG-1772 and patch pig-1772-beta2-1.patch

      Description

      The current implementation of inner in case of cogroup is in conflict with join. We need to decide of whether to fix inner cogroup or just remove the functionality if it is not widely used

        Activity

        Hide
        Olga Natkovich added a comment -

        We need to document that this functionality is deprecated

        Show
        Olga Natkovich added a comment - We need to document that this functionality is deprecated
        Hide
        Olga Natkovich added a comment -

        It looks like we already do not mention inner or outer keywords neither in the syntax of group/cogroup, nor in any discussions.

        The only place I found the reference is in examples where I suggest to do the following:

        • remove all examples from GROUP section that refer to INNER cogroup
        • There is also example in the description of IsEmpty function that uses inner cogroup, it should be changed to an outer join as follows:

        SSN = load 'ssn.txt' using PigStorage() as (ssn:long);

        SSN_NAME = load 'students.txt' using PigStorage() as (ssn:long, name:chararray);

        – do a left out join of SSN with SSN_Name
        X = JOIN SSN by ssn LEFT OUTER, SSN_NAME by ssn;

        – only keep those ssn's for which there is no name
        Y = filter X by IsEmpty(SSN_NAME);

        Show
        Olga Natkovich added a comment - It looks like we already do not mention inner or outer keywords neither in the syntax of group/cogroup, nor in any discussions. The only place I found the reference is in examples where I suggest to do the following: remove all examples from GROUP section that refer to INNER cogroup There is also example in the description of IsEmpty function that uses inner cogroup, it should be changed to an outer join as follows: SSN = load 'ssn.txt' using PigStorage() as (ssn:long); SSN_NAME = load 'students.txt' using PigStorage() as (ssn:long, name:chararray); – do a left out join of SSN with SSN_Name X = JOIN SSN by ssn LEFT OUTER, SSN_NAME by ssn; – only keep those ssn's for which there is no name Y = filter X by IsEmpty(SSN_NAME);

          People

          • Assignee:
            Corinne Chandel
            Reporter:
            Olga Natkovich
          • Votes:
            0 Vote for this issue
            Watchers:
            0 Start watching this issue

            Dates

            • Created:
              Updated:
              Resolved:

              Development