Skip to content

Instantly share code, notes, and snippets.

@polleyg

polleyg/beam_sql_part_3.java

Created January 23, 2019 06:42
Show Gist options
  • Save polleyg/5eca9b45abf6fbcc3543cc7ad18556d8 to your computer and use it in GitHub Desktop.
Save polleyg/5eca9b45abf6fbcc3543cc7ad18556d8 to your computer and use it in GitHub Desktop.
Download ZIP
beam_sql_part_3
Raw
beam_sql_part_3.java
[..]
.apply("transform_sql", SqlTransform.query(
"SELECT lang, SUM(views) as sum_views " +
"FROM PCOLLECTION GROUP BY lang")
)
[..]
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment