public class StreamingWriteTables<ElementT> extends PTransform<PCollection<KV<TableDestination,ElementT>>,WriteResult>
TableRowentries and the
TableDestinationit 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|
|Modifier and Type||Method and Description|
Override this method to specify how this
compose, compose, getAdditionalInputs, getDefaultOutputCoder, getDefaultOutputCoder, getDefaultOutputCoder, getKindString, getName, getResourceHints, populateDisplayData, setResourceHints, toString, validate, validate
public WriteResult expand(PCollection<KV<TableDestination,ElementT>> input)
PTransformshould be expanded on the given
NOTE: This method should not be called directly. Instead apply the
be applied to the
InputT using the
Composite transforms, which are defined in terms of other transforms, should return the output of one of the composed transforms. Non-composite transforms, which do not apply any transforms internally, should return a new unbound output and register evaluators (via backend-specific registration methods).