public static class BigtableWriteSchemaTransformProvider.GetMutationsFromBeamRow
extends org.apache.beam.sdk.transforms.SimpleFunction<org.apache.beam.sdk.values.Row,org.apache.beam.sdk.values.KV<com.google.protobuf.ByteString,java.lang.Iterable<com.google.bigtable.v2.Mutation>>>
Constructor and Description |
---|
GetMutationsFromBeamRow() |
Modifier and Type | Method and Description |
---|---|
org.apache.beam.sdk.values.KV<com.google.protobuf.ByteString,java.lang.Iterable<com.google.bigtable.v2.Mutation>> |
apply(org.apache.beam.sdk.values.Row row) |
fromSerializableFunctionWithOutputType
public org.apache.beam.sdk.values.KV<com.google.protobuf.ByteString,java.lang.Iterable<com.google.bigtable.v2.Mutation>> apply(org.apache.beam.sdk.values.Row row)
apply
in interface org.apache.beam.sdk.transforms.ProcessFunction<org.apache.beam.sdk.values.Row,org.apache.beam.sdk.values.KV<com.google.protobuf.ByteString,java.lang.Iterable<com.google.bigtable.v2.Mutation>>>
apply
in interface org.apache.beam.sdk.transforms.SerializableFunction<org.apache.beam.sdk.values.Row,org.apache.beam.sdk.values.KV<com.google.protobuf.ByteString,java.lang.Iterable<com.google.bigtable.v2.Mutation>>>
apply
in class org.apache.beam.sdk.transforms.SimpleFunction<org.apache.beam.sdk.values.Row,org.apache.beam.sdk.values.KV<com.google.protobuf.ByteString,java.lang.Iterable<com.google.bigtable.v2.Mutation>>>