update example to use checkpoint delay (#237)

Author: zhongkechen

examples/src/main/java/software/amazon/lambda/durable/examples/ManyAsyncChildContextExample.java

@@ -5,6 +5,7 @@
 import java.time.Duration;
 import java.util.ArrayList;
 import java.util.concurrent.TimeUnit;
+import software.amazon.lambda.durable.DurableConfig;
 import software.amazon.lambda.durable.DurableContext;
 import software.amazon.lambda.durable.DurableFuture;
 import software.amazon.lambda.durable.DurableHandler;
@@ -66,4 +67,13 @@ public Output handleRequest(Input input, DurableContext context) {
 
         return new Output(totalSum, executionTimeMs, replayTimeMs);
     }
+
+    @Override
+    protected DurableConfig createConfiguration() {
+        // Add a small checkpoint delay to help batch the checkpoint requests and reduce the overall latencies
+        // when the function has many concurrent operations
+        return DurableConfig.builder()
+                .withCheckpointDelay(Duration.ofMillis(10))
+                .build();
+    }
 }

examples/src/main/java/software/amazon/lambda/durable/examples/ManyAsyncStepsExample.java

@@ -5,6 +5,7 @@
 import java.time.Duration;
 import java.util.ArrayList;
 import java.util.concurrent.TimeUnit;
+import software.amazon.lambda.durable.DurableConfig;
 import software.amazon.lambda.durable.DurableContext;
 import software.amazon.lambda.durable.DurableFuture;
 import software.amazon.lambda.durable.DurableHandler;
@@ -61,4 +62,13 @@ public Output handleRequest(Input input, DurableContext context) {
 
         return new Output(totalSum, executionTimeMs, replayTimeMs);
     }
+
+    @Override
+    protected DurableConfig createConfiguration() {
+        // Add a small checkpoint delay to help batch the checkpoint requests and reduce the overall latencies
+        // when the function has many concurrent operations
+        return DurableConfig.builder()
+                .withCheckpointDelay(Duration.ofMillis(10))
+                .build();
+    }
 }