Details
-
New Feature
-
Status: Open
-
P3
-
Resolution: Unresolved
-
2.11.0
-
None
-
None
Description
I have a dataflow pipeline where first I queried one model, but then for each record that pointed to another model I wanted to be able to fetch that too.
Browsing the {{apache_beam & google.cloud.proto.datastore.v1 }}source I was able to make this happen:
https://stackoverflow.com/a/55616668/4458510
I copied the same mechanism from the other Datastore DoFn's and it seems to work fine, and I think something like this would be a good addition to apache_beam.io.gcp.datastore.v1.datastoreio in the sdk