Google云数据流，自定义源的工作原理

I am trying to build a custom source by extending BoundedSource using google cloud dataflow APIs. I would like to know how and when the custom source's start() and advance() method will be invoked by dataflow platfrom? If someone can explain the method invocation flow for custom source, will help alot.

我试图通过使用谷歌云数据流API扩展BoundedSource来构建自定义源。我想知道数据流平台如何以及何时调用自定义源的start（）和advance（）方法？如果有人可以解释自定义源的方法调用流程，将有很多帮助。

1 个解决方案

#1

The Javadoc for Source.Reader describes the interactions with the Reader.

Source.Reader的Javadoc描述了与Reader的交互。