Beam Website Feedback

[Mo Brian]

Hi team,

I’m studying the apache beam from 
https://beam.apache.org/get-started/wordcount-example/#windowedwordcount-example

A bit lost on the windowed_wordcount.py and it’s start command:

windowed_wordcount.py input a pubsub message:
lines = p | beam.io.ReadFromPubSub(known_args.input_topic)

start command provide a file input:
python -m apache_beam.examples.windowed_wordcount --input YOUR_INPUT_FILE \
                                         --output_table PROJECT:DATASET.TABLE \
                                         --runner DataflowRunner \
                                         --project YOUR_GCP_PROJECT \
                                         --temp_location 
gs://YOUR_GCS_BUCKET/tmp/

Should I change the command here?

Thanks

Brian

Sent from Mail<https://go.microsoft.com/fwlink/?LinkId=550986> for Windows 10