This is an automated email from the ASF dual-hosted git repository.
mxm pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new e845da1 [BEAM-6730] Update docs for Python generate_sequence transform
new 23276fe Merge pull request #8321: [BEAM-6730] Update docs for Python
generate_sequence transform
e845da1 is described below
commit e845da1f478d2475624223db3a08a4ccc856cd90
Author: Maximilian Michels <[email protected]>
AuthorDate: Tue Apr 16 15:01:05 2019 +0200
[BEAM-6730] Update docs for Python generate_sequence transform
This provides more documentation similar to `kafka.py` to prevent users from
getting confused about how to use this external transform.
---
.../apache_beam/io/external/generate_sequence.py | 20 +++++++++++++++++++-
1 file changed, 19 insertions(+), 1 deletion(-)
diff --git a/sdks/python/apache_beam/io/external/generate_sequence.py
b/sdks/python/apache_beam/io/external/generate_sequence.py
index 4c9d0b8..8de68ab 100644
--- a/sdks/python/apache_beam/io/external/generate_sequence.py
+++ b/sdks/python/apache_beam/io/external/generate_sequence.py
@@ -27,7 +27,25 @@ from apache_beam.transforms import ptransform
class GenerateSequence(ptransform.PTransform):
"""
- A PTransform that provides a bounded or unbounded stream of integers.
+ An external PTransform which provides a bounded or unbounded stream of
+ integers.
+
+ Note: To use this transform, you need to start the Java expansion service.
+ Please refer to the portability documentation on how to do that. The
+ expansion service address has to be provided when instantiating this
+ transform. During pipeline translation this transform will be replaced by
+ the Java SDK's GenerateSequence.
+
+ If you start Flink's job server, the expansion service will be started on
+ port 8097. This is also the configured default for this transform. For a
+ different address, please set the expansion_service parameter.
+
+ For more information see:
+ - https://beam.apache.org/documentation/runners/flink/
+ - https://beam.apache.org/roadmap/portability/
+
+ Note: Runners need to support translating Read operations in order to use
+ this source. At the moment only the Flink Runner supports this.
"""
def __init__(self, start, stop=None,
