выполнить операцию соединения для pcollection луча apache в pthon, но получение объекта dict не имеет атрибута pipe

Question

results = ({'personal_data': read_Personal_Data, 'contact_data': read_Contact_Data} |
                beam.ParDo(Join()))

class Join(beam.DoFn):

    def process(self, element):
        if(element[0]['personal_data'][0]==element[0]['contact_data'][0]):
            result = [element[0]['personal_data'][0]]
        return result