samples: add delete samples

samples/snippets/src/main/java/com/example/bigtable/deletes/DeleteCheckAndMutateExample.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_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 DeleteCheckAndMutateExample {
+  public void checkAndMutate(
+      String projectId,
+      String instanceId,
+      String tableId,
+      String rowKey,
+      String family,
+      String qualifier) {
+    try (BigtableDataClient dataClient = BigtableDataClient.create(projectId, instanceId)) {
+      Filters.Filter condition = Filters.FILTERS.qualifier().exactMatch(qualifier);
+      Mutation mutation = Mutation.create().deleteCells(family, qualifier);
+      dataClient.checkAndMutateRow(
+          ConditionalRowMutation.create(tableId, rowKey).condition(condition).then(mutation));
+    } catch (IOException e) {
+      System.err.println("An exception has occurred: " + e.getMessage());
+    }
+  }
+}
+// [END bigtable_delete_check_and_mutate]

samples/snippets/src/main/java/com/example/bigtable/deletes/DeleteColumnFamilyExample.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_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, String rowKey, String familyName) {
+    try (BigtableDataClient dataClient = BigtableDataClient.create(projectId, instanceId)) {
+      dataClient.mutateRow(RowMutation.create(tableId, rowKey).deleteFamily(familyName));
+    } catch (IOException e) {
+      System.err.println("An exception has occurred: " + e.getMessage());
+    }
+  }
+}
+// [END bigtable_delete_column_family]

samples/snippets/src/main/java/com/example/bigtable/deletes/DeleteDropRowRangeExample.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_drop_row_range]
+import com.google.cloud.bigtable.admin.v2.BigtableTableAdminClient;
+import java.io.IOException;
+
+public class DeleteDropRowRangeExample {
+  public void dropRowRange(String projectId, String instanceId, String tableId, String rowPrefix) {
+    try (BigtableTableAdminClient tableAdminClient =
+        BigtableTableAdminClient.create(projectId, instanceId)) {
+      tableAdminClient.dropRowRange(tableId, rowPrefix);
+    } catch (IOException e) {
+      System.err.println("An exception has occurred: " + e.getMessage());
+    }
+  }
+}
+// [END bigtable_drop_row_range]

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

@@ -0,0 +1,41 @@
+/*
+ * 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 DeleteFromColumnExample {
+  public void deleteFromColumn(
+      String projectId,
+      String instanceId,
+      String tableId,
+      String rowKey,
+      String familyName,
+      String qualifier) {
+    try (BigtableDataClient dataClient = BigtableDataClient.create(projectId, instanceId)) {
+      Mutation mutation = Mutation.create().deleteCells(familyName, qualifier);
+      dataClient.mutateRow(RowMutation.create(tableId, rowKey, mutation));
+    } catch (IOException e) {
+      System.err.println("An exception has occurred: " + e.getMessage());
+    }
+  }
+}
+// [END bigtable_delete_from_column]

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

@@ -0,0 +1,35 @@
+/*
+ * 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 DeleteFromRowExample {
+  public void deleteFromRow(String projectId, String instanceId, String tableId, String rowKey) {
+    try (BigtableDataClient dataClient = BigtableDataClient.create(projectId, instanceId)) {
+      Mutation mutation = Mutation.create().deleteRow();
+      dataClient.mutateRow(RowMutation.create(tableId, rowKey, mutation));
+    } catch (IOException e) {
+      System.err.println("An exception has occurred: " + e.getMessage());
+    }
+  }
+}
+// [END bigtable_delete_from_row]

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

@@ -0,0 +1,49 @@
+/*
+ * 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.Filters;
+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 DeleteStreamingAndBatchingExample {
+  public void streamingAndBatching(
+      String projectId, String instanceId, String tableId, String familyName, String qualifier) {
+    try (BigtableDataClient dataClient = BigtableDataClient.create(projectId, instanceId)) {
+      try (Batcher<RowMutationEntry, Void> batcher = dataClient.newBulkMutationBatcher(tableId)) {
+        ServerStream<Row> rows =
+            dataClient.readRows(Query.create(tableId).filter(Filters.FILTERS.pass()));
+        for (Row row : rows) {
+          batcher.add(RowMutationEntry.create(row.getKey()).deleteCells(familyName, qualifier));
+        }
+        // Blocks until mutations are applied on all submitted row entries.
+        batcher.flush();
+      } catch (InterruptedException e) {
+        e.printStackTrace();
+      }
+    } catch (IOException e) {
+      System.err.println("An exception has occurred: " + e.getMessage());
+    }
+  }
+}
+// [END bigtable_streaming_and_batching]

samples/snippets/src/main/java/com/example/bigtable/deletes/DeleteTableExample.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_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) {
+    try (BigtableTableAdminClient tableAdminClient =
+        BigtableTableAdminClient.create(projectId, instanceId)) {
+      tableAdminClient.deleteTable(tableId);
+    } catch (IOException e) {
+      System.err.println("An exception has occurred: " + e.getMessage());
+    }
+  }
+}
+// [END bigtable_delete_table]

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);