public static class SpannerIO.WriteGrouped extends org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<MutationGroup>,SpannerWriteResult>
SpannerIO.Write
but supports grouped mutations.Constructor and Description |
---|
WriteGrouped(SpannerIO.Write spec) |
Modifier and Type | Method and Description |
---|---|
SpannerWriteResult |
expand(org.apache.beam.sdk.values.PCollection<MutationGroup> input) |
void |
populateDisplayData(org.apache.beam.sdk.transforms.display.DisplayData.Builder builder) |
public WriteGrouped(SpannerIO.Write spec)
public void populateDisplayData(org.apache.beam.sdk.transforms.display.DisplayData.Builder builder)
populateDisplayData
in interface org.apache.beam.sdk.transforms.display.HasDisplayData
populateDisplayData
in class org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<MutationGroup>,SpannerWriteResult>
public SpannerWriteResult expand(org.apache.beam.sdk.values.PCollection<MutationGroup> input)
expand
in class org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<MutationGroup>,SpannerWriteResult>