Re: Controlling namespace when writing to DataStore

2018-09-02 Thread Csaba Kassai
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

Controlling namespace when writing to DataStore

2018-08-29 Thread Randal Moore
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?