v2/googlecloud-to-googlecloud/src/main/java/com/google/cloud/teleport/v2/utils/FirestoreConverters.java [433:450]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public PCollectionTuple expand(PCollection<String> entityJson) {
      TupleTag<Entity> goodTag = new TupleTag<>();
      DatastoreV1.Write datastoreWrite =
          DatastoreIO.v1().write().withProjectId(projectId()).withHintNumWorkers(hintNumWorkers());
      if (!throttleRampup()) {
        datastoreWrite = datastoreWrite.withRampupThrottlingDisabled();
      }

      PCollectionTuple entities =
          entityJson
              .apply("StringToEntity", ParDo.of(new JsonToEntity()))
              .apply(
                  "CheckSameKey",
                  CheckSameKey.newBuilder().setErrorTag(errorTag()).setGoodTag(goodTag).build());

      entities.get(goodTag).apply("WriteToDatastore", datastoreWrite);
      return entities;
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



v1/src/main/java/com/google/cloud/teleport/templates/common/DatastoreConverters.java [416:433]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public PCollectionTuple expand(PCollection<String> entityJson) {
      TupleTag<Entity> goodTag = new TupleTag<>();
      DatastoreV1.Write datastoreWrite =
          DatastoreIO.v1().write().withProjectId(projectId()).withHintNumWorkers(hintNumWorkers());
      if (!throttleRampup()) {
        datastoreWrite = datastoreWrite.withRampupThrottlingDisabled();
      }

      PCollectionTuple entities =
          entityJson
              .apply("StringToEntity", ParDo.of(new JsonToEntity()))
              .apply(
                  "CheckSameKey",
                  CheckSameKey.newBuilder().setErrorTag(errorTag()).setGoodTag(goodTag).build());

      entities.get(goodTag).apply("WriteToDatastore", datastoreWrite);
      return entities;
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -