Skip to content
#

data

Here are 6,853 public repositories matching this topic...

bcleenders
bcleenders commented Oct 2, 2020

When a user wants to stream data to a date-partitioned BQ table, the way to do this is:

//noinspection ScalaStyle
class DayPartitionFunction()
  extends SerializableFunction[ValueInSingleWindow[TableRow], TableDestination] {
  override def apply(input: ValueInSingleWindow[TableRow]): TableDestination = {
    val partition = DateTimeFormat.forPattern("yyyyMMdd").withZone(DateTimeZo

Improve this page

Add a description, image, and links to the data topic page so that developers can more easily learn about it.

Curate this topic

Add this topic to your repo

To associate your repository with the data topic, visit your repo's landing page and select "manage topics."

Learn more

You can’t perform that action at this time.