samples: add delete samples (#1472)

Author: kolea2

README.md

@@ -502,6 +502,13 @@ Samples are in the [`samples/`](https://github.com/googleapis/java-bigtable/tree
 | Write Conditionally | [source code](https://github.com/googleapis/java-bigtable/blob/main/samples/snippets/src/main/java/com/example/bigtable/WriteConditionally.java) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/java-bigtable&page=editor&open_in_editor=samples/snippets/src/main/java/com/example/bigtable/WriteConditionally.java) |
 | Write Increment | [source code](https://github.com/googleapis/java-bigtable/blob/main/samples/snippets/src/main/java/com/example/bigtable/WriteIncrement.java) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/java-bigtable&page=editor&open_in_editor=samples/snippets/src/main/java/com/example/bigtable/WriteIncrement.java) |
 | Write Simple | [source code](https://github.com/googleapis/java-bigtable/blob/main/samples/snippets/src/main/java/com/example/bigtable/WriteSimple.java) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/java-bigtable&page=editor&open_in_editor=samples/snippets/src/main/java/com/example/bigtable/WriteSimple.java) |
+| Batch Delete Example | [source code](https://github.com/googleapis/java-bigtable/blob/main/samples/snippets/src/main/java/com/example/bigtable/deletes/BatchDeleteExample.java) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/java-bigtable&page=editor&open_in_editor=samples/snippets/src/main/java/com/example/bigtable/deletes/BatchDeleteExample.java) |
+| Conditional Delete Example | [source code](https://github.com/googleapis/java-bigtable/blob/main/samples/snippets/src/main/java/com/example/bigtable/deletes/ConditionalDeleteExample.java) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/java-bigtable&page=editor&open_in_editor=samples/snippets/src/main/java/com/example/bigtable/deletes/ConditionalDeleteExample.java) |
+| Delete Column Cells Example | [source code](https://github.com/googleapis/java-bigtable/blob/main/samples/snippets/src/main/java/com/example/bigtable/deletes/DeleteColumnCellsExample.java) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/java-bigtable&page=editor&open_in_editor=samples/snippets/src/main/java/com/example/bigtable/deletes/DeleteColumnCellsExample.java) |
+| Delete Column Family Example | [source code](https://github.com/googleapis/java-bigtable/blob/main/samples/snippets/src/main/java/com/example/bigtable/deletes/DeleteColumnFamilyExample.java) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/java-bigtable&page=editor&open_in_editor=samples/snippets/src/main/java/com/example/bigtable/deletes/DeleteColumnFamilyExample.java) |
+| Delete Row Example | [source code](https://github.com/googleapis/java-bigtable/blob/main/samples/snippets/src/main/java/com/example/bigtable/deletes/DeleteRowExample.java) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/java-bigtable&page=editor&open_in_editor=samples/snippets/src/main/java/com/example/bigtable/deletes/DeleteRowExample.java) |
+| Delete Table Example | [source code](https://github.com/googleapis/java-bigtable/blob/main/samples/snippets/src/main/java/com/example/bigtable/deletes/DeleteTableExample.java) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/java-bigtable&page=editor&open_in_editor=samples/snippets/src/main/java/com/example/bigtable/deletes/DeleteTableExample.java) |
+| Drop Row Range Example | [source code](https://github.com/googleapis/java-bigtable/blob/main/samples/snippets/src/main/java/com/example/bigtable/deletes/DropRowRangeExample.java) | [![Open in Cloud Shell][shell_img]](https://console.cloud.google.com/cloudshell/open?git_repo=https://github.com/googleapis/java-bigtable&page=editor&open_in_editor=samples/snippets/src/main/java/com/example/bigtable/deletes/DropRowRangeExample.java) |
 
 
 

samples/snippets/src/main/java/com/example/bigtable/deletes/BatchDeleteExample.java

@@ -0,0 +1,44 @@
+/*
+ * Copyright 2022 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.example.bigtable.deletes;
+
+// [START bigtable_streaming_and_batching]
+import com.google.api.gax.batching.Batcher;
+import com.google.api.gax.rpc.ServerStream;
+import com.google.cloud.bigtable.data.v2.BigtableDataClient;
+import com.google.cloud.bigtable.data.v2.models.Query;
+import com.google.cloud.bigtable.data.v2.models.Row;
+import com.google.cloud.bigtable.data.v2.models.RowMutationEntry;
+import java.io.IOException;
+
+public class BatchDeleteExample {
+ public void batchDelete(String projectId, String instanceId, String tableId)
+ throws InterruptedException, IOException {
+ try (BigtableDataClient dataClient = BigtableDataClient.create(projectId, instanceId)) {
+ try (Batcher<RowMutationEntry, Void> batcher = dataClient.newBulkMutationBatcher(tableId)) {
+ ServerStream<Row> rows = dataClient.readRows(Query.create(tableId));
+ for (Row row : rows) {
+ batcher.add(
+ RowMutationEntry.create(row.getKey()).deleteCells("cell_plan", "data_plan_05gb"));
+ }
+ // Blocks until mutations are applied on all submitted row entries.
+ batcher.flush();
+ }
+ }
+ }
+}
+// [END bigtable_streaming_and_batching]

samples/snippets/src/main/java/com/example/bigtable/deletes/ConditionalDeleteExample.java

@@ -0,0 +1,39 @@
+/*
+ * Copyright 2022 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.example.bigtable.deletes;
+
+// [START bigtable_delete_check_and_mutate]
+import com.google.cloud.bigtable.data.v2.BigtableDataClient;
+import com.google.cloud.bigtable.data.v2.models.ConditionalRowMutation;
+import com.google.cloud.bigtable.data.v2.models.Filters;
+import com.google.cloud.bigtable.data.v2.models.Mutation;
+import java.io.IOException;
+
+public class ConditionalDeleteExample {
+ public void conditionalDelete(String projectId, String instanceId, String tableId)
+ throws IOException {
+ try (BigtableDataClient dataClient = BigtableDataClient.create(projectId, instanceId)) {
+ Filters.Filter condition = Filters.FILTERS.value().exactMatch("PQ2A.190405.004");
+ Mutation mutation = Mutation.create().deleteCells("stats_summary", "os_build");
+ dataClient.checkAndMutateRow(
+ ConditionalRowMutation.create(tableId, "phone#4c410523#20190502")
+ .condition(condition)
+ .then(mutation));
+ }
+ }
+}
+// [END bigtable_delete_check_and_mutate]

samples/snippets/src/main/java/com/example/bigtable/deletes/DeleteColumnCellsExample.java

@@ -0,0 +1,34 @@
+/*
+ * Copyright 2022 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.example.bigtable.deletes;
+
+// [START bigtable_delete_from_column]
+import com.google.cloud.bigtable.data.v2.BigtableDataClient;
+import com.google.cloud.bigtable.data.v2.models.Mutation;
+import com.google.cloud.bigtable.data.v2.models.RowMutation;
+import java.io.IOException;
+
+public class DeleteColumnCellsExample {
+ public void deleteColumnCells(String projectId, String instanceId, String tableId)
+ throws IOException {
+ try (BigtableDataClient dataClient = BigtableDataClient.create(projectId, instanceId)) {
+ Mutation mutation = Mutation.create().deleteCells("cell_plan", "data_plan_01gb");
+ dataClient.mutateRow(RowMutation.create(tableId, "phone#4c410523#20190501", mutation));
+ }
+ }
+}
+// [END bigtable_delete_from_column]

samples/snippets/src/main/java/com/example/bigtable/deletes/DeleteColumnFamilyExample.java

@@ -0,0 +1,33 @@
+/*
+ * Copyright 2022 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.example.bigtable.deletes;
+
+// [START bigtable_delete_column_family]
+import com.google.cloud.bigtable.data.v2.BigtableDataClient;
+import com.google.cloud.bigtable.data.v2.models.RowMutation;
+import java.io.IOException;
+
+public class DeleteColumnFamilyExample {
+ public void deleteColumnFamily(String projectId, String instanceId, String tableId)
+ throws IOException {
+ try (BigtableDataClient dataClient = BigtableDataClient.create(projectId, instanceId)) {
+ dataClient.mutateRow(
+ RowMutation.create(tableId, "phone#5c10102#20190501").deleteFamily("stats_summary"));
+ }
+ }
+}
+// [END bigtable_delete_column_family]

samples/snippets/src/main/java/com/example/bigtable/deletes/DeleteRowExample.java

@@ -0,0 +1,33 @@
+/*
+ * Copyright 2022 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.example.bigtable.deletes;
+
+// [START bigtable_delete_from_row]
+import com.google.cloud.bigtable.data.v2.BigtableDataClient;
+import com.google.cloud.bigtable.data.v2.models.Mutation;
+import com.google.cloud.bigtable.data.v2.models.RowMutation;
+import java.io.IOException;
+
+public class DeleteRowExample {
+ public void deleteRow(String projectId, String instanceId, String tableId) throws IOException {
+ try (BigtableDataClient dataClient = BigtableDataClient.create(projectId, instanceId)) {
+ Mutation mutation = Mutation.create().deleteRow();
+ dataClient.mutateRow(RowMutation.create(tableId, "phone#4c410523#20190501", mutation));
+ }
+ }
+}
+// [END bigtable_delete_from_row]

samples/snippets/src/main/java/com/example/bigtable/deletes/DeleteTableExample.java

@@ -0,0 +1,31 @@
+/*
+ * Copyright 2022 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.example.bigtable.deletes;
+
+// [START bigtable_delete_table]
+import com.google.cloud.bigtable.admin.v2.BigtableTableAdminClient;
+import java.io.IOException;
+
+public class DeleteTableExample {
+ public void deleteTable(String projectId, String instanceId, String tableId) throws IOException {
+ try (BigtableTableAdminClient tableAdminClient =
+ BigtableTableAdminClient.create(projectId, instanceId)) {
+ tableAdminClient.deleteTable(tableId);
+ }
+ }
+}
+// [END bigtable_delete_table]

samples/snippets/src/main/java/com/example/bigtable/deletes/DropRowRangeExample.java

@@ -0,0 +1,31 @@
+/*
+ * Copyright 2022 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.example.bigtable.deletes;
+
+// [START bigtable_drop_row_range]
+import com.google.cloud.bigtable.admin.v2.BigtableTableAdminClient;
+import java.io.IOException;
+
+public class DropRowRangeExample {
+ public void dropRowRange(String projectId, String instanceId, String tableId) throws IOException {
+ try (BigtableTableAdminClient tableAdminClient =
+ BigtableTableAdminClient.create(projectId, instanceId)) {
+ tableAdminClient.dropRowRange(tableId, "phone#4c410523");
+ }
+ }
+}
+// [END bigtable_drop_row_range]

samples/snippets/src/test/java/com/example/bigtable/MobileTimeSeriesBaseTest.java

@@ -170,7 +170,9 @@ public static void writePlanData() throws IOException {
  public static void cleanupTable() throws IOException {
  try (BigtableTableAdminClient adminClient =
  BigtableTableAdminClient.create(projectId, instanceId)) {
- adminClient.deleteTable(TABLE_ID);
+ if (adminClient.exists(TABLE_ID)) {
+ adminClient.deleteTable(TABLE_ID);
+ }
  } catch (Exception e) {
  System.out.println("Error during afterClass: \n" + e.toString());
  throw (e);