Skip to content

Instantly share code, notes, and snippets.

@brunoripa
Created January 30, 2018 13:20
Show Gist options
  • Save brunoripa/e693c531d7a29bf4bfb6e7cb18795a68 to your computer and use it in GitHub Desktop.
Save brunoripa/e693c531d7a29bf4bfb6e7cb18795a68 to your computer and use it in GitHub Desktop.
with apache_beam.Pipeline(options=options) as p:
rows = (
p |
ReadFromText(input_filename) |
apache_beam.ParDo(Split())
)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment