public class StreamingWriteTables<ElementT> extends org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<TableDestination,ElementT>>,WriteResult>
TableRow
entries and the TableDestination
it should be written to. The BigQuery streaming-write service is used to stream
these writes to the appropriate table.
This transform assumes that all destination tables already exist by the time it sees a write for that table.
Constructor and Description |
---|
StreamingWriteTables() |
Modifier and Type | Method and Description |
---|---|
WriteResult |
expand(org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<TableDestination,ElementT>> input) |
public WriteResult expand(org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<TableDestination,ElementT>> input)
expand
in class org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<TableDestination,ElementT>>,WriteResult>