---

sduskis · web-flow · commit 95c8ea8c2dcc · 2019-02-07T20:52:13.000-05:00
yaml --- r: 19191 b: refs/heads/autosynth-bigquerystorage c: 1baa602 h: refs/heads/master i: 19189: fb12073 19187: c8570f5 19183: 2b8eebc
diff --git a/[refs] b/[refs]
@@ -124,7 +124,7 @@ refs/tags/v0.69.0: 78f67a29e8b9c46ba01de566a2eae0fd1c03edea
 refs/heads/autosynth-asset: cd8251de8c40e239ad24dcf9ed93ea2708a3eed5
 refs/heads/autosynth-automl: 2a8b018cf05811fd472e5d1053e67a12ceec0b64
 refs/heads/autosynth-bigquerydatatransfer: 564833a85642d4194adc025f021e10e723154246
-refs/heads/autosynth-bigquerystorage: 81bdd008363130086ab4a328e28bfbe13ede8ed3
+refs/heads/autosynth-bigquerystorage: 1baa6023966a694c1ccd8ed8d5b47ece662b4fce
 refs/heads/autosynth-bigtable: 2fbcb15847e0e89e79d6dc07420e28d7dfcea894
 refs/heads/autosynth-bigtable-admin: 6379a2bc712f2736c83de0e009b4d26da4fa82ca
 refs/heads/autosynth-containeranalysis: 039ca5b8db725c76c16a965ff26b2774322b8ef8
diff --git a/branches/autosynth-bigquerystorage/google-cloud-clients/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/models/Mutation.java b/branches/autosynth-bigquerystorage/google-cloud-clients/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/models/Mutation.java
@@ -73,6 +73,19 @@ public static Mutation createUnsafe() {
     return new Mutation(true);
   }
 
+  /**
+   * Wraps the List of protobuf {@link com.google.bigtable.v2.Mutation}. This methods, like {@link
+   * #createUnsafe()}, allows setCell operation to use server side timestamp. This is dangerous
+   * because mutations will no longer be idempotent, which might cause multiple duplicate values to
+   * be stored in Bigtable. This option should only be used for advanced usecases with extreme care.
+   */
+  @BetaApi
+  public static Mutation fromProtoUnsafe(List<com.google.bigtable.v2.Mutation> protos) {
+    Mutation mutation = new Mutation(true);
+    mutation.mutations.addAll(protos);
+    return mutation;
+  }
+
   private Mutation(boolean allowServersideTimestamp) {
     this.allowServersideTimestamp = allowServersideTimestamp;
   }
diff --git a/branches/autosynth-bigquerystorage/google-cloud-clients/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/data/v2/models/MutationTest.java b/branches/autosynth-bigquerystorage/google-cloud-clients/google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/data/v2/models/MutationTest.java
@@ -95,6 +95,8 @@ public void setCellTest() {
     assertThat(actual.get(3).getSetCell().getValue())
         .isEqualTo(ByteString.copyFromUtf8("fake-value2"));
     assertThat(actual.get(3).getSetCell().getTimestampMicros()).isIn(expectedTimestampRange);
+
+    assertThat(Mutation.fromProtoUnsafe(actual).getMutations()).isEqualTo(actual);
   }
 
   @Test

Original file line number	Diff line number	Diff line change
`@@ -95,6 +95,8 @@ public void setCellTest() {`
`95`	`95`	`assertThat(actual.get(3).getSetCell().getValue())`
`96`	`96`	`.isEqualTo(ByteString.copyFromUtf8("fake-value2"));`
`97`	`97`	`assertThat(actual.get(3).getSetCell().getTimestampMicros()).isIn(expectedTimestampRange);`
	`98`	`+`
	`99`	`+ assertThat(Mutation.fromProtoUnsafe(actual).getMutations()).isEqualTo(actual);`
`98`	`100`	`}`
`99`	`101`
`100`	`102`	`@Test`