I'm just getting started with running some Dataflow pipelines from Cloud Composer. I have a working java dataflow pipeline packaged as a jar file, and I can't get it to run from CC. Still reviewing this code with another developer, so not ready to post details yet.
In the meanwhile, a general question:
Is there a well-documented demo that shows how to run DataFlow pipelines from Cloud Composer? I have not been able to find any so far. I'd be looking for one demo for a java pipeline and one demo for a python pipeline. I'm looking for documentation of the process end-to-end, showing how to integrate my Dataflow code, build the environment (java or python, or if it is already built into CC, then demo that it's working right), install additional python dependencies that i may have, declare Airflow variables, etc. You know, a self-contained document that has all the steps needed to actually get something to work with my code, not just code snippets and fragments and pointers to other web sites. So a demo like the wordcount demo for Dataproc is not quite good enough (as it just runs pre-canned code, not my code.)
What's the best way to get started here?