Merge branch 'feature/easy-refactor' into 'develop'

[GAL-602] refactor: refactor this module based on the Easy Stream framework. See merge request galaxy/tsg_olap/sip-rtp-correlation!26
[GAL-602] style: use validate mode
2024-07-01 07:56:41 +00:00 · 2024-07-01 15:52:40 +08:00 · 2024-07-01 15:41:47 +08:00 · 2024-07-01 15:40:35 +08:00 · 2024-06-29 16:10:14 +08:00 · 2024-06-28 21:40:36 +08:00
30 changed files with 3386 additions and 82 deletions
--- a/.gitignore
+++ b/.gitignore
@@ -0,0 +1,35 @@
+target/
+!.mvn/wrapper/maven-wrapper.jar
+!**/src/main/**/target/
+!**/src/test/**/target/
+
+### IntelliJ IDEA ###
+.idea/
+*.iws
+*.iml
+*.ipr
+
+### Eclipse ###
+.apt_generated
+.classpath
+.factorypath
+.project
+.settings
+.springBeans
+.sts4-cache
+
+### NetBeans ###
+/nbproject/private/
+/nbbuild/
+/dist/
+/nbdist/
+/.nb-gradle/
+build/
+!**/src/main/**/build/
+!**/src/test/**/build/
+
+### VS Code ###
+.vscode/
+
+### Mac OS ###
+.DS_Store
--- a/.gitlab-ci.yml
+++ b/.gitlab-ci.yml
@@ -0,0 +1,47 @@
+image: 192.168.40.153:9080/common/maven:3.8.1-openjdk-11-slim-with-git
+
+variables:
+  MAVEN_CLI_OPTS: "--batch-mode --errors --show-version"
+
+stages:
+  - check
+  - test
+  - build
+
+snapshot-version:
+  stage: check
+  script:
+    - mvn $MAVEN_CLI_OPTS enforcer:enforce@snapshot-version-check
+  rules:
+    - if: $CI_MERGE_REQUEST_TARGET_BRANCH_NAME == "develop" && $CI_PIPELINE_SOURCE == "merge_request_event"
+
+non-snapshot-version:
+  stage: check
+  script:
+    - mvn $MAVEN_CLI_OPTS enforcer:enforce@release-version-check
+    - |-
+      if `mvn $MAVEN_CLI_OPTS dependency:get@release-deploy-check > /dev/null 2>&1`; then
+        echo "The current version has been deployed."
+        exit 1
+      else
+        echo "The current version has not been deployed."
+      fi
+  rules:
+    - if: $CI_MERGE_REQUEST_TARGET_BRANCH_NAME =~ /(^master$|^release\/)/ && $CI_PIPELINE_SOURCE == "merge_request_event"
+
+test:
+  stage: test
+  script:
+    - mvn $MAVEN_CLI_OPTS clean test
+  only:
+    - merge_requests
+
+# Used for building snapshot versions on the develop branch.
+build:
+  stage: build
+  script:
+    - echo "$MAVEN_SETTINGS_XML" > /usr/share/maven/conf/settings.xml
+    - mvn clean site deploy -DskipTests
+  only:
+    - master
+    - /^release\//
--- a/README.md
+++ b/README.md
@@ -1,92 +1,25 @@
-# flink-voip-fusion
+# SIP RTP Correlation

+## 简介

+SIP RTP Correlation 项目是一个使用 Apache Flink 实现的实时数据处理项目，旨在从 Kafka 中读取 SIP（Session Initiation Protocol）和 RTP（Real-time Transport Protocol）数据，将它们融合成完整的 VoIP（Voice over Internet Protocol）通话数据。

-## Getting started
+SIP RTP Correlation 项目可以用于实时监控和分析 VoIP 通话数据，提取关键指标，以及进行实时报警和诊断。

-To make it easy for you to get started with GitLab, here's a list of recommended next steps.
+## 编译和打包

