Java benchmarks support

.gitignore

@@ -188,3 +188,6 @@ cache
 # IntelliJ IDEA files
 .idea
 *.iml
+
+# Visual Studio Code files
+.vscode/

benchmarks/600.java/601.hello-world/config.json

@@ -0,0 +1,6 @@
+{
+    "timeout": 60,
+    "memory": 256,
+    "languages": ["java"]
+}
+

benchmarks/600.java/601.hello-world/input.py

@@ -0,0 +1,5 @@
+def buckets_count():
+    return (0, 0)
+
+def generate_input(data_dir, size, benchmarks_bucket, input_paths, output_paths, upload_func):
+    return { }

benchmarks/600.java/601.hello-world/java/pom.xml

@@ -0,0 +1,45 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <groupId>faas</groupId>
+    <artifactId>benchmark</artifactId>
+    <version>1</version>
+
+    <properties>
+        <maven.compiler.source>8</maven.compiler.source>
+        <maven.compiler.target>8</maven.compiler.target>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+    </properties>
+
+    <dependencies>
+        <!-- https://mvnrepository.com/artifact/com.google.code.gson/gson -->
+        <dependency>
+            <groupId>com.google.code.gson</groupId>
+            <artifactId>gson</artifactId>
+            <version>2.11.0</version>
+        </dependency>
+    </dependencies>
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-shade-plugin</artifactId>
+                <version>3.2.4</version>
+                <executions>
+                    <execution>
+                        <phase>package</phase>
+                        <goals>
+                            <goal>shade</goal>
+                        </goals>
+                        <configuration>
+                            <createDependencyReducedPom>false</createDependencyReducedPom>
+                        </configuration>
+                    </execution>
+                </executions>
+            </plugin>
+        </plugins>
+    </build>
+</project>

benchmarks/600.java/601.hello-world/java/src/main/java/faas/App.java

@@ -0,0 +1,11 @@
+package faas;
+import com.google.gson.JsonObject;
+
+public class App {
+    public JsonObject handler(JsonObject args) {
+
+        JsonObject jsonResult = new JsonObject();
+        jsonResult.addProperty("Hello", "World");
+        return jsonResult;
+    }
+}

benchmarks/wrappers/aws/java/Handler.java

