pip install google-cloud-dataflow --user
python
import apache_beam as beam with beam.Pipeline() as p: p | beam.Create(['hello', 'world']) | beam.io.Write(beam.io.TextFileSink('./test'))
exit() more ./test*
0 件のコメント :
コメントを投稿