Class BeamRowToBigtableMutation.ToBigtableRowFn
java.lang.Object
org.apache.beam.sdk.transforms.InferableFunction<Row,KV<ByteString,Iterable<com.google.bigtable.v2.Mutation>>>
org.apache.beam.sdk.transforms.SimpleFunction<Row,KV<ByteString,Iterable<com.google.bigtable.v2.Mutation>>>
org.apache.beam.sdk.io.gcp.bigtable.BeamRowToBigtableMutation.ToBigtableRowFn
- All Implemented Interfaces:
Serializable
,HasDisplayData
,ProcessFunction<Row,
,KV<ByteString, Iterable<com.google.bigtable.v2.Mutation>>> SerializableFunction<Row,
KV<ByteString, Iterable<com.google.bigtable.v2.Mutation>>>
- Enclosing class:
BeamRowToBigtableMutation
public static class BeamRowToBigtableMutation.ToBigtableRowFn
extends SimpleFunction<Row,KV<ByteString,Iterable<com.google.bigtable.v2.Mutation>>>
- See Also:
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionKV
<ByteString, Iterable<com.google.bigtable.v2.Mutation>> Returns the result of invoking this function on the given input.Methods inherited from class org.apache.beam.sdk.transforms.SimpleFunction
fromSerializableFunctionWithOutputType
Methods inherited from class org.apache.beam.sdk.transforms.InferableFunction
fromProcessFunctionWithOutputType, getInputTypeDescriptor, getOutputTypeDescriptor, populateDisplayData
-
Constructor Details
-
ToBigtableRowFn
-
-
Method Details
-
apply
Description copied from interface:ProcessFunction
Returns the result of invoking this function on the given input.- Specified by:
apply
in interfaceProcessFunction<Row,
KV<ByteString, Iterable<com.google.bigtable.v2.Mutation>>> - Specified by:
apply
in interfaceSerializableFunction<Row,
KV<ByteString, Iterable<com.google.bigtable.v2.Mutation>>> - Overrides:
apply
in classSimpleFunction<Row,
KV<ByteString, Iterable<com.google.bigtable.v2.Mutation>>>
-