Skip to content

Instantly share code, notes, and snippets.

Embed
What would you like to do?
pubsub.apply(Flatten.<TableRow>pCollections())
.apply("Fixed Windows",
Window.<TableRow>into(FixedWindows.of(Duration.standardMinutes(1))))
.apply("BQWrite", BigQueryIO.writeTableRows()
.to(TableRefPartition.perDay(
"my-project",
"my-dataset",
"my-tables"))
.withSchema(SchemaFor.backupEvent())
.withWriteDisposition(BigQueryIO.Write.WriteDisposition.WRITE_APPEND)
.withCreateDisposition(BigQueryIO.Write.CreateDisposition.CREATE_NEVER)
);
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
You can’t perform that action at this time.