データストアエンティティを作成し、データフローパイプラインでそれを使用するための正しい方法は何であるデータストアエンティティを作成するための好適な/正しい方法でこれらの

Question

：

// First, create a fake email for our fake user 
    final String email = "me@fake.com"; 

    // Now, create a 'key' for that user using the email 
    final Key userKey = 
      datastore.newKeyFactory().kind("user").newKey(email); 

    // Now create a entity using that key adn add some fields to it 
    final Entity newUser = 
      Entity 
        .builder(userKey) 
        .set("name", "Faker") 
        .set("email", email) 
        .build(); 

か、DatastoreWordCount exampleで行われているようには？

• 最初の例のエンティティはcom.google.cloud.datastore.Entityです。
• 2番目の例のエンティティはcom.google.datastore.v1.Entityです。

私はオンラインで見つけるすべてのコード例が示唆するので、私はcom.google.cloud.datastore.Entityを使用してコードを持っていると私は、データフローパイプラインの一部としてそれをデータストアに保存する方法がわからない：

com.google.cloud.dataflow.sdk.io.datastore.DatastoreIO.v1().write() 

それだけで作業していますcom.google.datastore.v1.Entity。

私はcom.google.cloud.dataflow:google-cloud-dataflow-java-sdk-all:1.7.0を使用しています。

Answer 1

状況をよく分析しました - データフローのDatastoreIO.v1()はcom.google.datastore.v1.Entityで動作します。