Hi,
you can set the namespace in the key of the Datastore entity. Like this:
Key.Builder keyBuilder = DatastoreHelper.makeKey(...);
keyBuilder.getPartitionIdBuilder().setNamespace(namespace);
https://beam.apache.org/documentation/sdks/javadoc/2.6.0/org/apache/beam/sdk/io/gcp/datastore/DatastoreV
I cannot find a way to control which namespace I'm writing to when saving
to DataStore from a Beam/DataFlow job. I am using
org.apache.beam.sdk.io.gcp.datastore.DatastoreV1
I find the ability to control the namespace with the reader but not the writer.
Am I missing something obvious?