Class BigtableReadSchemaTransformProvider.BigtableRowToBeamRow
- java.lang.Object
-
- org.apache.beam.sdk.transforms.InferableFunction<InputT,OutputT>
-
- org.apache.beam.sdk.transforms.SimpleFunction<com.google.bigtable.v2.Row,org.apache.beam.sdk.values.Row>
-
- org.apache.beam.sdk.io.gcp.bigtable.BigtableReadSchemaTransformProvider.BigtableRowToBeamRow
-
- All Implemented Interfaces:
java.io.Serializable,org.apache.beam.sdk.transforms.display.HasDisplayData,org.apache.beam.sdk.transforms.ProcessFunction<com.google.bigtable.v2.Row,org.apache.beam.sdk.values.Row>,org.apache.beam.sdk.transforms.SerializableFunction<com.google.bigtable.v2.Row,org.apache.beam.sdk.values.Row>
- Enclosing class:
- BigtableReadSchemaTransformProvider
public static class BigtableReadSchemaTransformProvider.BigtableRowToBeamRow extends org.apache.beam.sdk.transforms.SimpleFunction<com.google.bigtable.v2.Row,org.apache.beam.sdk.values.Row>- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description BigtableRowToBeamRow()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.apache.beam.sdk.values.Rowapply(com.google.bigtable.v2.Row bigtableRow)-
Methods inherited from class org.apache.beam.sdk.transforms.SimpleFunction
fromSerializableFunctionWithOutputType
-
-
-
-
Method Detail
-
apply
public org.apache.beam.sdk.values.Row apply(com.google.bigtable.v2.Row bigtableRow)
- Specified by:
applyin interfaceorg.apache.beam.sdk.transforms.ProcessFunction<com.google.bigtable.v2.Row,org.apache.beam.sdk.values.Row>- Specified by:
applyin interfaceorg.apache.beam.sdk.transforms.SerializableFunction<com.google.bigtable.v2.Row,org.apache.beam.sdk.values.Row>- Overrides:
applyin classorg.apache.beam.sdk.transforms.SimpleFunction<com.google.bigtable.v2.Row,org.apache.beam.sdk.values.Row>
-
-