public class EntityToRow
extends org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<com.google.datastore.v1.Entity>,org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.Row>>
PTransform
to perform a conversion of Entity
to Row
.Modifier and Type | Method and Description |
---|---|
static EntityToRow |
create(org.apache.beam.sdk.schemas.Schema schema,
java.lang.String keyField)
Create a PTransform instance.
|
org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.Row> |
expand(org.apache.beam.sdk.values.PCollection<com.google.datastore.v1.Entity> input) |
public static EntityToRow create(org.apache.beam.sdk.schemas.Schema schema, java.lang.String keyField)
schema
- Schema
of the target row.keyField
- A name of the row field to store the Key
in.PTransform
instance for Entity to Row conversion.public org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.Row> expand(org.apache.beam.sdk.values.PCollection<com.google.datastore.v1.Entity> input)
expand
in class org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<com.google.datastore.v1.Entity>,org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.Row>>