java: Support modelbox flow JNI API.

Author: pymumu

.clang-tidy

@@ -68,5 +68,5 @@ Checks: >
   # clang-analyzer-optin.cplusplus.VirtualCall,
 
 # Turn all the warnings from the checks above into errors.
-HeaderFilterRegex: '(src|test/unit|test/drivers|test/mock)/*'
+HeaderFilterRegex: '((?!build/)src|test/unit|test/drivers|test/function|test/mock)/*'
 FormatStyle: file

.github/workflows/merge-request-ascend.yml

@@ -5,6 +5,10 @@ on:
     branches: 
       - main
 
+concurrency: 
+  group: ${{ github.head_ref && github.workflow}}
+  cancel-in-progress: true
+
 env:
   BUILD_TYPE: Release
 
@@ -17,16 +21,32 @@ jobs:
     steps:
     - uses: actions/checkout@v3
     - run: apt update
+    - name: Set up JDK 11
+      uses: actions/setup-java@v1
+      with:
+        java-version: 11
+        maven-version: '3.6.2'
+        cache: 'maven'
+    - name: Set up Maven
+      uses: stCarolas/setup-maven@v4.4
+      with:
+        maven-version: 3.8.2
+    - uses: actions/cache@v1
+      with:
+        path: /root/.m2/repository
+        key: ${{ runner.os }}-maven-${{ hashFiles('src/java/pom.xml') }}
+        restore-keys: |
+          ${{ runner.os }}-maven-
     - name: ccache
       uses: hendrikmuhs/ccache-action@v1.2
       with:
         key: ubuntu-latest
-        max-size: 1024M
+        max-size: 512M
     - name: Configure CMake
       run: |
         mkdir build
         cd build
-        cmake .. -DCMAKE_BUILD_TYPE=${{env.BUILD_TYPE}} -DWITH_WEBUI=off -DCLANG_TIDY=on -DCLANG_TIDY_AS_ERROR=on
+        cmake .. -DCMAKE_BUILD_TYPE=${{env.BUILD_TYPE}} -DWITH_WEBUI=off -DCLANG_TIDY=on -DCLANG_TIDY_AS_ERROR=on -DWITH_JAVA=on
 
     - name: Build
       working-directory: build

.github/workflows/merge-request-cuda.yml

@@ -5,6 +5,10 @@ on:
     branches: 
       - main
 
+concurrency: 
+  group: ${{ github.head_ref && github.workflow}}
+  cancel-in-progress: true
+
 env:
   BUILD_TYPE: Release
 
@@ -16,17 +20,33 @@ jobs:
 
     steps:
     - uses: actions/checkout@v3
-    - run: apt update 
+    - run: apt update
+    - name: Set up JDK 11
+      uses: actions/setup-java@v1
+      with:
+        java-version: 11
+        maven-version: '3.6.2'
+        cache: 'maven'
+    - name: Set up Maven
+      uses: stCarolas/setup-maven@v4.4
+      with:
+        maven-version: 3.8.2
+    - uses: actions/cache@v1
+      with:
+        path: /root/.m2/repository
+        key: ${{ runner.os }}-maven-${{ hashFiles('src/java/pom.xml') }}
+        restore-keys: |
+          ${{ runner.os }}-maven-
     - name: ccache
       uses: hendrikmuhs/ccache-action@v1.2
       with:
         key: ubuntu-latest
-        max-size: 1024M
+        max-size: 512M
     - name: Configure CMake
       run: |
         mkdir build
         cd build
-        cmake .. -DCMAKE_BUILD_TYPE=${{env.BUILD_TYPE}} -DWITH_WEBUI=off -DCLANG_TIDY=on -DCLANG_TIDY_AS_ERROR=on
+        cmake .. -DCMAKE_BUILD_TYPE=${{env.BUILD_TYPE}} -DWITH_WEBUI=off -DCLANG_TIDY=on -DCLANG_TIDY_AS_ERROR=on -DWITH_JAVA=on
 
     - name: Build
       working-directory: build