-Already a pro? Just edit this README.md and make it your own. Want to make it easy? [Use the template at the bottom](#editing-this-readme)!
-
-## Add your files
-
- [ ] [Create](https://docs.gitlab.com/ee/user/project/repository/web_editor.html#create-a-file) or [upload](https://docs.gitlab.com/ee/user/project/repository/web_editor.html#upload-a-file) files
- [ ] [Add files using the command line](https://docs.gitlab.com/ee/gitlab-basics/add-file.html#add-a-file-using-the-command-line) or push an existing Git repository with the following command:
-
-```
-cd existing_repo
-git remote add origin https://git.mesalab.cn/galaxy/tsg_olap/flink-voip-fusion.git
-git branch -M main
-git push -uf origin main
+使用Maven工具对项目进行编译和打包：
+```shell
+mvn clean package
 ```

-## Integrate with your tools
+## 运行Flink任务

- [ ] [Set up project integrations](https://git.mesalab.cn/galaxy/tsg_olap/flink-voip-fusion/-/settings/integrations)
+使用以下命令运行Flink任务：
+```shell
+flink run -c com.geedgenetworks.flink.easy.core.Runner path/to/sip-rtp-correlation-<version>.jar job.yml
+```

-## Collaborate with your team
+## 贡献

- [ ] [Invite team members and collaborators](https://docs.gitlab.com/ee/user/project/members/)
- [ ] [Create a new merge request](https://docs.gitlab.com/ee/user/project/merge_requests/creating_merge_requests.html)
- [ ] [Automatically close issues from merge requests](https://docs.gitlab.com/ee/user/project/issues/managing_issues.html#closing-issues-automatically)
- [ ] [Enable merge request approvals](https://docs.gitlab.com/ee/user/project/merge_requests/approvals/)
- [ ] [Automatically merge when pipeline succeeds](https://docs.gitlab.com/ee/user/project/merge_requests/merge_when_pipeline_succeeds.html)
-
-## Test and Deploy
-
-Use the built-in continuous integration in GitLab.
-
- [ ] [Get started with GitLab CI/CD](https://docs.gitlab.com/ee/ci/quick_start/index.html)
- [ ] [Analyze your code for known vulnerabilities with Static Application Security Testing(SAST)](https://docs.gitlab.com/ee/user/application_security/sast/)
- [ ] [Deploy to Kubernetes, Amazon EC2, or Amazon ECS using Auto Deploy](https://docs.gitlab.com/ee/topics/autodevops/requirements.html)
- [ ] [Use pull-based deployments for improved Kubernetes management](https://docs.gitlab.com/ee/user/clusters/agent/)
- [ ] [Set up protected environments](https://docs.gitlab.com/ee/ci/environments/protected_environments.html)
-
-***
-
-# Editing this README
-
-When you're ready to make this README your own, just edit this file and use the handy template below (or feel free to structure it however you want - this is just a starting point!). Thank you to [makeareadme.com](https://www.makeareadme.com/) for this template.
-
-## Suggestions for a good README
-Every project is different, so consider which of these sections apply to yours. The sections used in the template are suggestions for most open source projects. Also keep in mind that while a README can be too long and detailed, too long is better than too short. If you think your README is too long, consider utilizing another form of documentation rather than cutting out information.
-
-## Name
-Choose a self-explaining name for your project.
-
-## Description
-Let people know what your project can do specifically. Provide context and add a link to any reference visitors might be unfamiliar with. A list of Features or a Background subsection can also be added here. If there are alternatives to your project, this is a good place to list differentiating factors.
-
-## Badges
-On some READMEs, you may see small images that convey metadata, such as whether or not all the tests are passing for the project. You can use Shields to add some to your README. Many services also have instructions for adding a badge.
-
-## Visuals
-Depending on what you are making, it can be a good idea to include screenshots or even a video (you'll frequently see GIFs rather than actual videos). Tools like ttygif can help, but check out Asciinema for a more sophisticated method.
-
-## Installation
-Within a particular ecosystem, there may be a common way of installing things, such as using Yarn, NuGet, or Homebrew. However, consider the possibility that whoever is reading your README is a novice and would like more guidance. Listing specific steps helps remove ambiguity and gets people to using your project as quickly as possible. If it only runs in a specific context like a particular programming language version or operating system or has dependencies that have to be installed manually, also add a Requirements subsection.
-
-## Usage
-Use examples liberally, and show the expected output if you can. It's helpful to have inline the smallest example of usage that you can demonstrate, while providing links to more sophisticated examples if they are too long to reasonably include in the README.
-
-## Support
-Tell people where they can go to for help. It can be any combination of an issue tracker, a chat room, an email address, etc.
-
-## Roadmap
-If you have ideas for releases in the future, it is a good idea to list them in the README.
-
-## Contributing
-State if you are open to contributions and what your requirements are for accepting them.
-
-For people who want to make changes to your project, it's helpful to have some documentation on how to get started. Perhaps there is a script that they should run or some environment variables that they need to set. Make these steps explicit. These instructions could also be useful to your future self.
-
-You can also document commands to lint the code or run tests. These steps help to ensure high code quality and reduce the likelihood that the changes inadvertently break something. Having instructions for running tests is especially helpful if it requires external setup, such as starting a Selenium server for testing in a browser.
-
-## Authors and acknowledgment
-Show your appreciation to those who have contributed to the project.
-
-## License
-For open source projects, say how it is licensed.
-
-## Project status
-If you have run out of energy or time for your project, put a note at the top of the README saying that development has slowed down or stopped completely. Someone may choose to fork your project or volunteer to step in as a maintainer or owner, allowing your project to keep going. You can also make an explicit request for maintainers.
+如果您发现任何问题或改进项目的想法，欢迎提交 Issue 或 Pull Request。
--- a/pom.xml
+++ b/pom.xml
@@ -0,0 +1,653 @@
+<?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>com.geedgenetworks.application</groupId>
+    <artifactId>sip-rtp-correlation</artifactId>
+    <version>2.0-SNAPSHOT</version>
+
+    <name>Flink : SIP-RTP : Correlation</name>
+
+    <properties>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+        <java.version>11</java.version>
+        <maven.compiler.source>${java.version}</maven.compiler.source>
+        <maven.compiler.target>${java.version}</maven.compiler.target>
+        <scala.version>2.12.10</scala.version>
+        <scala.binary.version>2.12</scala.binary.version>
+        <flink.version>1.13.6</flink.version>
+        <easy.stream.version>1.3-SNAPSHOT</easy.stream.version>
+        <slf4j.version>1.7.32</slf4j.version>
+        <log4j.version>2.17.1</log4j.version>
+        <junit.version>5.8.0</junit.version>
+    </properties>
+
+    <distributionManagement>
+        <repository>
+            <id>platform-releases</id>
+            <url>http://192.168.40.153:8099/content/repositories/platform-release</url>
+            <uniqueVersion>true</uniqueVersion>
+        </repository>
+        <snapshotRepository>
+            <id>platform-snapshots</id>
+            <url>http://192.168.40.153:8099/content/repositories/platform-snapshot</url>
+        </snapshotRepository>
+        <site>
+            <id>platform-site</id>
+            <url>
+                dav:http://192.168.40.153:8099/content/sites/platform-site/platform/application/sip-rtp-correlate-${project.version}
+            </url>
+        </site>
+    </distributionManagement>
+
+    <repositories>
+        <repository>
+            <id>central</id>
+            <url>http://192.168.40.153:8099/content/groups/public</url>
+        </repository>
+        <repository>
+            <id>snapshots</id>
+            <url>http://192.168.40.153:8099/content/groups/public</url>
+            <snapshots>
+                <enabled>true</enabled>
+            </snapshots>
+        </repository>
+    </repositories>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.slf4j</groupId>
+            <artifactId>slf4j-api</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.logging.log4j</groupId>
+            <artifactId>log4j-slf4j-impl</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.logging.log4j</groupId>
+            <artifactId>log4j-api</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.logging.log4j</groupId>
+            <artifactId>log4j-core</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>com.zdjizhi</groupId>
+            <artifactId>galaxy</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>xyz.downgoon</groupId>
+            <artifactId>snowflake</artifactId>
+            <version>1.0.0</version>
+        </dependency>
+
+        <!--  Easy Stream -->
+        <dependency>
+            <groupId>com.geedgenetworks.flink</groupId>
+            <artifactId>easy-stream-common</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>com.geedgenetworks.flink</groupId>
+            <artifactId>easy-stream-core</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>com.geedgenetworks.flink</groupId>
+            <artifactId>easy-stream-grouped-exec-pipeline</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>com.geedgenetworks.flink</groupId>
+            <artifactId>easy-stream-filter-pipeline</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>com.geedgenetworks.flink</groupId>
+            <artifactId>easy-stream-console-pipeline</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>com.geedgenetworks.flink</groupId>
+            <artifactId>easy-stream-split-pipeline</artifactId>
+            <version>${easy.stream.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>com.geedgenetworks.flink</groupId>
+            <artifactId>easy-stream-correlate-pipeline</artifactId>
+            <version>${easy.stream.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>com.geedgenetworks.flink</groupId>
+            <artifactId>easy-stream-union-pipeline</artifactId>
+            <version>${easy.stream.version}</version>
+        </dependency>
+
+        <dependency>
+            <groupId>com.geedgenetworks.flink</groupId>
+            <artifactId>easy-stream-kafka-connector</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>com.geedgenetworks.flink</groupId>
+            <artifactId>easy-stream-text-connector</artifactId>
+            <version>${easy.stream.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>com.geedgenetworks.flink</groupId>
+            <artifactId>easy-stream-socket-connector</artifactId>
+            <version>${easy.stream.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>com.geedgenetworks.flink</groupId>
+            <artifactId>easy-stream-console-connector</artifactId>
+            <version>${easy.stream.version}</version>
+        </dependency>
+
+        <dependency>
+            <groupId>com.geedgenetworks.flink</groupId>
+            <artifactId>easy-stream-json-format</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>com.geedgenetworks.flink</groupId>
+            <artifactId>easy-stream-flink-shim</artifactId>
+        </dependency>
+
+        <!-- Flink -->
+        <dependency>
+            <groupId>org.apache.flink</groupId>
+            <artifactId>flink-clients_${scala.binary.version}</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.flink</groupId>
+            <artifactId>flink-core</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.flink</groupId>
+            <artifactId>flink-streaming-java_${scala.binary.version}</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.flink</groupId>
+            <artifactId>flink-runtime_${scala.binary.version}</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.flink</groupId>
+            <artifactId>flink-runtime-web_${scala.binary.version}</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.flink</groupId>
+            <artifactId>flink-table-common</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.flink</groupId>
+            <artifactId>flink-table-api-java-bridge_${scala.binary.version}</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.flink</groupId>
+            <artifactId>flink-table-planner-blink_${scala.binary.version}</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.flink</groupId>
+            <artifactId>flink-table-runtime-blink_${scala.binary.version}</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>org.junit.jupiter</groupId>
+            <artifactId>junit-jupiter-api</artifactId>
+            <scope>test</scope>
+        </dependency>
+    </dependencies>
+
+    <dependencyManagement>
+        <dependencies>
+            <!-- DEV -->
+            <dependency>
+                <groupId>com.github.spotbugs</groupId>
+                <artifactId>spotbugs-annotations</artifactId>
+                <version>4.4.2</version>
+            </dependency>
+            <!-- LOG -->
+            <dependency>
+                <groupId>org.slf4j</groupId>
+                <artifactId>slf4j-api</artifactId>
+                <version>${slf4j.version}</version>
+            </dependency>
+            <dependency>
+                <groupId>org.apache.logging.log4j</groupId>
+                <artifactId>log4j-slf4j-impl</artifactId>
+                <version>${log4j.version}</version>
+                <scope>runtime</scope>
+            </dependency>
+            <dependency>
+                <groupId>org.apache.logging.log4j</groupId>
+                <artifactId>log4j-api</artifactId>
+                <version>${log4j.version}</version>
+                <scope>runtime</scope>
+            </dependency>
+            <dependency>
+                <groupId>org.apache.logging.log4j</groupId>
+                <artifactId>log4j-core</artifactId>
+                <version>${log4j.version}</version>
+                <scope>runtime</scope>
+            </dependency>
+            <dependency>
+                <!-- API bridge between log4j 1 and 2 -->
+                <groupId>org.apache.logging.log4j</groupId>
+                <artifactId>log4j-1.2-api</artifactId>
+                <version>${log4j.version}</version>
+                <scope>runtime</scope>
+            </dependency>
+
+            <!-- Test -->
+            <dependency>
+                <groupId>org.junit.jupiter</groupId>
+                <artifactId>junit-jupiter-api</artifactId>
+                <version>${junit.version}</version>
+                <scope>test</scope>
+            </dependency>
+            <dependency>
+                <groupId>org.junit.jupiter</groupId>
+                <artifactId>junit-jupiter</artifactId>
+                <version>${junit.version}</version>
+                <scope>test</scope>
+            </dependency>
+
+            <!--  Common  -->
+            <dependency>
+                <groupId>com.zdjizhi</groupId>
+                <artifactId>galaxy</artifactId>
+                <version>1.1.3</version>
+                <exclusions>
+                    <exclusion>
+                        <groupId>org.slf4j</groupId>
+                        <artifactId>slf4j-log4j12</artifactId>
+                    </exclusion>
+                    <exclusion>
+                        <groupId>log4j</groupId>
+                        <artifactId>log4j</artifactId>
+                    </exclusion>
+                    <exclusion>
+                        <groupId>org.apache.commons</groupId>
+                        <artifactId>commons-lang3</artifactId>
+                    </exclusion>
+                </exclusions>
+            </dependency>
+
+            <!-- Easy Stream-->
+            <dependency>
+                <groupId>com.geedgenetworks.flink</groupId>
+                <artifactId>easy-stream-common</artifactId>
+                <version>${easy.stream.version}</version>
+            </dependency>
+            <dependency>
+                <groupId>com.geedgenetworks.flink</groupId>
+                <artifactId>easy-stream-core</artifactId>
+                <version>${easy.stream.version}</version>
+            </dependency>
+            <dependency>
+                <groupId>com.geedgenetworks.flink</groupId>
+                <artifactId>easy-stream-grouped-exec-pipeline</artifactId>
+                <version>${easy.stream.version}</version>
+            </dependency>
+            <dependency>
+                <groupId>com.geedgenetworks.flink</groupId>
+                <artifactId>easy-stream-filter-pipeline</artifactId>
+                <version>${easy.stream.version}</version>
+            </dependency>
+            <dependency>
+                <groupId>com.geedgenetworks.flink</groupId>
+                <artifactId>easy-stream-console-pipeline</artifactId>
+                <version>${easy.stream.version}</version>
+            </dependency>
+            <dependency>
+                <groupId>com.geedgenetworks.flink</groupId>
+                <artifactId>easy-stream-kafka-connector</artifactId>
+                <version>${easy.stream.version}</version>
+            </dependency>
+            <dependency>
+                <groupId>com.geedgenetworks.flink</groupId>
+                <artifactId>easy-stream-json-format</artifactId>
+                <version>${easy.stream.version}</version>
+            </dependency>
+            <dependency>
+                <groupId>com.geedgenetworks.flink</groupId>
+                <artifactId>easy-stream-flink-shim</artifactId>
+                <version>${easy.stream.version}</version>
+            </dependency>
+
+            <!-- Flink -->
+            <dependency>
+                <groupId>org.apache.flink</groupId>
+                <artifactId>flink-core</artifactId>
+                <version>${flink.version}</version>
+                <scope>provided</scope>
+            </dependency>
+            <dependency>
+                <groupId>org.apache.flink</groupId>
+                <artifactId>flink-streaming-java_${scala.binary.version}</artifactId>
+                <version>${flink.version}</version>
+                <scope>provided</scope>
+            </dependency>
+            <dependency>
+                <groupId>org.apache.flink</groupId>
+                <artifactId>flink-clients_${scala.binary.version}</artifactId>
+                <version>${flink.version}</version>
+                <scope>provided</scope>
+            </dependency>
+            <dependency>
+                <groupId>org.apache.flink</groupId>
+                <artifactId>flink-runtime_${scala.binary.version}</artifactId>
+                <version>${flink.version}</version>
+                <scope>runtime</scope>
+            </dependency>
+            <dependency>
+                <groupId>org.apache.flink</groupId>
+                <artifactId>flink-runtime-web_${scala.binary.version}</artifactId>
+                <version>${flink.version}</version>
+                <scope>runtime</scope>
+            </dependency>
+
+            <dependency>
+                <groupId>org.apache.flink</groupId>
+                <artifactId>flink-connector-kafka_${scala.binary.version}</artifactId>
+                <version>${flink.version}</version>
+            </dependency>
+            <dependency>
+                <groupId>org.apache.flink</groupId>
+                <artifactId>flink-json</artifactId>
+                <version>${flink.version}</version>
+            </dependency>
+
+            <dependency>
+                <groupId>org.apache.flink</groupId>
+                <artifactId>flink-table-common</artifactId>
+                <version>${flink.version}</version>
+                <scope>provided</scope>
+            </dependency>
+            <dependency>
+                <groupId>org.apache.flink</groupId>
+                <artifactId>flink-table-api-java-bridge_${scala.binary.version}</artifactId>
+                <version>${flink.version}</version>
+                <scope>provided</scope>
+            </dependency>
+            <dependency>
+                <groupId>org.apache.flink</groupId>
+                <artifactId>flink-table-runtime-blink_${scala.binary.version}</artifactId>
+                <version>${flink.version}</version>
+                <scope>provided</scope>
+            </dependency>
+            <dependency>
+                <groupId>org.apache.flink</groupId>
+                <artifactId>flink-table-planner-blink_${scala.binary.version}</artifactId>
+                <version>${flink.version}</version>
+                <scope>provided</scope>
+            </dependency>
+        </dependencies>
+    </dependencyManagement>
+
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-checkstyle-plugin</artifactId>
+                <version>3.1.2</version>
+                <configuration>
+                    <suppressionsLocation>${basedir}/tools/maven/suppressions.xml</suppressionsLocation>
+                    <includeTestSourceDirectory>true</includeTestSourceDirectory>
+                    <configLocation>${basedir}/tools/maven/checkstyle.xml</configLocation>
+                    <logViolationsToConsole>true</logViolationsToConsole>
+                    <failOnViolation>true</failOnViolation>
+                </configuration>
+                <dependencies>
+                    <dependency>
+                        <groupId>com.puppycrawl.tools</groupId>
+                        <artifactId>checkstyle</artifactId>
+                        <version>8.40</version>
+                    </dependency>
+                </dependencies>
+                <executions>
+                    <execution>
+                        <id>java-style-check</id>
+                        <phase>compile</phase>
+                        <goals>
+                            <goal>check</goal>
+                        </goals>
+                        <configuration>
+                            <sourceDirectories>src/main/java</sourceDirectories>
+                        </configuration>
+                    </execution>
+                    <execution>
+                        <id>java-test-style-check</id>
+                        <phase>test-compile</phase>
+                        <goals>
+                            <goal>check</goal>
+                        </goals>
+                        <configuration>
+                            <testSourceDirectories>src/test/java</testSourceDirectories>
+                            <includeTestSourceDirectory>true</includeTestSourceDirectory>
+                        </configuration>
+                    </execution>
+                </executions>
+            </plugin>
+            <plugin>
+                <groupId>com.github.spotbugs</groupId>
+                <artifactId>spotbugs-maven-plugin</artifactId>
+                <version>4.4.2.2</version>
+                <configuration>
+                    <xmlOutput>true</xmlOutput>
+                    <!-- Low, Medium, High ('Low' is strictest) -->
+                    <threshold>Low</threshold>
+                    <effort>default</effort>
+                    <spotbugsXmlOutputDirectory>${project.build.directory}/spotbugs</spotbugsXmlOutputDirectory>
+                    <excludeFilterFile>${basedir}/tools/maven/spotbugs-exclude.xml</excludeFilterFile>
+                    <failOnError>true</failOnError>
+                </configuration>
+                <executions>
+                    <execution>
+                        <id>findbugs-main</id>
+                        <phase>compile</phase>
+                        <goals>
+                            <goal>check</goal>
+                        </goals>
+                    </execution>
+                    <execution>
+                        <id>findbugs-test</id>
+                        <phase>test-compile</phase>
+                        <goals>
+                            <goal>check</goal>
+                        </goals>
+                        <configuration>
+                            <includeTests>true</includeTests>
+                        </configuration>
+                    </execution>
+                </executions>
+            </plugin>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <version>3.8.1</version>
+                <configuration>
+                    <source>${maven.compiler.source}</source>
+                    <target>${maven.compiler.target}</target>
+                </configuration>
+            </plugin>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-shade-plugin</artifactId>
+                <version>3.5.1</version>
+                <executions>
+                    <execution>
+                        <id>default-shade</id>
+                        <phase>package</phase>
+                        <goals>
+                            <goal>shade</goal>
+                        </goals>
+                        <configuration>
+                            <createDependencyReducedPom>false</createDependencyReducedPom>
+                            <finalName>${project.artifactId}-${project.version}</finalName>
+                            <artifactSet>
+                                <excludes>
+                                    <exclude>org.apache.flink:force-shading</exclude>
+                                    <exclude>com.google.code.findbugs:jsr305</exclude>
+                                    <exclude>org.slf4j:*</exclude>
+                                    <exclude>org.apache.logging.log4j:*</exclude>
+                                    <exclude>org.mockito:mockito-core</exclude>
+                                </excludes>
+                            </artifactSet>
+                            <filters>
+                                <filter>
+                                    <artifact>*:*</artifact>
+                                    <excludes>
+                                        <exclude>META-INF/*.SF</exclude>
+                                        <exclude>META-INF/*.DSA</exclude>
+                                        <exclude>META-INF/*.RSA</exclude>
+                                    </excludes>
+                                </filter>
+                            </filters>
+                            <transformers>
+                                <transformer
+                                        implementation="org.apache.maven.plugins.shade.resource.ServicesResourceTransformer"/>
+                            </transformers>
+                        </configuration>
+                    </execution>
+                </executions>
+            </plugin>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-assembly-plugin</artifactId>
+                <version>3.0.0</version>
+                <executions>
+                    <execution>
+                        <id>build-jobs</id>
+                        <phase>package</phase>
+                        <goals>
+                            <goal>single</goal>
+                        </goals>
+                        <configuration>
+                            <finalName>${project.artifactId}-yml-${project.version}</finalName>
+                            <appendAssemblyId>false</appendAssemblyId>
+                            <descriptors>
+                                <descriptor>tools/dist/target.xml</descriptor>
+                            </descriptors>
+                        </configuration>
+                    </execution>
+                </executions>
+            </plugin>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-resources-plugin</artifactId>
+                <version>3.0.0</version>
+                <executions>
+                    <execution>
+                        <id>site-resources</id>
+                        <phase>pre-site</phase>
+                        <goals>
+                            <goal>resources</goal>
+                        </goals>
+                        <configuration>
+                            <resources>
+                                <resource>
+                                    <directory>src/site</directory>
+                                    <filtering>true</filtering>
+                                    <includes>
+                                        <include>**</include>
+                                    </includes>
+                                </resource>
+                            </resources>
+                        </configuration>
+                    </execution>
+                </executions>
+            </plugin>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-site-plugin</artifactId>
+                <configuration>
+                    <skip>false</skip>
+                </configuration>
+                <executions>
+                    <execution>
+                        <id>default-site</id>
+                        <goals>
+                            <goal>site</goal>
+                        </goals>
+                        <phase>site</phase>
+                        <configuration>
+                            <siteDirectory>${project.build.outputDirectory}</siteDirectory>
+                        </configuration>
+                    </execution>
+                    <execution>
+                        <id>site-deploy</id>
+                        <goals>
+                            <goal>stage-deploy</goal>
+                        </goals>
+                        <phase>deploy</phase>
+                    </execution>
+                </executions>
+            </plugin>
+        </plugins>
+
+        <pluginManagement>
+            <plugins>
+                <plugin>
+                    <groupId>org.apache.maven.plugins</groupId>
+                    <artifactId>maven-enforcer-plugin</artifactId>
+                    <version>3.0.0-M3</version>
+                    <executions>
+                        <execution>
+                            <id>release-version-check</id>
+                            <goals>
+                                <goal>enforce</goal>
+                            </goals>
+                            <configuration>
+                                <rules>
+                                    <requireReleaseVersion>
+                                        <message>SNAPSHOT versions ${project.version} are not allowed.</message>
+                                    </requireReleaseVersion>
+                                </rules>
+                            </configuration>
+                        </execution>
+                        <execution>
+                            <id>snapshot-version-check</id>
+                            <goals>
+                                <goal>enforce</goal>
+                            </goals>
+                            <configuration>
+                                <rules>
+                                    <requireSnapshotVersion>
+                                        <message>Non-SNAPSHOT versions ${project.version} are not allowed.</message>
+                                    </requireSnapshotVersion>
+                                </rules>
+                            </configuration>
+                        </execution>
+                    </executions>
+                </plugin>
+                <plugin>
+                    <groupId>org.apache.maven.plugins</groupId>
+                    <artifactId>maven-site-plugin</artifactId>
+                    <version>3.9.1</version>
+                    <configuration>
+                        <outputDirectory>${project.build.directory}/site</outputDirectory>
+                        <relativizeDecorationLinks>false</relativizeDecorationLinks>
+                    </configuration>
+                    <dependencies>
+                        <dependency>
+                            <groupId>org.apache.maven.wagon</groupId>
+                            <artifactId>wagon-webdav-jackrabbit</artifactId>
+                            <version>2.8</version>
+                        </dependency>
+                        <dependency>
+                            <groupId>org.apache.maven.doxia</groupId>
+                            <artifactId>doxia-module-markdown</artifactId>
+                            <version>1.9.1</version>
+                        </dependency>
+                    </dependencies>
+                </plugin>
+                <plugin>
+                    <groupId>org.apache.maven.plugins</groupId>
+                    <artifactId>maven-deploy-plugin</artifactId>
+                    <version>3.1.1</version>
+                </plugin>
+            </plugins>
+        </pluginManagement>
+    </build>
+
+</project>
--- a/src/main/java/com/geedgenetworks/flink/easy/application/voip/VoipUDFFactory.java
+++ b/src/main/java/com/geedgenetworks/flink/easy/application/voip/VoipUDFFactory.java
@@ -0,0 +1,33 @@
+package com.geedgenetworks.flink.easy.application.voip;
+
+import com.geedgenetworks.flink.easy.application.voip.udf.*;
+import com.geedgenetworks.flink.easy.common.api.UDFFactory;
+import org.apache.flink.table.functions.UserDefinedFunction;
+
+import java.util.HashMap;
+import java.util.Map;
+
+public class VoipUDFFactory implements UDFFactory {
+
+    private static final Map<String, UserDefinedFunction> R =
+            new HashMap<>() {{
+                put("IS_IP_ADDRESS", new IsIpAddress());
+
+                put("IS_INTERNAL_IP_ADDRESS", new IsInternalIpAddress());
+                put("IS_EXTERNAL_IP_ADDRESS", new IsExternalIpAddress());
+
+                put("HAS_IP_ADDRESS", new HasIpAddress());
+                put("HAS_EXTERNAL_IP_ADDRESS", new HasExternalIpAddress());
+
+                put("STREAM_DIR", new StreamDir());
+                put("FIND_NOT_BLANK", new FindNotBlank());
+                put("SORT_ADDRESS", new SortAddress());
+
+                put("SNOWFLAKE_ID", new SnowflakeID());
+            }};
+
+    @Override
+    public Map<String, UserDefinedFunction> register() {
+        return R;
+    }
+}
--- a/src/main/java/com/geedgenetworks/flink/easy/application/voip/udf/FindNotBlank.java
+++ b/src/main/java/com/geedgenetworks/flink/easy/application/voip/udf/FindNotBlank.java
@@ -0,0 +1,15 @@
+package com.geedgenetworks.flink.easy.application.voip.udf;
+
+import org.apache.commons.lang3.StringUtils;
+import org.apache.flink.table.annotation.DataTypeHint;
+import org.apache.flink.table.functions.ScalarFunction;
+
+public class FindNotBlank extends ScalarFunction {
+
+    public @DataTypeHint("STRING") String eval(String s1, String s2) {
+        if (StringUtils.isBlank(s1) && StringUtils.isNotBlank(s2)) {
+            return s2;
+        }
+        return s1;
+    }
+}
--- a/src/main/java/com/geedgenetworks/flink/easy/application/voip/udf/HasExternalIpAddress.java
+++ b/src/main/java/com/geedgenetworks/flink/easy/application/voip/udf/HasExternalIpAddress.java
@@ -0,0 +1,19 @@
+package com.geedgenetworks.flink.easy.application.voip.udf;
+
+import org.apache.flink.table.annotation.DataTypeHint;
+import org.apache.flink.table.functions.ScalarFunction;
+
+public class HasExternalIpAddress extends ScalarFunction {
+
+    private final IsExternalIpAddress isExternalIpAddress = new IsExternalIpAddress();
+
+    public @DataTypeHint("BOOLEAN") Boolean eval(String... ipaddr) {
+        if (null == ipaddr) {
+            return false;
+        }
+        for (var ip : ipaddr) {
+            return isExternalIpAddress.eval(ip);
+        }
+        return false;
+    }
+}
--- a/src/main/java/com/geedgenetworks/flink/easy/application/voip/udf/HasIpAddress.java
+++ b/src/main/java/com/geedgenetworks/flink/easy/application/voip/udf/HasIpAddress.java
@@ -0,0 +1,18 @@
+package com.geedgenetworks.flink.easy.application.voip.udf;
+
+import com.zdjizhi.utils.IPUtil;
+import org.apache.flink.table.annotation.DataTypeHint;
+import org.apache.flink.table.functions.ScalarFunction;
+
+public class HasIpAddress extends ScalarFunction {
+
+    public @DataTypeHint("BOOLEAN") Boolean eval(String... ipaddr) {
+        if (null == ipaddr) {
+            return false;
+        }
+        for (var ip : ipaddr) {
+            return ip != null && IPUtil.isIPAddress(ip);
+        }
+        return false;
+    }
+}
--- a/src/main/java/com/geedgenetworks/flink/easy/application/voip/udf/IsExternalIpAddress.java
+++ b/src/main/java/com/geedgenetworks/flink/easy/application/voip/udf/IsExternalIpAddress.java
@@ -0,0 +1,17 @@
+package com.geedgenetworks.flink.easy.application.voip.udf;
+
+import com.zdjizhi.utils.IPUtil;
+import org.apache.flink.table.annotation.DataTypeHint;
+import org.apache.flink.table.functions.ScalarFunction;
+
+import static com.zdjizhi.utils.IPUtil.isIPAddress;
+
+public class IsExternalIpAddress extends ScalarFunction {
+
+    public @DataTypeHint("BOOLEAN") Boolean eval(String ipaddr) {
+        if (ipaddr == null || !isIPAddress(ipaddr)) {
+            return false;
+        }
+        return !IPUtil.internalIp(ipaddr);
+    }
+}
--- a/src/main/java/com/geedgenetworks/flink/easy/application/voip/udf/IsInternalIpAddress.java
+++ b/src/main/java/com/geedgenetworks/flink/easy/application/voip/udf/IsInternalIpAddress.java
@@ -0,0 +1,17 @@
+package com.geedgenetworks.flink.easy.application.voip.udf;
+
+import com.zdjizhi.utils.IPUtil;
+import org.apache.flink.table.annotation.DataTypeHint;
+import org.apache.flink.table.functions.ScalarFunction;
+
+import static com.zdjizhi.utils.IPUtil.isIPAddress;
+
+public class IsInternalIpAddress extends ScalarFunction {
+
+    public @DataTypeHint("BOOLEAN") Boolean eval(String ipaddr) {
+        if (!isIPAddress(ipaddr)) {
+            return false;
+        }
+        return IPUtil.internalIp(ipaddr);
+    }
+}
--- a/src/main/java/com/geedgenetworks/flink/easy/application/voip/udf/IsIpAddress.java
+++ b/src/main/java/com/geedgenetworks/flink/easy/application/voip/udf/IsIpAddress.java
@@ -0,0 +1,15 @@
+package com.geedgenetworks.flink.easy.application.voip.udf;
+
+import com.zdjizhi.utils.IPUtil;
+import org.apache.flink.table.annotation.DataTypeHint;
+import org.apache.flink.table.functions.ScalarFunction;
+
+public class IsIpAddress extends ScalarFunction {
+
+    public @DataTypeHint("BOOLEAN") Boolean eval(String ipaddr) {
+        if (null == ipaddr) {
+            return false;
+        }
+        return IPUtil.isIPAddress(ipaddr);
+    }
+}
--- a/src/main/java/com/geedgenetworks/flink/easy/application/voip/udf/SnowflakeID.java
+++ b/src/main/java/com/geedgenetworks/flink/easy/application/voip/udf/SnowflakeID.java
@@ -0,0 +1,14 @@
+package com.geedgenetworks.flink.easy.application.voip.udf;
+
+import org.apache.flink.table.annotation.DataTypeHint;
+import org.apache.flink.table.functions.ScalarFunction;
+import xyz.downgoon.snowflake.Snowflake;
+
+public class SnowflakeID extends ScalarFunction {
+
+    private static final Snowflake SNOWFLAKE = new Snowflake(1, 1);
+
+    public @DataTypeHint("BIGINT") Long eval() {
+        return SNOWFLAKE.nextId();
+    }
+}
--- a/src/main/java/com/geedgenetworks/flink/easy/application/voip/udf/SortAddress.java
+++ b/src/main/java/com/geedgenetworks/flink/easy/application/voip/udf/SortAddress.java
@@ -0,0 +1,31 @@
+package com.geedgenetworks.flink.easy.application.voip.udf;
+
+import com.google.common.collect.Lists;
+import com.zdjizhi.utils.IPUtil;
+import org.apache.flink.api.java.tuple.Tuple2;
+import org.apache.flink.table.annotation.DataTypeHint;
+import org.apache.flink.table.functions.ScalarFunction;
+
+public class SortAddress extends ScalarFunction {
+
+    public @DataTypeHint("STRING")
+    String eval(
+            String ip1, Integer port1, String ip2, Integer port2) {
+        return of(Tuple2.of(ip1, port1), Tuple2.of(ip2, port2));
+    }
+
+    public static String of(
+            Tuple2<String, Integer> a1, Tuple2<String, Integer> a2) {
+        var list = Lists.newArrayList(a1, a2);
+        list.sort((a, b) -> {
+            if (a.f1.equals(b.f1)) {
+                return Long.compare(
+                        IPUtil.getIpDesimal(a.f0), IPUtil.getIpDesimal(b.f0));
+            } else {
+                return a.f1.compareTo(b.f1);
+            }
+        });
+        return String.format("%s:%s,%s:%s",
+                list.get(0).f0, list.get(0).f1, list.get(1).f0, list.get(1).f1);
+    }
+}
--- a/src/main/java/com/geedgenetworks/flink/easy/application/voip/udf/StreamDir.java
+++ b/src/main/java/com/geedgenetworks/flink/easy/application/voip/udf/StreamDir.java
@@ -0,0 +1,26 @@
+package com.geedgenetworks.flink.easy.application.voip.udf;
+
+import org.apache.flink.table.annotation.DataTypeHint;
+import org.apache.flink.table.functions.ScalarFunction;
+
+public class StreamDir extends ScalarFunction {
+
+    public @DataTypeHint("INT") Integer eval(Long flags) {
+        int v = 0;
+        if (flags == null) {
+            return v;
+        }
+        if ((flags & 8192) == 8192) {
+            v += 1;
+        }
+        if ((flags & 16384) == 16384) {
+            v += 2;
+        }
+        return v;
+    }
+
+    public static void main(String[] args) {
+        System.out.println(8192L + 16384L);
+        System.out.println(new StreamDir().eval(8192L + 16384L));
+    }
+}
--- a/src/main/resources/META-INF/services/com.geedgenetworks.flink.easy.common.api.UDFFactory
+++ b/src/main/resources/META-INF/services/com.geedgenetworks.flink.easy.common.api.UDFFactory
@@ -0,0 +1 @@
+com.geedgenetworks.flink.easy.application.voip.VoipUDFFactory
--- a/src/main/resources/jobs/job.yml
+++ b/src/main/resources/jobs/job.yml
--- a/src/main/resources/log4j2.properties
+++ b/src/main/resources/log4j2.properties
@@ -0,0 +1,25 @@
+################################################################################
+#  Licensed to the Apache Software Foundation (ASF) under one
+#  or more contributor license agreements.  See the NOTICE file
+#  distributed with this work for additional information
+#  regarding copyright ownership.  The ASF licenses this file
+#  to you 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.
+################################################################################
+
+rootLogger.level = INFO
+rootLogger.appenderRef.console.ref = ConsoleAppender
+
+appender.console.name = ConsoleAppender
+appender.console.type = CONSOLE
+appender.console.layout.type = PatternLayout
+appender.console.layout.pattern = %d{HH:mm:ss,SSS} %-5p %-60c %x - %m%n
--- a/src/site/markdown/changelogs.md
+++ b/src/site/markdown/changelogs.md
@@ -0,0 +1,5 @@
+## Changelog
+
+### 2.0
+
+- [GAL-602](https://jira.geedge.net/browse/GAL-602) 基于 Easy Stream 框架的配置化改造。
--- a/src/site/markdown/deploy.md
+++ b/src/site/markdown/deploy.md
@@ -0,0 +1,13 @@
+## Deploy
+
+- 准备 JDK ${java.version} 的环境
+
+- 准备 Flink ${flink.version} 的环境
+
+- [下载](./download.html) 对应版本 UDF 依赖 Jar
+
+- [下载](./download.html) 对应版本 Job 配置 (一个 yml 文件)
+
+- 执行命令 `flink run -Dflink.rest.bind-port=8081 -c com.geedgenetworks.flink.easy.core.Runner path/to/sip-rtp-correlation-<version>.jar job.yml`
+
+- 您将在控制台看到启动日志，同时您可以在 `http://<you-host>:8081` 看到任务 UI。
--- a/src/site/markdown/download.md
+++ b/src/site/markdown/download.md
@@ -0,0 +1,8 @@
+## Download
+
+### Easy Stream ${project.version}
+
+| UDF Jar                                                                                                                                                                                          | Job             |
+|--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------| --------------- |
+| [JAR](${project.distributionManagement.repository.url}/com/geedgenetworks/application/sip-rtp-correlation/${project.version}/${project.artifactId}-${project.version}.jar) ( [MD5](${project.distributionManagement.repository.url}/com/geedgenetworks/application/sip-rtp-correlation/${project.version}/${project.artifactId}-${project.version}.jar.md5) [SHA1](${project.distributionManagement.repository.url}/com/geedgenetworks/application/sip-rtp-correlation/${project.version}/${project.artifactId}-${project.version}.jar.sha1) ) | [YML](${project.distributionManagement.repository.url}/com/geedgenetworks/application/sip-rtp-correlation/${project.version}/${project.artifactId}-${project.version}.tar.gz) ( [MD5](${project.distributionManagement.repository.url}/com/geedgenetworks/application/sip-rtp-correlation/${project.version}/${project.artifactId}-${project.version}.tar.gz.md5) [SHA1](${project.distributionManagement.repository.url}/com/geedgenetworks/application/sip-rtp-correlation/${project.version}/${project.artifactId}-${project.version}.tar.gz.sha1) ) |
+
--- a/src/site/markdown/index.md
+++ b/src/site/markdown/index.md
@@ -0,0 +1,10 @@
+## SIP RTP Correlation
+
+SIP RTP Correlation 项目是一个使用 Apache Flink 实现的实时数据处理项目，旨在从 Kafka 中读取 SIP（Session Initiation Protocol）和 RTP（Real-time Transport Protocol）数据，将它们融合成完整的 VoIP（Voice over Internet Protocol）通话数据。
+
+SIP RTP Correlation 项目可以用于实时监控和分析 VoIP 通话数据，提取关键指标，以及进行实时报警和诊断。
+
+<br/>
+
+
+You can download the latest release from [Job Yml](./jobs/job.yml). And you can changelog from [CHANGELOG.md](./changelogs.html).
--- a/src/site/resources/css/site.css
+++ b/src/site/resources/css/site.css
@@ -0,0 +1,13 @@
+#banner {
+    height: 108px;
+    background: none;
+}
+
+#bannerLeft img {
+    margin-left: 18px;
+    margin-top: 10px;
+}
+
+div.well {
+    display: none;
+}
--- a/src/site/resources/images/logo.png
+++ b/src/site/resources/images/logo.png
--- a/src/site/site.xml
+++ b/src/site/site.xml
@@ -0,0 +1,56 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+  Licensed to the Apache Software Foundation (ASF) under one or more
+  contributor license agreements.  See the NOTICE file distributed with
+  this work for additional information regarding copyright ownership.
+  The ASF licenses this file to You under the Apache License, Version 2.0
+  (the "License"); you may not use this file except in compliance with
+  the License.  You may obtain maven-site.vm 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.
+-->
+<project name="SIP RTP Correlate">
+    <bannerLeft>
+        <name>Easy Stream</name>
+        <src>images/logo.png</src>
+        <href>#</href>
+    </bannerLeft>
+
+    <publishDate position="right"/>
+    <version position="right"/>
+
+    <skin>
+        <groupId>org.apache.maven.skins</groupId>
+        <artifactId>maven-fluido-skin</artifactId>
+        <version>1.10.0</version>
+    </skin>
+
+    <custom>
+        <fluidoSkin>
+            <sourceLineNumbersEnabled>true</sourceLineNumbersEnabled>
+        </fluidoSkin>
+    </custom>
+
+    <body>
+        <breadcrumbs position="left">
+            <item name="Galaxy" href="#"/>
+            <item name="Platform" href="#"/>
+            <item name="Easy Stream" href="#"/>
+            <item name="Application" href="#"/>
+        </breadcrumbs>
+
+        <menu name="OVERVIEW" inherit="top">
+            <item name="Introduction" href="index.html"/>
+            <item name="Deploy" href="deploy.html"/>
+            <item name="Download" href="download.html"/>
+        </menu>
+
+        <footer>
+            <![CDATA[ Copyright ©2022 <a href="#">Galaxy Platform</a>. All rights reserved.]]>
+        </footer>
+    </body>
+</project>
--- a/src/test/java/com/geedgenetworks/flink/easy/application/ApplicationTest.java
+++ b/src/test/java/com/geedgenetworks/flink/easy/application/ApplicationTest.java
@@ -0,0 +1,33 @@
+package com.geedgenetworks.flink.easy.application;
+
+import com.geedgenetworks.flink.easy.core.Runners;
+import org.junit.jupiter.api.Test;
+
+public class ApplicationTest {
+
+    static {
+        System.setProperty("easy.execute.mode", "validate");
+        System.setProperty("flink.rest.bind-port", "8081");
+//        System.setProperty("flink.rest.flamegraph.enabled", "true");
+        System.setProperty("flink.heartbeat.timeout", "1800000");
+    }
+
+    public static String discoverConfiguration(final String name) throws Exception {
+        var path = String.format("/jobs/%s.yml", name);
+        var resource = ApplicationTest.class.getResource(path);
+        if (resource == null) {
+            // maven
+            resource = ApplicationTest.class.getResource(String.format("../classes/%s", path));
+        }
+        if (resource == null) {
+            throw new IllegalArgumentException(
+                    String.format("Not found job '%s' in path [%s].", name, path));
+        }
+        return resource.getPath();
+    }
+
+    @Test
+    public void testJob() throws Exception {
+        Runners.run(discoverConfiguration("job"));
+    }
+}
--- a/src/test/resources/data/session-records.txt
+++ b/src/test/resources/data/session-records.txt
@@ -0,0 +1,4 @@
+{"log_id": 438322402985248769,"recv_time":946681200,"__inputid":"tsg_olap","session_id":10240001,"decoded_as":"RTP","ip_protocol":"udp","address_type":4,"client_ip":"192.168.64.8","server_ip":"192.168.39.62","client_port":25524,"server_port":4580,"t_vsys_id":0,"vsys_id":1024,"data_center":"tsg_olap","device_group":"tsg_olap","device_id":"0000000000000000","sled_ip":"127.0.0.1","app":"unknown","app_transition":"","client_geolocation":"unknown","server_geolocation":"unknown","decoded_path":"ETHERNET.IPv4.UDP.rtp","server_fqdn":"","out_src_mac":"00:1A:2B:3C:4D:5E","out_dest_mac":"5E:4D:3C:2B:1A:00","start_timestamp_ms":1715830004000,"end_timestamp_ms":946681200000,"tcp_rtt_ms":0,"tcp_client_isn":0,"tcp_server_isn":0,"tcp_handshake_latency_ms":0,"in_link_id":0,"out_link_id":0,"duration_ms":0,"sent_pkts":0,"sent_bytes":0,"received_pkts":0,"received_bytes":0,"tcp_c2s_ip_fragments":0,"tcp_s2c_ip_fragments":0,"tcp_c2s_rtx_pkts":0,"tcp_c2s_rtx_bytes":0,"tcp_s2c_rtx_pkts":0,"tcp_s2c_rtx_bytes":0,"tcp_c2s_o3_pkts":0,"tcp_s2c_o3_pkts":0,"tcp_c2s_lost_bytes":0,"tcp_s2c_lost_bytes":0,"flags":57620,"flags_identify_info":[1,1],"fqdn_category_list":[0],"monitor_rule_list":[0],"security_rule_list":[0],"sc_rule_list":[0],"shaping_rule_list":[0],"proxy_rule_list":[0],"statistics_rule_list":[0],"monitor_mirrored_pkts":0,"monitor_mirrored_bytes":0,"client_os_desc":"Windows","server_os_desc":"Linux","device_tag":"{\"tags\":[{\"tag\":\"data_center\",\"value\":\"tsg_olap\"},{\"tag\":\"device_group\",\"value\":\"tsg_olap\"}]}","dup_traffic_flag":0,"sc_rsp_raw":[0],"encapsulation":"[{\"tunnels_schema_type\":\"ETHERNET\",\"source_mac\":\"00:1A:2B:3C:4D:5E\",\"destination_mac\":\"5E:4D:3C:2B:1A:00\"}]","rtp_pcap_path":"123e4567-e89b-12d3-a456-426614174005"}
+{"log_id": 438322402985248769,"recv_time":946681200,"__inputid":"tsg_olap","session_id":10240002,"decoded_as":"SIP","ip_protocol":"udp","address_type":4,"client_ip":"10.0.0.1","server_ip":"192.0.2.1","client_port":1000,"server_port":60000,"t_vsys_id":0,"vsys_id":1025,"data_center":"tsg_olap","device_group":"tsg_olap","device_id":"0000000000000000","sled_ip":"127.0.0.1","app":"unknown","app_transition":"","client_geolocation":"unknown","server_geolocation":"unknown","decoded_path":"ETHERNET.IPv4.UDP.sip","server_fqdn":"","out_src_mac":"00:1A:2B:3C:4D:5E","out_dest_mac":"5E:4D:3C:2B:1A:00","start_timestamp_ms":1715830000100,"end_timestamp_ms":946681200000,"tcp_rtt_ms":0,"tcp_client_isn":0,"tcp_server_isn":0,"tcp_handshake_latency_ms":0,"in_link_id":0,"out_link_id":0,"duration_ms":0,"sent_pkts":0,"sent_bytes":0,"received_pkts":0,"received_bytes":0,"tcp_c2s_ip_fragments":0,"tcp_s2c_ip_fragments":0,"tcp_c2s_rtx_pkts":0,"tcp_c2s_rtx_bytes":0,"tcp_s2c_rtx_pkts":0,"tcp_s2c_rtx_bytes":0,"tcp_c2s_o3_pkts":0,"tcp_s2c_o3_pkts":0,"tcp_c2s_lost_bytes":0,"tcp_s2c_lost_bytes":0,"flags":8192,"flags_identify_info":[1,1],"fqdn_category_list":[0],"monitor_rule_list":[0],"security_rule_list":[0],"sc_rule_list":[0],"shaping_rule_list":[0],"proxy_rule_list":[0],"statistics_rule_list":[0],"monitor_mirrored_pkts":0,"monitor_mirrored_bytes":0,"client_os_desc":"Windows","server_os_desc":"Linux","device_tag":"{\"tags\":[{\"tag\":\"data_center\",\"value\":\"tsg_olap\"},{\"tag\":\"device_group\",\"value\":\"tsg_olap\"}]}","dup_traffic_flag":0,"sc_rsp_raw":[0],"encapsulation":"[{\"tunnels_schema_type\":\"ETHERNET\",\"source_mac\":\"00:1A:2B:3C:4D:5E\",\"destination_mac\":\"5E:4D:3C:2B:1A:00\"}]","sip_call_id":"NGMxZWY3Y2NmMzNlNGE3NzJhODgyZDAwM2YyMzQ4NGI.","sip_originator_description":"\"lina\"<sip:lina@192.0.2.1>;tag=1837055d","sip_responder_description":"\"1075\"<sip:1075@192.0.2.1>","sip_originator_sdp_connect_ip":"192.168.64.85","sip_originator_sdp_media_port":25524,"sip_originator_sdp_media_type":"application/sdp","sip_server":"OpenSIPS (2.4.11 (x86_64/linux))","sip_responder_sdp_connect_ip":"192.168.39.62","sip_responder_sdp_media_port":4580,"sip_responder_sdp_media_type":"application/sdp","sip_duration_s":590,"sip_bye":"responder","sip_cseq":"2 BYE","sip_via":"SIP/2.0/UDP 192.0.2.1:5060;branch=z9hG4bKbe7c.392190f1.0","sip_user_agent":"eyeBeam release 1011d stamp 40820","sip_is_request":0}
+{"log_id": 438322402985248769,"recv_time":946681200,"__inputid":"tsg_olap","session_id":10240003,"decoded_as":"RTP","ip_protocol":"udp","address_type":4,"client_ip":"192.168.164.18","server_ip":"192.168.39.162","client_port":65121,"server_port":4670,"t_vsys_id":0,"vsys_id":1024,"data_center":"tsg_olap","device_group":"tsg_olap","device_id":"0000000000000000","sled_ip":"127.0.0.1","app":"unknown","app_transition":"","client_geolocation":"unknown","server_geolocation":"unknown","decoded_path":"ETHERNET.IPv4.UDP.rtp","server_fqdn":"","out_src_mac":"00:1A:2B:3C:4D:5E","out_dest_mac":"5E:4D:3C:2B:1A:00","start_timestamp_ms":1715830000000,"end_timestamp_ms":946681200000,"tcp_rtt_ms":0,"tcp_client_isn":0,"tcp_server_isn":0,"tcp_handshake_latency_ms":0,"in_link_id":0,"out_link_id":0,"duration_ms":0,"sent_pkts":0,"sent_bytes":0,"received_pkts":0,"received_bytes":0,"tcp_c2s_ip_fragments":0,"tcp_s2c_ip_fragments":0,"tcp_c2s_rtx_pkts":0,"tcp_c2s_rtx_bytes":0,"tcp_s2c_rtx_pkts":0,"tcp_s2c_rtx_bytes":0,"tcp_c2s_o3_pkts":0,"tcp_s2c_o3_pkts":0,"tcp_c2s_lost_bytes":0,"tcp_s2c_lost_bytes":0,"flags":57620,"flags_identify_info":[1,1],"fqdn_category_list":[0],"monitor_rule_list":[0],"security_rule_list":[0],"sc_rule_list":[0],"shaping_rule_list":[0],"proxy_rule_list":[0],"statistics_rule_list":[0],"monitor_mirrored_pkts":0,"monitor_mirrored_bytes":0,"client_os_desc":"Windows","server_os_desc":"Linux","device_tag":"{\"tags\":[{\"tag\":\"data_center\",\"value\":\"tsg_olap\"},{\"tag\":\"device_group\",\"value\":\"tsg_olap\"}]}","dup_traffic_flag":0,"sc_rsp_raw":[0],"encapsulation":"[{\"tunnels_schema_type\":\"ETHERNET\",\"source_mac\":\"00:1A:2B:3C:4D:5E\",\"destination_mac\":\"5E:4D:3C:2B:1A:00\"}]","rtp_pcap_path":"123e4567-e89b-12d3-a456-426614174005"}
+{"log_id": 438322402985248769,"recv_time":946681200,"__inputid":"tsg_olap","session_id":10240004,"decoded_as":"SIP","ip_protocol":"udp","address_type":4,"client_ip":"10.0.0.2","server_ip":"192.0.2.2","client_port":1000,"server_port":60000,"t_vsys_id":0,"vsys_id":1024,"data_center":"tsg_olap","device_group":"tsg_olap","device_id":"0000000000000000","sled_ip":"127.0.0.1","app":"unknown","app_transition":"","client_geolocation":"unknown","server_geolocation":"unknown","decoded_path":"ETHERNET.IPv4.UDP.sip","server_fqdn":"","out_src_mac":"00:1A:2B:3C:4D:5E","out_dest_mac":"5E:4D:3C:2B:1A:00","start_timestamp_ms":1715830000000,"end_timestamp_ms":946681200000,"tcp_rtt_ms":0,"tcp_client_isn":0,"tcp_server_isn":0,"tcp_handshake_latency_ms":0,"in_link_id":0,"out_link_id":0,"duration_ms":0,"sent_pkts":0,"sent_bytes":0,"received_pkts":0,"received_bytes":0,"tcp_c2s_ip_fragments":0,"tcp_s2c_ip_fragments":0,"tcp_c2s_rtx_pkts":0,"tcp_c2s_rtx_bytes":0,"tcp_s2c_rtx_pkts":0,"tcp_s2c_rtx_bytes":0,"tcp_c2s_o3_pkts":0,"tcp_s2c_o3_pkts":0,"tcp_c2s_lost_bytes":0,"tcp_s2c_lost_bytes":0,"flags":24584,"flags_identify_info":[1,1],"fqdn_category_list":[0],"monitor_rule_list":[0],"security_rule_list":[0],"sc_rule_list":[0],"shaping_rule_list":[0],"proxy_rule_list":[0],"statistics_rule_list":[0],"monitor_mirrored_pkts":0,"monitor_mirrored_bytes":0,"client_os_desc":"Windows","server_os_desc":"Linux","device_tag":"{\"tags\":[{\"tag\":\"data_center\",\"value\":\"tsg_olap\"},{\"tag\":\"device_group\",\"value\":\"tsg_olap\"}]}","dup_traffic_flag":0,"sc_rsp_raw":[0],"encapsulation":"[{\"tunnels_schema_type\":\"ETHERNET\",\"source_mac\":\"00:1A:2B:3C:4D:5E\",\"destination_mac\":\"5E:4D:3C:2B:1A:00\"}]","sip_call_id":"IUMxZWY3Y2NmMzNlNGE3NzJhODgyZDAwM2YyMzQ4NGI.","sip_originator_description":"\"lina\"<sip:lina@192.0.2.1>;tag=1837055d","sip_responder_description":"\"1075\"<sip:1075@192.0.2.1>","sip_originator_sdp_connect_ip":"192.168.64.8","sip_originator_sdp_media_port":25524,"sip_originator_sdp_media_type":"application/sdp","sip_server":"OpenSIPS (2.4.11 (x86_64/linux))","sip_responder_sdp_connect_ip":"192.168.39.62","sip_responder_sdp_media_port":4580,"sip_responder_sdp_media_type":"application/sdp","sip_duration_s":590,"sip_bye":"responder","sip_cseq":"2 BYE","sip_via":"SIP/2.0/UDP 192.0.2.1:5060;branch=z9hG4bKbe7c.392190f1.0","sip_user_agent":"eyeBeam release 1011d stamp 40820","sip_is_request":0}
--- a/tools/dist/target.xml
+++ b/tools/dist/target.xml
@@ -0,0 +1,44 @@
+<!--
+Licensed to the Apache Software Foundation (ASF) under one
+or more contributor license agreements.  See the NOTICE file
+distributed with this work for additional information
+regarding copyright ownership.  The ASF licenses this file
+to you 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.
+-->
+<assembly
+        xmlns="http://maven.apache.org/plugins/maven-assembly-plugin/assembly/1.1.0"
+        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+        xsi:schemaLocation="http://maven.apache.org/plugins/maven-assembly-plugin/assembly/1.1.0 http://maven.apache.org/xsd/assembly-1.1.0.xsd">
+    <id>bin</id>
+
+    <formats>
+        <format>tar.gz</format>
+    </formats>
+
+    <includeBaseDirectory>false</includeBaseDirectory>
+
+    <fileSets>
+        <fileSet>
+            <directory>src/main/resources/jobs</directory>
+            <includes>
+                <include>*.yml</include>
+            </includes>
+            <fileMode>0755</fileMode>
+            <lineEnding>lf</lineEnding>
+            <directoryMode>0644</directoryMode>
+            <outputDirectory>./</outputDirectory>
+        </fileSet>
+    </fileSets>
+
+</assembly>
--- a/tools/maven/checkstyle.xml
+++ b/tools/maven/checkstyle.xml
@@ -0,0 +1,394 @@
+<?xml version="1.0"?>
+<!DOCTYPE module PUBLIC
+        "-//Puppy Crawl//DTD Check Configuration 1.3//EN"
+        "http://www.puppycrawl.com/dtds/configuration_1_3.dtd">
+
+<!--
+This is a checkstyle configuration file. For descriptions of
+what the following rules do, please see the checkstyle configuration
+page at http://checkstyle.sourceforge.net/config.html.
+-->
+
+<module name="Checker">
+
+    <module name="RegexpSingleline">
+        <!-- Checks that TODOs don't have stuff in parenthesis, e.g., username. -->
+        <property name="format" value="((//.*)|(\*.*))TODO\("/>
+        <property name="message" value="TODO comments must not include usernames."/>
+        <property name="severity" value="error"/>
+    </module>
+
+    <module name="RegexpSingleline">
+        <property name="format" value="\s+$"/>
+        <property name="message" value="Trailing whitespace"/>
+        <property name="severity" value="error"/>
+    </module>
+
+    <module name="RegexpSingleline">
+        <property name="format" value="Throwables.propagate\("/>
+        <property name="message" value="Throwables.propagate is deprecated"/>
+        <property name="severity" value="error"/>
+    </module>
+
+    <!-- Prevent *Tests.java as tools may not pick them up -->
+    <module name="RegexpOnFilename">
+        <property name="fileNamePattern" value=".*Tests\.java$"/>
+    </module>
+
+    <module name="SuppressionFilter">
+        <property name="file" value="${checkstyle.suppressions.file}" default="suppressions.xml"/>
+    </module>
+
+    <module name="FileLength">
+        <property name="max" value="3000"/>
+    </module>
+
+    <!-- All Java AST specific tests live under TreeWalker module. -->
+    <module name="TreeWalker">
+
+        <!-- Allow use of comment to suppress javadocstyle -->
+        <module name="SuppressionCommentFilter">
+            <property name="offCommentFormat" value="CHECKSTYLE.OFF\: ([\w\|]+)"/>
+            <property name="onCommentFormat" value="CHECKSTYLE.ON\: ([\w\|]+)"/>
+            <property name="checkFormat" value="$1"/>
+        </module>
+
+        <!-- Prohibit T.getT() methods for standard boxed types -->
+        <module name="Regexp">
+            <property name="format" value="Boolean\.getBoolean"/>
+            <property name="illegalPattern" value="true"/>
+            <property name="message" value="Use System.getProperties() to get system properties."/>
+        </module>
+
+        <module name="Regexp">
+            <property name="format" value="Integer\.getInteger"/>
+            <property name="illegalPattern" value="true"/>
+            <property name="message" value="Use System.getProperties() to get system properties."/>
+        </module>
+
+        <module name="Regexp">
+            <property name="format" value="Long\.getLong"/>
+            <property name="illegalPattern" value="true"/>
+            <property name="message" value="Use System.getProperties() to get system properties."/>
+        </module>
+
+        <!--
+
+        IllegalImport cannot blacklist classes so we have to fall back to Regexp.
+
+        -->
+
+        <!-- forbid use of commons lang validate -->
+        <module name="Regexp">
+            <property name="format" value="org\.apache\.commons\.lang3\.Validate"/>
+            <property name="illegalPattern" value="true"/>
+            <property name="message"
+                      value="Use Guava Checks instead of Commons Validate. Please refer to the coding guidelines."/>
+        </module>
+        <module name="Regexp">
+            <property name="format" value="org\.apache\.commons\.lang\."/>
+            <property name="illegalPattern" value="true"/>
+            <property name="message" value="Use commons-lang3 instead of commons-lang."/>
+        </module>
+        <module name="Regexp">
+            <property name="format" value="org\.codehaus\.jettison"/>
+            <property name="illegalPattern" value="true"/>
+            <property name="message" value="Use flink-shaded-jackson instead of jettison."/>
+        </module>
+        <module name="Regexp">
+            <property name="format" value="org\.testcontainers\.shaded"/>
+            <property name="illegalPattern" value="true"/>
+            <property name="message"
+                      value="Use utilities from appropriate library instead of org.testcontainers."/>
+        </module>
+
+        <!-- Enforce Java-style array declarations -->
+        <module name="ArrayTypeStyle"/>
+
+        <module name="TodoComment">
+            <!-- Checks that disallowed strings are not used in comments.  -->
+            <property name="format" value="(FIXME)|(XXX)"/>
+        </module>
+
+        <!--
+
+        IMPORT CHECKS
+
+        -->
+
+        <module name="RedundantImport">
+            <!-- Checks for redundant import statements. -->
+            <property name="severity" value="error"/>
+            <message key="import.redundancy"
+                     value="Redundant import {0}."/>
+        </module>
+
+        <module name="IllegalImport">
+            <property name="illegalPkgs"
+                      value="autovalue.shaded, avro.shaded, com.google.api.client.repackaged, com.google.appengine.repackaged"/>
+        </module>
+        <module name="IllegalImport">
+            <property name="illegalPkgs" value="com.fasterxml.jackson"/>
+            <message key="import.illegal" value="{0}; Use flink-shaded-jackson instead."/>
+        </module>
+        <module name="IllegalImport">
+            <property name="illegalPkgs" value="org.codehaus.jackson"/>
+            <message key="import.illegal" value="{0}; Use flink-shaded-jackson instead."/>
+        </module>
+        <module name="IllegalImport">
+            <property name="illegalPkgs" value="org.objectweb.asm"/>
+            <message key="import.illegal" value="{0}; Use flink-shaded-asm instead."/>
+        </module>
+        <module name="IllegalImport">
+            <property name="illegalPkgs" value="io.netty"/>
+            <message key="import.illegal" value="{0}; Use flink-shaded-netty instead."/>
+        </module>
+
+        <module name="RedundantModifier">
+            <!-- Checks for redundant modifiers on various symbol definitions.
+              See: http://checkstyle.sourceforge.net/config_modifier.html#RedundantModifier
+
+              We exclude METHOD_DEF to allow final methods in final classes to make them more future-proof.
+            -->
+            <property name="tokens"
+                      value="VARIABLE_DEF, ANNOTATION_FIELD_DEF, INTERFACE_DEF, CLASS_DEF, ENUM_DEF"/>
+        </module>
+
+        <!--
+            IllegalImport cannot blacklist classes, and c.g.api.client.util is used for some shaded
+            code and some useful code. So we need to fall back to Regexp.
+        -->
+        <module name="RegexpSinglelineJava">
+            <property name="format" value="^import com.google.common.base.Preconditions;$"/>
+            <property name="message" value="Static import functions from Guava Preconditions"/>
+        </module>
+
+        <module name="UnusedImports">
+            <property name="severity" value="error"/>
+            <property name="processJavadoc" value="true"/>
+            <message key="import.unused"
+                     value="Unused import: {0}."/>
+        </module>
+
+        <!--
+
+        NAMING CHECKS
+
+        -->
+
+        <!-- Item 38 - Adhere to generally accepted naming conventions -->
+
+        <module name="PackageName">
+            <!-- Validates identifiers for package names against the
+              supplied expression. -->
+            <!-- Here the default checkstyle rule restricts package name parts to
+              seven characters, this is not in line with common practice at Google.
+            -->
+            <property name="format" value="^[a-z]+(\.[a-z][a-z0-9]{1,})*$"/>
+            <property name="severity" value="error"/>
+        </module>
+
+        <module name="TypeNameCheck">
+            <!-- Validates static, final fields against the
+            expression "^[A-Z][a-zA-Z0-9]*$". -->
+            <metadata name="altname" value="TypeName"/>
+            <property name="severity" value="error"/>
+        </module>
+
+        <module name="ConstantNameCheck">
+            <!-- Validates non-private, static, final fields against the supplied
+            public/package final fields "^[A-Z][A-Z0-9]*(_[A-Z0-9]+)*$". -->
+            <metadata name="altname" value="ConstantName"/>
+            <property name="applyToPublic" value="true"/>
+            <property name="applyToProtected" value="true"/>
+            <property name="applyToPackage" value="true"/>
+            <property name="applyToPrivate" value="true"/>
+            <property name="format" value="^([A-Z][A-Z0-9]*(_[A-Z0-9]+)*|FLAG_.*)$"/>
+            <message key="name.invalidPattern"
+                     value="Variable ''{0}'' should be in ALL_CAPS (if it is a constant) or be private (otherwise)."/>
+            <property name="severity" value="error"/>
+        </module>
+
+        <module name="StaticVariableNameCheck">
+            <!-- Validates static, non-final fields against the supplied
+            expression "^[a-z][a-zA-Z0-9]*_?$". -->
+            <metadata name="altname" value="StaticVariableName"/>
+            <property name="applyToPublic" value="true"/>
+            <property name="applyToProtected" value="true"/>
+            <property name="applyToPackage" value="true"/>
+            <property name="applyToPrivate" value="true"/>
+            <property name="format" value="^[a-z][a-zA-Z0-9]*_?$"/>
+            <property name="severity" value="error"/>
+        </module>
+
+        <module name="MemberNameCheck">
+            <!-- Validates non-static members against the supplied expression. -->
+            <metadata name="altname" value="MemberName"/>
+            <property name="applyToPublic" value="true"/>
+            <property name="applyToProtected" value="true"/>
+            <property name="applyToPackage" value="true"/>
+            <property name="applyToPrivate" value="true"/>
+            <property name="format" value="^[a-z][a-zA-Z0-9]*$"/>
+            <property name="severity" value="error"/>
+        </module>
+
+        <module name="MethodNameCheck">
+            <!-- Validates identifiers for method names. -->
+            <metadata name="altname" value="MethodName"/>
+            <property name="format" value="^[a-z][a-zA-Z0-9]*(_[a-zA-Z0-9]+)*$"/>
+            <property name="severity" value="error"/>
+        </module>
+
+        <module name="ParameterName">
+            <!-- Validates identifiers for method parameters against the
+              expression "^[a-z][a-zA-Z0-9]*$". -->
+            <property name="severity" value="error"/>
+        </module>
+
+        <module name="LocalFinalVariableName">
+            <!-- Validates identifiers for local final variables against the
+              expression "^[a-z][a-zA-Z0-9]*$". -->
+            <property name="severity" value="error"/>
+        </module>
+
+        <module name="LocalVariableName">
+            <!-- Validates identifiers for local variables against the
+              expression "^[a-z][a-zA-Z0-9]*$". -->
+            <property name="severity" value="error"/>
+        </module>
+
+        <!--
+
+        LENGTH and CODING CHECKS
+
+        -->
+
+        <!-- Checks for braces around if and else blocks -->
+        <module name="NeedBraces">
+            <property name="severity" value="error"/>
+            <property name="tokens"
+                      value="LITERAL_IF, LITERAL_ELSE, LITERAL_FOR, LITERAL_WHILE, LITERAL_DO"/>
+        </module>
+
+        <module name="UpperEll">
+            <!-- Checks that long constants are defined with an upper ell.-->
+            <property name="severity" value="error"/>
+        </module>
+
+        <module name="FallThrough">
+            <!-- Warn about falling through to the next case statement.  Similar to
+            javac -Xlint:fallthrough, but the check is suppressed if a single-line comment
+            on the last non-blank line preceding the fallen-into case contains 'fall through' (or
+            some other variants that we don't publicized to promote consistency).
+            -->
+            <property name="reliefPattern"
+                      value="fall through|Fall through|fallthru|Fallthru|falls through|Falls through|fallthrough|Fallthrough|No break|NO break|no break|continue on"/>
+            <property name="severity" value="error"/>
+        </module>
+
+        <!-- Checks for over-complicated boolean expressions. -->
+        <module name="SimplifyBooleanExpression"/>
+
+        <!-- Detects empty statements (standalone ";" semicolon). -->
+        <module name="EmptyStatement"/>
+
+        <!-- Detect multiple consecutive semicolons (e.g. ";;"). -->
+        <module name="RegexpSinglelineJava">
+            <property name="format" value=";{2,}"/>
+            <property name="message" value="Use one semicolon"/>
+            <property name="ignoreComments" value="true"/>
+        </module>
+
+        <!--
+
+        MODIFIERS CHECKS
+
+        -->
+
+        <module name="ModifierOrder">
+            <!-- Warn if modifier order is inconsistent with JLS3 8.1.1, 8.3.1, and
+                 8.4.3.  The prescribed order is:
+                 public, protected, private, abstract, static, final, transient, volatile,
+                 synchronized, native, strictfp
+              -->
+            <property name="severity" value="error"/>
+        </module>
+
+
+        <!--
+
+        WHITESPACE CHECKS
+
+        -->
+
+        <module name="EmptyLineSeparator">
+            <!-- Checks for empty line separator between tokens. The only
+                 excluded token is VARIABLE_DEF, allowing class fields to
+                 be declared on consecutive lines.
+            -->
+            <property name="allowMultipleEmptyLines" value="false"/>
+            <property name="allowMultipleEmptyLinesInsideClassMembers" value="false"/>
+            <property name="tokens" value="PACKAGE_DEF, IMPORT, STATIC_IMPORT, CLASS_DEF,
+        INTERFACE_DEF, ENUM_DEF, STATIC_INIT, INSTANCE_INIT, METHOD_DEF,
+        CTOR_DEF"/>
+        </module>
+
+        <module name="SingleSpaceSeparator"/>
+
+        <module name="WhitespaceAround">
+            <!-- Checks that various tokens are surrounded by whitespace.
+                 This includes most binary operators and keywords followed
+                 by regular or curly braces.
+            -->
+            <property name="tokens" value="ASSIGN, BAND, BAND_ASSIGN, BOR,
+        BOR_ASSIGN, BSR, BSR_ASSIGN, BXOR, BXOR_ASSIGN, COLON, DIV, DIV_ASSIGN,
+        EQUAL, GE, GT, LAMBDA, LAND, LE, LITERAL_CATCH, LITERAL_DO, LITERAL_ELSE,
+        LITERAL_FINALLY, LITERAL_FOR, LITERAL_IF, LITERAL_RETURN,
+        LITERAL_SYNCHRONIZED, LITERAL_TRY, LITERAL_WHILE, LOR, LT, MINUS,
+        MINUS_ASSIGN, MOD, MOD_ASSIGN, NOT_EQUAL, PLUS, PLUS_ASSIGN, QUESTION,
+        SL, SL_ASSIGN, SR_ASSIGN, STAR, STAR_ASSIGN, TYPE_EXTENSION_AND"/>
+            <property name="severity" value="error"/>
+        </module>
+
+        <module name="WhitespaceAfter">
+            <!-- Checks that commas, semicolons and typecasts are followed by
+                 whitespace.
+            -->
+            <property name="tokens" value="COMMA, SEMI, TYPECAST"/>
+        </module>
+
+        <module name="NoWhitespaceAfter">
+            <!-- Checks that there is no whitespace after various unary operators.
+                 Linebreaks are allowed.
+            -->
+            <property name="tokens" value="BNOT, DEC, DOT, INC, LNOT, UNARY_MINUS,
+        UNARY_PLUS"/>
+            <property name="allowLineBreaks" value="true"/>
+            <property name="severity" value="error"/>
+        </module>
+
+        <module name="NoWhitespaceBefore">
+            <!-- Checks that there is no whitespace before various unary operators.
+                 Linebreaks are allowed.
+            -->
+            <property name="tokens" value="SEMI, DOT, POST_DEC, POST_INC"/>
+            <property name="allowLineBreaks" value="true"/>
+            <property name="severity" value="error"/>
+        </module>
+
+        <module name="OperatorWrap">
+            <!-- Checks that assignment operators are at the end of the line. -->
+            <property name="option" value="eol"/>
+            <property name="tokens" value="ASSIGN"/>
+        </module>
+
+        <module name="ParenPad">
+            <!-- Checks that there is no whitespace before close parens or after
+                 open parens.
+            -->
+            <property name="severity" value="error"/>
+        </module>
+
+    </module>
+</module>
+
--- a/tools/maven/spotbugs-exclude.xml
+++ b/tools/maven/spotbugs-exclude.xml
@@ -0,0 +1,18 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<FindBugsFilter>
+    <Match>
+        <Bug pattern="EI_EXPOSE_REP"/>
+    </Match>
+    <Match>
+        <Bug pattern="EI_EXPOSE_REP2"/>
+    </Match>
+    <Match>
+        <Bug pattern="SE_NO_SERIALVERSIONID"/>
+    </Match>
+    <Match>
+        <Bug pattern="SE_TRANSIENT_FIELD_NOT_RESTORED"/>
+    </Match>
+    <Match>
+        <Bug pattern="SQL_PREPARED_STATEMENT_GENERATED_FROM_NONCONSTANT_STRING"/>
+    </Match>
+</FindBugsFilter>
--- a/tools/maven/suppressions.xml
+++ b/tools/maven/suppressions.xml
@@ -0,0 +1,12 @@
+<?xml version="1.0"?>
+<!DOCTYPE suppressions PUBLIC
+	"-//Puppy Crawl//DTD Suppressions 1.1//EN"
+	"http://www.puppycrawl.com/dtds/suppressions_1_1.dtd">
+
+<suppressions>
+	<!-- target directory is not relevant for checkstyle -->
+	<suppress
+		files="[\\/]target[\\/]"
+		checks=".*"/>
+
+</suppressions>
Author	SHA1	Message	Date
梁超	1bf739af73	Merge branch 'feature/easy-refactor' into 'develop' [GAL-602] refactor: refactor this module based on the Easy Stream framework. See merge request galaxy/tsg_olap/sip-rtp-correlation!26	2024-07-01 07:56:41 +00:00
chaochaoc	e106c6c6d6	[GAL-602] style: use validate mode	2024-07-01 15:52:40 +08:00
chaochaoc	db1326f582	[GAL-602] docs: add yml	2024-07-01 15:41:47 +08:00
chaochaoc	67a40e2719	[GAL-602] feat: update key-by expression	2024-07-01 15:40:35 +08:00
chaoc	7723c48e5b	fix: fix some bugs	2024-06-29 16:10:14 +08:00
chaochaoc	c980123d55	[GAL-602] style: remove unused file	2024-06-28 21:40:36 +08:00
chaochaoc	cf98121180	[GAL-602] feat: add docs and fix some bugs	2024-06-28 18:47:28 +08:00
chaochaoc	e5a5331464	[GAL-602] feat: add docs and fix some bugs	2024-06-28 18:45:53 +08:00
chaochaoc	07125ea224	[GAL-602] style: add comment	2024-06-28 10:23:39 +08:00
chaochaoc	6164546dbb	[GAL-602] refactor: add sink fail records	2024-06-28 10:21:02 +08:00
chaochaoc	eab517c44f	[GAL-602] refactor: impl correlate jobs through config yml	2024-06-27 18:22:00 +08:00
chaochaoc	c077c16a3a	[GAL-602] refactor: impl sip doube-ways correlate	2024-06-27 15:31:14 +08:00
chaochaoc	1ff8c985c7	[GAL-602] refactor: using the easy stream	2024-06-26 18:21:46 +08:00
梁超	53c6c267e8	Merge branch 'hotfix/field-completion' into 'main' [GAL-568] fix: add field 'rtp_originator_dir' See merge request galaxy/tsg_olap/sip-rtp-correlation!25	2024-05-10 05:50:10 +00:00
chaochaoc	20e8421900	chore: update versions	2024-05-10 13:49:37 +08:00
chaochaoc	d01235e092	[GAL-568] fix: add field 'rtp_originator_dir'	2024-05-10 11:58:35 +08:00
梁超	12828291a9	Merge branch 'hotfix/app-name' into 'main' fix: modify job name See merge request galaxy/tsg_olap/sip-rtp-correlation!24	2023-12-18 07:52:56 +00:00
chaoc	f21e814763	chore: update versions	2023-12-18 15:47:41 +08:00
chaoc	11c2c641bb	docs: add job name config	2023-12-18 15:47:30 +08:00
chaoc	59cabb4868	fix: add job name config	2023-12-18 15:47:23 +08:00
chaoc	b7c739a955	chore: update version	2023-12-15 10:32:17 +08:00
梁超	1f6ef08a30	Merge branch 'hotfix/illegal-flags' into 'release/1.2' [GAL-444] fix: fix error caused by invalid flags See merge request galaxy/tsg_olap/sip-rtp-correlation!23	2023-12-15 02:27:43 +00:00
chaoc	87abd1e2ca	[GAL-444] fix: fix error caused by invalid flags	2023-12-15 10:24:06 +08:00
梁超	2542a8bfd2	Merge branch 'bugfix/repeat-voip' into 'main' chore: update version See merge request galaxy/tsg_olap/sip-rtp-correlation!21	2023-12-07 09:22:19 +00:00
chaoc	1c0259a95c	chore: update version	2023-12-07 17:20:20 +08:00
梁超	37f49c40d5	Merge branch 'bugfix/repeat-voip' into 'main' fix: repeated voip record See merge request galaxy/tsg_olap/sip-rtp-correlation!20	2023-12-07 09:19:32 +00:00
chaoc	beef47df4c	fix: add ipaddr non-empty check	2023-12-07 17:17:05 +08:00
chaoc	6d77d1c3c0	fix: remove rtp from state when fusion successfully	2023-12-07 17:15:11 +08:00
梁超	4179a0a887	Merge branch 'bugfix/some-err' into 'main' [GAL-444] fix: output unmatched sip record See merge request galaxy/tsg_olap/sip-rtp-correlation!19	2023-12-06 10:17:02 +00:00
chaoc	6ebefc9026	chore: update version	2023-12-06 18:15:37 +08:00
chaoc	701019c38a	[GAL-444] fix: output unmatched sip record	2023-12-06 18:14:52 +08:00
chaoc	6ae7fdef06	[GAL-444] fix: use default '1' instead of '0'	2023-12-06 18:14:33 +08:00
梁超	e277117c6d	Merge branch 'release/1.2' into 'main' chore: add distribution management See merge request galaxy/tsg_olap/sip-rtp-correlation!18	2023-12-05 09:53:19 +00:00
chaoc	d54c93b61d	chore: add distribution management	2023-12-05 17:52:49 +08:00
梁超	3b06d3dfd5	Merge branch 'release/1.2' into 'main' chore: update version See merge request galaxy/tsg_olap/sip-rtp-correlation!17	2023-12-05 09:51:35 +00:00
chaoc	e718120be1	chore: update version	2023-12-05 17:47:51 +08:00
梁超	1dffb8fb6f	Merge branch 'feature/field-update' into 'main' [GAL-444] feat: field update See merge request galaxy/tsg_olap/sip-rtp-correlation!16	2023-12-05 09:45:50 +00:00
chaoc	0994219ede	fix: long value reader	2023-12-05 17:43:32 +08:00
chaoc	6f915e5162	fix: update flag	2023-12-04 17:19:32 +08:00
chaoc	35247d7414	fix: update field name	2023-12-04 17:08:53 +08:00
chaoc	64f19b528e	chore: update version	2023-12-04 10:29:04 +08:00
chaoc	d0c3ebd60f	feat: update stream dir field read method	2023-12-04 10:28:03 +08:00
chaoc	114c180742	feature: field update	2023-11-21 09:59:44 +08:00
梁超	e51d693fa0	Merge branch 'release/1.1' into 'main' chore: update version See merge request galaxy/tsg_olap/sip-rtp-correlation!15	2023-10-25 08:43:28 +00:00
chaoc	757808d313	chore: update version	2023-10-25 16:42:31 +08:00
梁超	e123233af9	Merge branch 'feature/config-key' into 'main' [GAL-419] feat: modify config option name See merge request galaxy/tsg_olap/sip-rtp-correlation!14	2023-10-25 08:40:51 +00:00
chaoc	ad3072cc7a	docs: modify config option name	2023-10-25 16:35:30 +08:00
chaoc	617ddab7ab	feat: modify config option name	2023-10-25 16:30:27 +08:00
梁超	45891bc734	Merge branch 'feature/internal-ip-config' into 'main' feat: add config 'DETERMINE_INTRANET_IP_BE_ABNORMAL' See merge request galaxy/tsg_olap/sip-rtp-correlation!13	2023-10-13 06:43:38 +00:00
chaoc	19e0bce58f	chore: update version	2023-10-13 14:43:08 +08:00
chaoc	10ce6cfa07	feat: add config 'DETERMINE_INTRANET_IP_BE_ABNORMAL'	2023-10-13 14:38:23 +08:00
梁超	9d5d99974b	Merge branch 'release/1.0' into 'main' release: 1.0 See merge request galaxy/tsg_olap/sip-rtp-correlation!12	2023-10-12 06:52:09 +00:00
梁超	970977ba3c	Merge branch 'hotfix/output-sip' into 'release/1.0' hotfix: add sip record output See merge request galaxy/tsg_olap/sip-rtp-correlation!11	2023-10-12 02:44:32 +00:00
chaoc	732d9f5aa9	style: update version	2023-10-12 10:42:48 +08:00
chaoc	96fa19aea1	fix: use event time timer	2023-10-12 10:36:44 +08:00
chaoc	1b7c33d078	fix: output sip record	2023-10-12 10:36:29 +08:00
liang chao	b9463f07ac	Merge branch 'release/1.0' into 'main' merge: 1.0-rc3 See merge request galaxy/tsg_olap/sip-rtp-correlation!10	2023-08-28 03:30:06 +00:00
liang chao	35e2807a91	Merge branch 'hotfix/rename' into 'release/1.0' style: rename job name See merge request galaxy/tsg_olap/sip-rtp-correlation!9	2023-08-28 03:29:10 +00:00
chaoc	2275f349d1	Merge remote-tracking branch 'origin/release/1.0' into hotfix/rename	2023-08-28 11:27:23 +08:00
chaoc	1fedfbe4b8	style: add plugin reproducible	2023-08-28 11:26:25 +08:00
chaoc	b2f15b3919	style: modify job name	2023-08-28 11:11:02 +08:00
liang chao	8fc8cc7c2d	Merge branch 'hotfix/null-point-err' into 'release/1.0' style: update versions See merge request galaxy/tsg_olap/sip-rtp-correlation!8	2023-08-21 09:09:25 +00:00
chaoc	98bb843159	style: update versions	2023-08-21 17:08:51 +08:00
liang chao	edb044596e	Merge branch 'hotfix/null-point-err' into 'release/1.0' docs: add hotfix changelog See merge request galaxy/tsg_olap/sip-rtp-correlation!7	2023-08-21 09:06:49 +00:00
chaoc	557156af79	docs: add hotfix changelog	2023-08-21 17:06:22 +08:00
liang chao	32a811fb1c	Merge branch 'hotfix/null-point-err' into 'release/1.0' fix(utils): fix null point err See merge request galaxy/tsg_olap/sip-rtp-correlation!6	2023-08-21 08:59:11 +00:00
chaoc	36cbaebf0c	fix(utils): fix null point err	2023-08-21 16:57:13 +08:00
liang chao	da572f4bd0	Merge branch 'release/1.0' into 'main' merge: 1.0.rc1 See merge request galaxy/tsg_olap/sip-rtp-correlation!5	2023-08-16 03:05:22 +00:00
chaoc	68e91c9ae5	style: update version	2023-08-16 10:45:46 +08:00
chaoc	69004f5c02	test: add data template	2023-08-15 09:53:50 +08:00
chaoc	9804b0cc52	doc: update readme for run cmd	2023-08-14 14:46:04 +08:00
chaoc	fa619d2595	doc: update readme	2023-08-14 11:42:59 +08:00
chaoc	a44d434952	doc: update readme for add config desc	2023-08-14 11:12:45 +08:00
chaoc	736bc40202	style: modify rtp clear interval default value	2023-08-14 11:12:01 +08:00
chaoc	6a2e5bacb9	perf: code optimization	2023-08-14 10:51:42 +08:00
chaoc	da69688270	style: update default parallelism	2023-08-14 10:50:41 +08:00
chaoc	a4e92c03e7	style: use enum type	2023-08-14 10:50:02 +08:00
chaoc	b207f8fb8e	pref: support multi-parallel source	2023-08-14 10:49:35 +08:00
chaoc	5f16a98402	style: remove unused code	2023-08-14 10:48:15 +08:00
chaoc	43282c7163	style: use enum type	2023-08-14 10:47:51 +08:00
liang chao	77cdd73f02	Merge branch 'hotfix/no-collect-expire-data' into 'main' fix: cannot collect data due to expiration See merge request galaxy/tsg_olap/sip-rtp-correlation!4	2023-08-11 06:18:46 +00:00
chaoc	b38f128f32	style: optimize imports	2023-08-11 14:16:11 +08:00
chaoc	2c64391737	perf(functions): fix the issue of being unable to collect expired data	2023-08-11 14:14:58 +08:00
liang chao	5481a7b9ee	Merge branch 'feature/address-keyby-impl' into 'main' feature: develop job using java See merge request galaxy/tsg_olap/sip-rtp-correlation!3	2023-08-10 09:39:51 +00:00
chaoc	7e5a524eb7	style: modify project name	2023-08-10 17:39:22 +08:00
chaoc	255d6d9fcb	perf: change the timing of timer register	2023-08-10 15:33:20 +08:00
chaoc	4c90c27921	style: delete unused code	2023-08-10 15:32:23 +08:00
chaoc	f4b8ba69d0	fix: error ttl conf	2023-08-10 15:31:45 +08:00
chaoc	0f6fdda7f5	pref: adjust the timer interval	2023-08-10 15:30:30 +08:00
chaoc	44eb3ed402	style: add influxdb report conf	2023-08-10 15:29:53 +08:00
chaoc	ebada97c22	test: add do nothing sink	2023-08-10 15:29:19 +08:00
chaoc	7221f2a52f	feat: impl using the Address as the keyBy parameter	2023-08-09 16:38:34 +08:00
chaoc	6a444d38ba	style: add conf example file	2023-08-09 16:28:27 +08:00
chaoc	7d0d185c0e	refactor: extract keyedFunction to simple class	2023-08-09 16:27:56 +08:00
chaoc	c9c26f0a9c	refactor: extract keyedFunction to simple class	2023-08-09 16:27:46 +08:00
chaoc	b20c33e2bd	chore: add plugins	2023-08-09 16:26:21 +08:00
chaoc	c10b8930e3	style(performance): organize performance testing code	2023-08-09 15:58:06 +08:00
chaoc	21ef68da95	test: add conf props	2023-08-07 17:15:46 +08:00
chaoc	33b9d61711	test(performance): add test case	2023-08-07 17:15:27 +08:00
chaoc	43dbc50a19	fix: fix some errors	2023-08-07 17:13:23 +08:00
chaoc	5bc835ec3f	test(utils): add RTP data generator	2023-08-04 16:10:38 +08:00
chaoc	673d077e32	test(utils): optimize data generator	2023-08-04 16:10:24 +08:00
chaoc	b2af6cdad8	perf(error): optimize cond	2023-08-03 17:48:35 +08:00
chaoc	bfd28178b0	perf(error): add cond	2023-08-03 17:29:47 +08:00
chaoc	cefc581964	test(functions): add test for SIPPairingFunction	2023-08-03 17:21:38 +08:00
chaoc	c1404584c0	test(functions): add test for Address	2023-08-03 17:21:15 +08:00
chaoc	ef851cb187	test(records): add test for Record	2023-08-03 17:20:54 +08:00
chaoc	402db73b53	test(conf): add test for FusionConfiguration	2023-08-03 17:20:31 +08:00
chaoc	cbc7c91abe	test(utils): add test data generator	2023-08-03 17:18:00 +08:00
chaoc	14d569edfd	feat(error): add handler which process exception records	2023-08-03 17:17:24 +08:00
chaoc	4d3b53cbb7	fix: collect expire rtp data record	2023-08-03 17:16:09 +08:00
chaoc	112708f056	fix: fix time type error	2023-08-03 17:15:38 +08:00
chaoc	b40469ea8d	pref: modify param type	2023-08-03 16:11:10 +08:00
chaoc	b7cc87b4bc	feat(app): job main	2023-08-03 16:04:13 +08:00
chaoc	9ed0da345b	feat(format): add json serializer	2023-08-03 16:03:54 +08:00
chaoc	559c7b287c	fix(record): update field type	2023-08-03 16:03:30 +08:00
chaoc	bcd6826c56	perf(record): update return values	2023-08-03 16:03:09 +08:00
chaoc	7296c36d80	feat(functions): add function that fusion SIP data and RTP data to VoIP	2023-08-03 16:02:21 +08:00
chaoc	a8a6519a88	feat(functions): add function that splits record based on field 'schema_type'	2023-08-03 16:01:49 +08:00
chaoc	7d2b0bae29	pref(functions): format code	2023-08-03 16:00:39 +08:00
chaoc	098a196cc0	pref(record): add field setter	2023-08-03 15:59:26 +08:00
chaoc	cfb56877c3	feat(conf): add Enhanced-Configuration utils	2023-08-03 15:58:42 +08:00
chaoc	d4bc2787d4	chore: add test deps and some plugins	2023-08-03 15:57:20 +08:00
chaoc	53eca34191	feat(functions): impl keyedProcessFunction that pairs SIP one-way direction to double direction	2023-08-03 09:56:19 +08:00
chaoc	a949a98a37	feat(functions): add function helper	2023-08-03 09:54:23 +08:00
chaoc	fe274d4da6	feat(functions): add some function pojo types	2023-08-03 09:53:41 +08:00
chaoc	6d90d720fd	feat(conf): add some configuration options	2023-08-03 09:52:11 +08:00
chaoc	43f10e38e7	chore: add lombok	2023-08-03 09:51:47 +08:00
chaoc	f52376d63d	feat(record): add some enum types	2023-08-03 09:44:56 +08:00
chaoc	1046784f3e	feat(record): add json data parser utils	2023-08-03 09:39:39 +08:00
chaoc	3ff568c823	chore: init maven frame	2023-08-02 17:05:56 +08:00
chaoc	906b6e6ca4	chore: add git ignore file	2023-08-02 17:04:01 +08:00
chaoc	8d5d1d9523	docs: update readme	2023-08-02 17:02:54 +08:00
				`@@ -0,0 +1 @@`
				`com.geedgenetworks.flink.easy.application.voip.VoipUDFFactory`