public static class SpannerIO.WriteGrouped
extends <any>
SpannerIO.Write
but supports grouped mutations.Constructor and Description |
---|
WriteGrouped(SpannerIO.Write spec) |
Modifier and Type | Method and Description |
---|---|
SpannerWriteResult |
expand(PCollection<MutationGroup> input) |
public WriteGrouped(SpannerIO.Write spec)
public SpannerWriteResult expand(PCollection<MutationGroup> input)