Alex Indaco created BEAM-7048:
---------------------------------

             Summary: Fetch GCP-Datastore entity by id inside of a Dataflow 
transform
                 Key: BEAM-7048
                 URL: https://issues.apache.org/jira/browse/BEAM-7048
             Project: Beam
          Issue Type: New Feature
          Components: io-ideas
    Affects Versions: 2.11.0
            Reporter: Alex Indaco


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

 



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to