Как реализуется синтаксис канала в Apache Beam? - PullRequest
1 голос
/ 23 апреля 2019

Я сейчас учусь apache beam и из любопытства хотел бы задать вопрос ниже.

Заранее я прочитал ниже документы и темы.

https://beam.apache.org/documentation/programming-guide/#applying-transforms

Объясните синтаксис Python Apache Beam

Я понимаю, что pipe (|) - это версия Python .apply Java.Однако мне любопытно узнать, как Python интерпретирует оператор __or__ как процессор, который обрабатывает каждый элемент pcollection, проходящий слева направо.

Я ценю, если кто-то может научить меня и указать ссылку на код.

Спасибо, Ю

1 Ответ

0 голосов
/ 25 апреля 2019

Я бы хотел отметить ответ @Kolban как ответ.

Я сделал поиск в Google по "перегрузке оператора Python" и нашел куча хороших ссылок, которые кажутся вероятными. В поисках Github репозиторий, похоже, что это может быть реальный код: https://github.com/apache/beam/blob/master/sdks/python/apache_beam/transforms/ptransform.py#L470

...