@@ -0,0 +1,75 @@
+import com.amazonaws.services.lambda.runtime.Context;
+import com.amazonaws.services.lambda.runtime.RequestHandler;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.core.type.TypeReference;
+
+import faas.App;
+
+import java.io.File;
+import java.io.IOException;
+import java.time.Instant;
+import java.util.HashMap;
+import java.util.Map;
+
+public class Handler implements RequestHandler<Map<String, Object>, String> {
+    private static final ObjectMapper mapper = new ObjectMapper();
+
+    @Override
+    public String handleRequest(Map<String, Object> event, Context context) {
+
+        Map<String, Object> inputData = event;
+
+        // Extract input if trigger is API Gateway (body is a string)
+        if (event.containsKey("body") && event.get("body") instanceof String)
+            try {
+                inputData = mapper.readValue((String) event.get("body"),new TypeReference<Map<String, Object>>() {});
+            } catch (IOException e) {
+                throw new RuntimeException("Failed to parse JSON body", e);
+            }
+
+        App function = new App();
+
+        Instant begin = Instant.now();
+        long start_nano = System.nanoTime();
+
+        Map<String, Object> functionOutput = function.handler(inputData);
+
+        long end_nano = System.nanoTime();
+        Instant end = Instant.now();
+
+
+        long computeTime = end_nano - start_nano;
+        // Detect cold start
+        boolean isCold = false;
+        String fileName = "/tmp/cold_run"; 
+
+        File file = new File(fileName);
+        if (!file.exists()) {
+            isCold = true;
+            try {
+                file.createNewFile();
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+        }
+
+        // Convert to Unix timestamp in seconds.microseconds
+        String formattedBegin = String.format("%d.%06d", begin.getEpochSecond(), begin.getNano() / 1000); // Convert nanoseconds to microseconds
+        String formattedEnd = String.format("%d.%06d", end.getEpochSecond(), end.getNano() / 1000);
+
+
+        Map<String, Object> result = new HashMap<>();
+        result.put("begin", formattedBegin); 
+        result.put("end", formattedEnd);
+        result.put("request_id", context.getAwsRequestId());  
+        result.put("compute_time", computeTime);
+        result.put("is_cold", isCold);
+        result.put("result", functionOutput);
+        try {
+            return mapper.writeValueAsString(result);
+        } catch (IOException e) {
+            throw new RuntimeException("Failed to serialize result of benchmark to JSON in Wrapper", e);
+        }
+
+    }
+}

benchmarks/wrappers/openwhisk/java/Main.java

@@ -0,0 +1,55 @@
+import faas.App;
+import com.google.gson.JsonObject;
+import java.time.Instant;
+import java.time.Duration;
+import java.io.File;
+import java.io.IOException;
+
+
+public class Main {
+    public static JsonObject main(JsonObject args) {
+
+        App function = new App();
+
+        long start_nano = System.nanoTime();
+
+        Instant begin = Instant.now();
+        JsonObject result = function.handler(args);
+        Instant end = Instant.now();
+
+        long end_nano = System.nanoTime();
+
+        // long computeTime = Duration.between(begin, end).toNanos() / 1000; // Convert nanoseconds to microseconds
+
+        long computeTime = end_nano - start_nano;
+        boolean isCold = false;
+        String fileName = "/tmp/cold_run"; 
+
+        File file = new File(fileName);
+        if (!file.exists()) {
+            isCold = true;
+            try {
+                file.createNewFile();
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
+        }
+
+        // Convert to Unix timestamp in seconds.microseconds
+        String formattedBegin = String.format("%d.%06d", begin.getEpochSecond(), begin.getNano() / 1000); // Convert nanoseconds to microseconds
+        String formattedEnd = String.format("%d.%06d", end.getEpochSecond(), end.getNano() / 1000);
+
+        String requestId = System.getenv("__OW_ACTIVATION_ID");  
+
+        JsonObject jsonResult = new JsonObject();
+        jsonResult.addProperty("begin", formattedBegin); 
+        jsonResult.addProperty("end", formattedEnd);
+        jsonResult.addProperty("request_id", requestId);  
+        jsonResult.addProperty("compute_time", computeTime);
+        jsonResult.addProperty("is_cold", isCold);
+        jsonResult.addProperty("result", result.toString());
+        return jsonResult;
+    }
+
+}
+

config/example2.json

@@ -0,0 +1,69 @@
+{
+    "experiments": {
+      "deployment": "openwhisk",
+      "update_code": false,
+      "update_storage": false,
+      "download_results": false,
+      "runtime": {
+        "language": "java",
+        "version": "8"
+      },
+      "type": "invocation-overhead",
+      "perf-cost": {
+        "benchmark": "601.hello-world",
+        "experiments": ["cold", "warm", "burst", "sequential"],
+        "input-size": "test",
+        "repetitions": 50,
+        "concurrent-invocations": 50,
+        "memory-sizes": [128, 256]
+      },
+      "network-ping-pong": {
+        "invocations": 50,
+        "repetitions": 1000,
+        "threads": 1
+      },
+      "invocation-overhead": {
+        "repetitions": 5,
+        "N": 20,
+        "type": "payload",
+        "payload_begin": 1024,
+        "payload_end": 6251000,
+        "payload_points": 20,
+        "code_begin": 1048576,
+        "code_end": 261619712,
+        "code_points": 20
+      },
+      "eviction-model": {
+        "invocations": 1,
+        "function_copy_idx": 0,
+        "repetitions": 5,
+        "sleep": 1
+      }
+    },
+    "deployment": {
+      "openwhisk": {
+        "shutdownStorage": false,
+        "removeCluster": false,
+        "wskBypassSecurity": "true",
+        "wskExec": "wsk",
+        "experimentalManifest": false,
+        "docker_registry": {
+          "registry": "",
+          "username": "",
+          "password": ""
+        },
+        "storage": {
+          "address": "",
+          "mapped_port": 9011,
+          "access_key": "",
+          "secret_key": "",
+          "instance_id": "",
+          "output_buckets": [],
+          "input_buckets": [],
+          "type": "minio"
+         }
+
+      }
+    }
+  }
+

config/systems.json

@@ -316,6 +316,24 @@
             "minio": "7.0.16"
           }
         }
+      },
+      "java": {
+        "base_images": {
+          "8": "openwhisk/java8action"
+        },
+        "images": [
+          "function"
+        ],
+        "username": "docker_user",
+        "deployment": {
+          "files": [
+            "Main.java",
+            "Storage.java"
+          ],
+          "packages": {
+            "minio": "8.5.9"
+          }
+        }
       }
     },
     "architecture": ["x64"],

dockerfiles/openwhisk/java/Dockerfile.function

@@ -0,0 +1,8 @@
+ARG BASE_IMAGE
+FROM $BASE_IMAGE
+COPY . /function/
+
+# RUN apt-get update && apt-get install -y maven
+
+# # Check if pom.xml exists before running Maven
+# RUN if [ -f ./pom.xml ]; then mvn clean install; else echo "pom.xml not found, aborting build." && exit 1; fi

sebs.py

@@ -64,7 +64,7 @@ def simplified_common_params(func):
     @click.option(
         "--language",
         default=None,
-        type=click.Choice(["python", "nodejs"]),
+        type=click.Choice(["python", "nodejs", "java"]),
         help="Benchmark language",
     )
     @click.option("--language-version", default=None, type=str, help="Benchmark language version")