def partitioning(self):
        joinp = super(ProjectingJoin, self).partitioning()

        return project_partitioning(self.output_columns, joinp)
Partitioning of a Join followed by a Project
dataset/ETHPy150Open uwescience/raco/raco/algebra.py/ProjectingJoin.partitioning