README.md

@@ -9,7 +9,7 @@ ModelBox是一个适用于端边云场景的AI推理应用开发框架，提供
 ## ModelBox特点
 
 1. **易于开发**  
-   AI推理业务可视化编排开发，功能模块化，丰富组件库；c++，python多语言支持。
+   AI推理业务可视化编排开发，功能模块化，丰富组件库；c++，python, Java多语言支持。
 
 1. **易于集成**  
    集成云上对接的组件，云上对接更容易。

README_en.md

@@ -7,7 +7,7 @@ ModelBox is an AI application development framework featuring device-edge-cloud
 ## ModelBox Highlights
 
 1. **Easy to develop**  
-   Simplified orchestration and development of inference applications via a graphical interface, modularized functions, rich component libraries, and multi-language support (C++, Python).
+   Simplified orchestration and development of inference applications via a graphical interface, modularized functions, rich component libraries, and multi-language support (C++, Python, Java).
 
 1. **Easy to integrate**  
    Easy to integrate different components on the cloud.

src/demo/hello_world/flowunit/hello_world/hello_world.py

@@ -34,7 +34,7 @@ def process(self, data_context):
         out_data = data_context.output("out_data")
 
         for buffer in in_data:
-            request_body = json.loads(buffer.as_object().strip(chr(0)))
+            request_body = json.loads(str(buffer))
             msg = request_body.get("msg")
             msg = msg.title()
             msg = addTimestamp(msg)

src/drivers/virtual/inference/virtualdriver_inference.h

@@ -49,9 +49,7 @@ class VirtualInferenceFlowUnitDesc : public modelbox::FlowUnitDesc {
   std::shared_ptr<modelbox::Configuration> config_;
 };
 
-class InferenceVirtualDriver
-    : public modelbox::VirtualDriver,
-      public std::enable_shared_from_this<InferenceVirtualDriver> {
+class InferenceVirtualDriver : public modelbox::VirtualDriver {
  public:
   InferenceVirtualDriver() = default;
   ~InferenceVirtualDriver() override = default;

src/drivers/virtual/java/virtualdriver_java.h

@@ -54,9 +54,7 @@ class VirtualJavaFlowUnitDesc : public modelbox::FlowUnitDesc {
   std::string jar_file_path_;
 };
 
-class JavaVirtualDriver
-    : public modelbox::VirtualDriver,
-      public std::enable_shared_from_this<JavaVirtualDriver> {
+class JavaVirtualDriver : public modelbox::VirtualDriver {
  public:
   JavaVirtualDriver() = default;
   ~JavaVirtualDriver() override = default;

src/drivers/virtual/python/virtualdriver_python.h

@@ -54,9 +54,7 @@ class VirtualPythonFlowUnitDesc : public modelbox::FlowUnitDesc {
   std::string python_file_path_;
 };
 
-class PythonVirtualDriver
-    : public modelbox::VirtualDriver,
-      public std::enable_shared_from_this<PythonVirtualDriver> {
+class PythonVirtualDriver : public modelbox::VirtualDriver {
  public:
   PythonVirtualDriver() = default;
   ~PythonVirtualDriver() override = default;

src/drivers/virtual/yolobox/virtualdriver_yolobox.h

@@ -46,9 +46,7 @@ class YoloBoxVirtualFlowUnitDesc : public modelbox::FlowUnitDesc {
   std::shared_ptr<modelbox::Configuration> config_;
 };
 
-class YoloBoxVirtualDriver
-    : public modelbox::VirtualDriver,
-      public std::enable_shared_from_this<YoloBoxVirtualDriver> {
+class YoloBoxVirtualDriver : public modelbox::VirtualDriver {
  public:
   YoloBoxVirtualDriver() = default;
   ~YoloBoxVirtualDriver() override = default;