chamikaramj commented on code in PR #17674:
URL: https://github.com/apache/beam/pull/17674#discussion_r880807313
##########
examples/multi-language/src/main/java/org/apache/beam/examples/multilanguage/PythonDataframeWordCount.java:
##########
@@ -42,19 +41,20 @@
* An example that counts words in Shakespeare and utilizes a Python external
transform.
*
* <p>This class, {@link PythonDataframeWordCount}, uses Python
DataframeTransform to count words
- * from the input text file. The Python expansion service provided by
--expansionService must allow
- * the expansion of apache_beam.dataframe.transforms.DataframeTransform (which
can be done by
- * passing --fully_qualified_name_glob commandline option when launching the
expansion service).
+ * from the input text file.
*
- * <p>Note that, for using Dataflow Runner, you should specify the following
two additional
- * arguments:
+ * <p>The example command below shows how to run this pipeline on Dataflow
runner:
*
* <pre>{@code
- * --experiments=use_runner_v2
- *
--sdkHarnessContainerImageOverrides=.*python.*,gcr.io/apache-beam-testing/beam-sdk/beam_python3.8_sdk:latest
+ * ./gradlew :examples:multi-language:pythonDataframeWordCount --args=" \
+ * --runner=DataflowRunner \
+ * --output=gs://{$OUTPUT_BUCKET}/count \
+ * --experiments=use_runner_v2 \
Review Comment:
Is this required ? For Python if we detect multi-language transforms for
DataflowRunner we add this experiment automatically (can be updated in a
separate PR).
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
