Module Expr Str Assign NameStore Str Import alias Import alias Import alias ImportFrom alias alias alias ClassDef bases NameLoad body Expr Str FunctionDef arguments args NameParam defaults vararg kwarg body Expr Str Expr Call AttributeLoad NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam defaults NameLoad NameLoad NameLoad NameLoad NameLoad NameLoad NameLoad NameLoad NameLoad NameLoad NameLoad NameLoad body If AttributeLoad NameLoad attr body Assign NameStore ListComp Call NameLoad NameLoad comprehension NameStore SubscriptLoad AttributeLoad NameLoad attr Index Num Assign NameStore ListLoad If NameLoad body Expr Call AttributeLoad NameLoad attr Call NameLoad NameLoad If NameLoad body Expr Call AttributeLoad NameLoad attr Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Call NameLoad NameLoad Expr Call AttributeLoad NameLoad attr Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Call NameLoad NameLoad If NameLoad body Expr Call AttributeLoad NameLoad attr Call NameLoad NameLoad If NameLoad body Expr Call AttributeLoad NameLoad attr Call NameLoad NameLoad If NameLoad body Expr Call AttributeLoad NameLoad attr NameLoad orelse If NameLoad body Expr Call AttributeLoad NameLoad attr ListComp Call AttributeLoad NameLoad attr comprehension NameStore NameLoad If NameLoad body Expr Call AttributeLoad NameLoad attr ListComp Call NameLoad NameLoad comprehension NameStore NameLoad If NameLoad body Expr Call AttributeLoad NameLoad attr Call NameLoad NameLoad If NameLoad body Expr Call AttributeLoad NameLoad attr Call NameLoad NameLoad orelse Expr Call AttributeLoad NameLoad attr NameLoad If CompareIs NameLoad NameLoad body Assign NameStore Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr Expr Call AttributeLoad NameLoad attr NameLoad orelse If NameLoad body Expr Call AttributeLoad NameLoad attr Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Call NameLoad NameLoad Expr Call AttributeLoad NameLoad attr Call NameLoad NameLoad If NameLoad body Expr Call AttributeLoad NameLoad attr Call NameLoad NameLoad If NameLoad body Expr Call AttributeLoad NameLoad attr Call NameLoad NameLoad If NameLoad body Expr Call AttributeLoad NameLoad attr NameLoad Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body If Call NameLoad NameLoad NameLoad body Assign NameStore Call AttributeLoad NameLoad attr keyword AttributeLoad NameLoad attr AttributeLoad NameLoad attr orelse Assign NameStore Call AttributeLoad NameLoad attr keyword NameLoad AttributeLoad NameLoad attr Return Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad decorator_list decorator_list FunctionDef arguments args defaults vararg kwarg body Expr Str Assign SubscriptStore NameLoad Index Str Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr If UnaryOpNot CompareIn Str NameLoad body Assign SubscriptStore NameLoad Index Str NameLoad Return Call NameLoad NameLoad NameLoad decorator_list FunctionDef arguments args defaults vararg kwarg body Expr Str Assign SubscriptStore NameLoad Index Str Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr If UnaryOpNot CompareIn Str NameLoad body Assign SubscriptStore NameLoad Index Str NameLoad Return Call NameLoad NameLoad NameLoad decorator_list FunctionDef arguments args defaults vararg kwarg body Expr Str Assign SubscriptStore NameLoad Index Str Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr If UnaryOpNot CompareIn Str NameLoad body Assign SubscriptStore NameLoad Index Str NameLoad Return Call NameLoad NameLoad NameLoad decorator_list FunctionDef arguments args defaults vararg kwarg body Expr Str Assign SubscriptStore NameLoad Index Str Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr If UnaryOpNot CompareIn Str NameLoad body Assign SubscriptStore NameLoad Index Str NameLoad Return Call NameLoad NameLoad NameLoad decorator_list
N/A N/A Operations related to a CoGroup pipe. N/A __author__ Gabor Szabo N/A cascading.pipe N/A cascading.pipe.cogroup N/A cascading.operation pycascading.pipe Operation coerce_to_fields _Stackable CoGroup N/A Operation N/A N/A CoGroup two or more streams on common fields.

    This is a PyCascading wrapper around a Cascading CoGroup.
     __init__ N/A N/A self N/A args kwargs N/A N/A Create a Cascading CoGroup pipe.

        Arguments:
        args[0] -- the fields on which to join

        Keyword arguments:
        group_name -- the groupName parameter for Cascading
        group_fields -- the fields on which to group
        declared_fields -- the declaredFields parameter for Cascading
        result_group_fields -- the resultGroupFields parameter for Cascading
        joiner -- the joiner parameter for Cascading
        num_self_joins -- the numSelfJoins parameter for Cascading
        lhs -- the lhs parameter for Cascading
        lhs_group_fields -- the lhsGroupFields parameter for Cascading
        rhs -- the rhs parameter for Cascading
        rhs_group_fields -- the rhsGroupFields parameter for Cascading
         N/A N/A N/A Operation __init__ self N/A N/A self __args args N/A N/A self __kwargs kwargs N/A __create_args N/A N/A self group_name pipes group_fields declared_fields result_group_fields joiner pipe num_self_joins lhs lhs_group_fields rhs rhs_group_fields N/A None None None None None None None None None None None None N/A N/A N/A self __args N/A N/A group_fields N/A N/A coerce_to_fields f N/A f N/A N/A self __args N/A 0 N/A args N/A N/A group_name N/A N/A N/A N/A args append N/A str group_name N/A lhs N/A N/A N/A N/A args append N/A N/A lhs get_assembly N/A N/A N/A args append N/A coerce_to_fields lhs_group_fields N/A N/A N/A args append N/A N/A rhs get_assembly N/A N/A N/A args append N/A coerce_to_fields rhs_group_fields N/A declared_fields N/A N/A N/A N/A args append N/A coerce_to_fields declared_fields N/A result_group_fields N/A N/A N/A N/A args append N/A coerce_to_fields result_group_fields N/A joiner N/A N/A N/A N/A args append joiner N/A N/A pipes N/A N/A N/A N/A args append N/A N/A N/A p get_assembly N/A p pipes N/A group_fields N/A N/A N/A N/A args append N/A N/A coerce_to_fields f N/A f group_fields N/A declared_fields N/A N/A N/A N/A args append N/A coerce_to_fields declared_fields N/A result_group_fields N/A N/A N/A N/A args append N/A coerce_to_fields result_group_fields N/A N/A N/A N/A args append None N/A N/A joiner None N/A N/A joiner N/A N/A N/A N/A cascading pipe cogroup InnerJoin N/A N/A N/A args append joiner N/A N/A pipe N/A N/A N/A N/A args append N/A N/A pipe get_assembly N/A N/A N/A args append N/A coerce_to_fields group_fields N/A N/A N/A args append N/A int num_self_joins N/A declared_fields N/A N/A N/A N/A args append N/A coerce_to_fields declared_fields N/A result_group_fields N/A N/A N/A N/A args append N/A coerce_to_fields result_group_fields N/A joiner N/A N/A N/A N/A args append joiner N/A args N/A _create_with_parent N/A N/A self parent N/A N/A N/A N/A isinstance parent _Stackable N/A N/A args N/A N/A self __create_args pipes N/A parent stack N/A self __kwargs N/A N/A args N/A N/A self __create_args pipe parent N/A self __kwargs N/A N/A N/A N/A cascading pipe CoGroup args N/A N/A inner_join N/A N/A N/A args kwargs N/A N/A Shortcut for an inner join. N/A N/A kwargs N/A joiner N/A N/A N/A N/A cascading pipe cogroup InnerJoin N/A N/A N/A declared_fields kwargs N/A N/A N/A kwargs N/A declared_fields None N/A N/A CoGroup args kwargs N/A outer_join N/A N/A N/A args kwargs N/A N/A Shortcut for an outer join. N/A N/A kwargs N/A joiner N/A N/A N/A N/A cascading pipe cogroup OuterJoin N/A N/A N/A declared_fields kwargs N/A N/A N/A kwargs N/A declared_fields None N/A N/A CoGroup args kwargs N/A left_outer_join N/A N/A N/A args kwargs N/A N/A Shortcut for a left outer join. N/A N/A kwargs N/A joiner N/A N/A N/A N/A cascading pipe cogroup LeftJoin N/A N/A N/A declared_fields kwargs N/A N/A N/A kwargs N/A declared_fields None N/A N/A CoGroup args kwargs N/A right_outer_join N/A N/A N/A args kwargs N/A N/A Shortcut for a right outer join. N/A N/A kwargs N/A joiner N/A N/A N/A N/A cascading pipe cogroup RightJoin N/A N/A N/A declared_fields kwargs N/A N/A N/A kwargs N/A declared_fields None N/A N/A CoGroup args kwargs N/A