Как указать сценарий запуска в задании потока данных для Java, который будет выполняться на каждом работнике VM потока данных - PullRequest
0 голосов
/ 21 марта 2019

У меня есть требование изменить ~ / .ssh / authorized_keys для добавления пользовательских открытых ключей для входа в систему. Я нашел эту статью, которая предназначена для работы с Python. https://beam.apache.org/documentation/sdks/python-pipeline-dependencies/

Как мы можем сделать то же самое для задания потока данных Java.

...