1
Я пытаюсь создать пользовательский источник, расширив BoundedSource с помощью API-интерфейсов Google Cloud Dataflow. Я хотел бы знать, как и когда метод start() и advance() настраиваемого источника будет вызван потоком данных? Если кто-то может объяснить поток вызова метода для настраиваемого источника, он поможет много.Google cloud dataflow, как работает пользовательский источник
Что вы пробовали? Попробуйте сначала взглянуть на этот документ, чтобы узнать, как вы должны задавать вопросы и получать ответы. https://stackoverflow.com/help/how-to-ask –