use async example

delta-io · Feb 3, 2025 · 9278d0b · 9278d0b
1 parent 0fc403d
commit 9278d0b
Showing 1 changed file with 10 additions and 4 deletions.
diff --git a/...ples/kernel-examples/src/main/java/io/delta/kernel/examples/CreateTableAndInsertData.java b/...ples/kernel-examples/src/main/java/io/delta/kernel/examples/CreateTableAndInsertData.java
@@ -410,11 +410,17 @@ public void insertWithOptionalCheckpoint(String tablePath) throws IOException {
         for (int i = 0; i < 12; i++) {
             TransactionCommitResult commitResult = insertDataIntoUnpartitionedTable(tablePath);
             for(PostCommitAction action: commitResult.getPostCommitActions())
-            if (action.getType().equals("checkpoint")) {
                 // Checkpoint the table
-               action.threadSafeInvoke();
-               didCheckpoint = true;
-            }
+                didCheckpoint = didCheckpoint || CompletableFuture.supplyAsync(() -> {
+                            // run the code async
+                            try{
+                                action.threadSafeInvoke();
+                            } catch (IOException e) {
+                                return false;
+                            }
+                            return action.getType().equals("checkpoint");
+                        }
+                ).join(); // wait async finish.
         }
 
         if (!didCheckpoint) {