diff --git a/.github/workflows/e2e.yaml b/.github/workflows/e2e.yaml
new file mode 100644
index 0000000..9c07faa
--- /dev/null
+++ b/.github/workflows/e2e.yaml
@@ -0,0 +1,47 @@
+# 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.
+
+name: E2E
+
+on:
+  pull_request:
+  push:
+    branches: 
+      - master
+    tags:
+      - 'v*'
+
+jobs:
+  agent:
+    runs-on: ubuntu-18.04
+    timeout-minutes: 180
+    strategy:
+      fail-fast: true
+    steps:
+      - uses: actions/checkout@v1
+        with:
+          submodules: true
+      - uses: actions/setup-java@v1
+        with:
+          java-version: 8
+      - uses: aahmed-se/setup-maven@v3
+        with:
+          maven-version: 3.6.1
+      - name: Set environment
+        run: export MAVEN_OPTS='-Dmaven.repo.local=~/.m2/repository -XX:+TieredCompilation -XX:TieredStopAtLevel=1 -XX:+CMSClassUnloadingEnabled -XX:+UseConcMarkSweepGC -XX:-UseGCOverheadLimit -Xmx3g'
+      - name: Compile & Install Test Codes
+        run: |
+          mvn -f ./test/e2e/validator/pom.xml clean verify
diff --git a/test/e2e/validator/docker/conf.d/nginx.conf b/test/e2e/validator/docker/conf.d/nginx.conf
new file mode 100644
index 0000000..da2e81b
--- /dev/null
+++ b/test/e2e/validator/docker/conf.d/nginx.conf
@@ -0,0 +1,158 @@
+# 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.
+
+# This nginx.conf is designed and written for local dev environments
+# It will use the blocking startup mode and console logging
+worker_processes  1;
+daemon off;
+error_log /dev/stdout error;
+
+events {
+    worker_connections 1024;
+}
+http {
+    lua_package_path "/skywalking-nginx-lua/lib/skywalking/?.lua;;";
+    # Buffer represents the register inform and the queue of the finished segment
+    lua_shared_dict tracing_buffer 100m;
+
+    # Init is the timer setter and keeper
+    # Setup an infinite loop timer to do register and trace report.
+    init_worker_by_lua_block {
+        local metadata_buffer = ngx.shared.tracing_buffer
+
+        metadata_buffer:set('serviceName', 'User_Service_Name')
+        -- Instance means the number of Nginx deloyment, does not mean the worker instances
+        metadata_buffer:set('serviceInstanceName', 'User_Service_Instance_Name')
+
+        require("client"):startBackendTimer("http://127.0.0.1:8080")
+    }
+    log_format sw_trace escape=json "$uri $request_body";
+
+    server {
+        listen 8080;
+
+        # This is for local dev only, please do not add this in any production env.
+        lua_code_cache off;
+
+        location /ingress {
+            default_type text/html;
+
+            rewrite_by_lua_block {
+                require("tracer"):startBackendTimer()
+            }
+
+            proxy_pass http://127.0.0.1:8080/tier2/lb;
+
+            body_filter_by_lua_block {
+                require("tracer"):finish()
+            }
+
+            log_by_lua_block {
+                require("tracer"):prepareForReport()
+            }
+        }
+
+        location /tier2/lb {
+            default_type text/html;
+
+            rewrite_by_lua_block {
+                require("tracer"):startBackendTimer()
+            }
+
+            proxy_pass http://127.0.0.1:8080/backend;
+
+            body_filter_by_lua_block {
+                require("tracer"):finish()
+            }
+
+            log_by_lua_block {
+                require("tracer"):prepareForReport()
+            }
+        }
+
+        # ------------------------------------------------------
+        # -- Mock backend business service as the upsteeam
+        # ------------------------------------------------------
+        location /backend {
+            default_type text/html;
+            content_by_lua_block {
+                ngx.say("<p>Backend service for testing only.</p>")
+                ngx.say("<p>Backend sw6 received headers: " .. ngx.req.get_headers()["sw6"] .. "</p>")
+            }
+        }
+
+
+        # ------------------------------------------------------
+        # -- Mock OAP server to provide register and trace collection
+        # ------------------------------------------------------
+        location /v2/service/register {
+            default_type text/html;
+            lua_need_request_body on;
+            access_log /var/log/nginx/trace.log sw_trace;
+
+            content_by_lua_block {
+                local cjson = require('cjson')
+
+                ngx.log(ngx.DEBUG, 'Service register request = ', ngx.req.get_body_data())
+                local param = cjson.decode(ngx.req.get_body_data())
+
+                local registeredInfo = {}
+                registeredInfo[1] = {key=param.services[1].serviceName, value=1}
+                ngx.say(cjson.encode(registeredInfo))
+            }
+        }
+
+        location /v2/instance/register {
+            default_type text/html;
+	        access_log /var/log/nginx/trace.log sw_trace;
+            lua_need_request_body on;
+
+            content_by_lua_block {
+                local cjson = require('cjson')
+                ngx.log(ngx.DEBUG, 'Service instance register request = ', ngx.req.get_body_data())
+                local param = cjson.decode(ngx.req.get_body_data())
+
+                local registeredInfo = {}
+
+                registeredInfo[1] = {key=param.instances[1].instanceUUID, value=1}
+                ngx.say(cjson.encode(registeredInfo))
+            }
+        }
+
+        location /v2/instance/heartbeat {
+            default_type text/html;
+            lua_need_request_body on;
+            access_log /var/log/nginx/trace.log sw_trace;
+
+            content_by_lua_block {
+                local cjson = require('cjson')
+                --ngx.log(ngx.DEBUG, 'Service instance ping request = ', ngx.req.get_body_data())
+            }
+        }
+
+        location /v2/segments {
+            default_type text/html;
+            lua_need_request_body on;
+            access_log /var/log/nginx/trace.log sw_trace;
+
+            content_by_lua_block {
+                local cjson = require('cjson')
+                ngx.log(ngx.DEBUG, 'Received segment = ', ngx.req.get_body_data())
+            }
+        }
+    }
+}
\ No newline at end of file
diff --git a/test/e2e/validator/pom.xml b/test/e2e/validator/pom.xml
new file mode 100644
index 0000000..868b886
--- /dev/null
+++ b/test/e2e/validator/pom.xml
@@ -0,0 +1,268 @@
+<?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 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.
+  ~
+  -->
+<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>org.apache.skywalking.plugin</groupId>
+    <artifactId>validator</artifactId>
+    <version>0.0.1</version>
+    <packaging>jar</packaging>
+
+    <name>skywalking-validator-tools</name>
+    <url>http://maven.apache.org</url>
+
+    <properties>
+        <java.version>1.8</java.version>
+
+        <junit.version>4.11</junit.version>
+        <gson.version>2.8.5</gson.version>
+        <slf4j.version>1.7.25</slf4j.version>
+        <log4j.version>2.9.0</log4j.version>
+        <guava.version>28.1-jre</guava.version>
+        <snakeyaml.version>1.18</snakeyaml.version>
+        <gson.version>2.8.6</gson.version>
+        <lombok.version>1.18.10</lombok.version>
+
+        <maven.compiler.source>${java.version}</maven.compiler.source>
+        <maven.compiler.target>${java.version}</maven.compiler.target>
+
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+
+        <maven-compiler-plugin.version>3.8.0</maven-compiler-plugin.version>
+        <docker-maven-plugin.version>0.4.13</docker-maven-plugin.version>
+
+        <maven-failsafe-plugin.version>3.0.0-M4</maven-failsafe-plugin.version>
+        <maven-compiler-plugin.version>3.8.0</maven-compiler-plugin.version>
+        <docker-maven-plugin.version>0.30.0</docker-maven-plugin.version>
+        <surefire.version>3.0.0-M4</surefire.version>
+
+        <skipSurefire>false</skipSurefire>
+    </properties>
+
+    <dependencies>
+        <dependency>
+            <groupId>junit</groupId>
+            <artifactId>junit</artifactId>
+            <version>${junit.version}</version>
+        </dependency>
+
+        <dependency>
+            <groupId>com.google.guava</groupId>
+            <artifactId>guava</artifactId>
+            <version>${guava.version}</version>
+        </dependency>
+
+        <dependency>
+            <groupId>org.yaml</groupId>
+            <artifactId>snakeyaml</artifactId>
+            <version>${snakeyaml.version}</version>
+        </dependency>
+
+        <dependency>
+            <groupId>com.google.code.gson</groupId>
+            <artifactId>gson</artifactId>
+            <version>${gson.version}</version>
+        </dependency>
+
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+            <version>${lombok.version}</version>
+            <scope>provided</scope>
+        </dependency>
+
+        <dependency>
+            <groupId>org.freemarker</groupId>
+            <artifactId>freemarker</artifactId>
+            <version>2.3.23</version>
+        </dependency>
+
+        <dependency>
+            <groupId>org.slf4j</groupId>
+            <artifactId>slf4j-api</artifactId>
+            <version>${slf4j.version}</version>
+        </dependency>
+
+        <dependency>
+            <groupId>org.slf4j</groupId>
+            <artifactId>log4j-over-slf4j</artifactId>
+            <version>${slf4j.version}</version>
+        </dependency>
+
+        <dependency>
+            <groupId>org.apache.logging.log4j</groupId>
+            <artifactId>log4j-core</artifactId>
+            <version>${log4j.version}</version>
+        </dependency>
+
+        <dependency>
+            <groupId>org.apache.logging.log4j</groupId>
+            <artifactId>log4j-slf4j-impl</artifactId>
+            <version>${log4j.version}</version>
+            <exclusions>
+                <exclusion>
+                    <groupId>org.apache.logging.log4j</groupId>
+                    <artifactId>log4j-core</artifactId>
+                </exclusion>
+            </exclusions>
+        </dependency>
+    </dependencies>
+
+    <build>
+        <finalName>skywalking-validator-tools</finalName>
+        <pluginManagement>
+            <plugins>
+                <plugin>
+                    <groupId>org.apache.maven.plugins</groupId>
+                    <artifactId>maven-failsafe-plugin</artifactId>
+                    <version>${maven-failsafe-plugin.version}</version>
+                    <dependencies>
+                        <dependency>
+                            <groupId>org.apache.maven.surefire</groupId>
+                            <artifactId>surefire-junit4</artifactId>
+                            <version>${maven-failsafe-plugin.version}</version>
+                        </dependency>
+                    </dependencies>
+                    <executions>
+                        <execution>
+                            <id>integration-test</id>
+                            <goals>
+                                <goal>integration-test</goal>
+                                <goal>verify</goal>
+                            </goals>
+                            <configuration>
+                                <excludes>
+                                    <exclude>none</exclude>
+                                </excludes>
+                                <includes>
+                                    <include>**/*IT.java</include>
+                                </includes>
+                            </configuration>
+                        </execution>
+                    </executions>
+                </plugin>
+                <plugin>
+                    <groupId>io.fabric8</groupId>
+                    <artifactId>docker-maven-plugin</artifactId>
+                    <version>${docker-maven-plugin.version}</version>
+                    <configuration>
+                        <sourceMode>all</sourceMode>
+                        <showLogs>true</showLogs>
+                        <logDate>default</logDate>
+                        <imagePullPolicy>IfNotPresent</imagePullPolicy>
+                    </configuration>
+                    <executions>
+                        <execution>
+                            <id>start</id>
+                            <phase>pre-integration-test</phase>
+                            <goals>
+                                <goal>start</goal>
+                            </goals>
+                        </execution>
+                        <execution>
+                            <id>stop</id>
+                            <phase>post-integration-test</phase>
+                            <goals>
+                                <goal>stop</goal>
+                            </goals>
+                        </execution>
+                    </executions>
+                </plugin>
+            </plugins>
+        </pluginManagement>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <version>${maven-compiler-plugin.version}</version>
+                <configuration>
+                    <source>${java.version}</source>
+                    <target>${java.version}</target>
+                    <encoding>${project.build.sourceEncoding}</encoding>
+                </configuration>
+            </plugin>
+
+            <plugin>
+                <groupId>io.fabric8</groupId>
+                <artifactId>docker-maven-plugin</artifactId>
+                <configuration>
+                    <containerNamePattern>%a-%t-%i</containerNamePattern>
+                    <images>
+                        <image>
+                            <name>openresty/openresty</name>
+                            <alias>openresty-with-skywalking</alias>
+                            <run>
+                                <ports>
+                                    <port>+nginx.host:nginx.port:8080</port>
+                                </ports>
+                                <volumes>
+                                    <bind>
+                                        <volume>${project.build.testOutputDirectory}/logs:/var/log/nginx</volume>
+                                        <volume>${project.basedir}/docker/conf.d:/var/nginx/conf.d</volume>
+                                        <volume>
+                                            ${project.basedir}/../../../lib/skywalking:/skywalking-nginx-lua/lib/skywalking
+                                        </volume>
+                                    </bind>
+                                </volumes>
+                                <wait>
+                                    <http>
+                                        <url>
+                                            http://${docker.host.address}:${nginx.port}
+                                        </url>
+                                    </http>
+                                    <time>30000</time>
+                                </wait>
+                                <cmd>/usr/bin/openresty -c /var/nginx/conf.d/nginx.conf</cmd>
+                            </run>
+                        </image>
+                    </images>
+                </configuration>
+            </plugin>
+
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-surefire-plugin</artifactId>
+                <version>${surefire.version}</version>
+                <configuration>
+                    <skip>${skipSurefire}</skip>
+                </configuration>
+            </plugin>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-failsafe-plugin</artifactId>
+                <version>${maven-failsafe-plugin.version}</version>
+                <configuration>
+                    <systemPropertyVariables>
+                        <ping.url>
+                            http://${nginx.host}:${nginx.port}/ingress
+                        </ping.url>
+                    </systemPropertyVariables>
+                </configuration>
+                <executions>
+                    <execution>
+                        <goals>
+                            <goal>verify</goal>
+                        </goals>
+                    </execution>
+                </executions>
+            </plugin>
+        </plugins>
+    </build>
+</project>
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/ApplicationAssert.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/ApplicationAssert.java
new file mode 100644
index 0000000..c59bd6c
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/ApplicationAssert.java
@@ -0,0 +1,53 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.assertor;
+
+import java.util.List;
+import org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception.RegistryApplicationNotFoundException;
+import org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception.RegistryApplicationSizeNotEqualsException;
+import org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception.ValueAssertFailedException;
+import org.apache.skywalking.plugin.test.agent.tool.validator.entity.RegistryApplication;
+
+public class ApplicationAssert {
+    public static void assertEquals(List<RegistryApplication> expected, List<RegistryApplication> actual) {
+
+        if (expected == null) {
+            return;
+        }
+
+        for (RegistryApplication application : expected) {
+            RegistryApplication actualApplication = getMatchApplication(actual, application);
+            try {
+                ExpressParser.parse(application.expressValue())
+                             .assertValue("registry application", actualApplication.expressValue());
+            } catch (ValueAssertFailedException e) {
+                throw new RegistryApplicationSizeNotEqualsException(application.applicationCode(), e);
+            }
+        }
+    }
+
+    private static RegistryApplication getMatchApplication(List<RegistryApplication> actual,
+        RegistryApplication application) {
+        for (RegistryApplication registryApplication : actual) {
+            if (registryApplication.applicationCode().equals(application.applicationCode())) {
+                return registryApplication;
+            }
+        }
+        throw new RegistryApplicationNotFoundException(application.applicationCode());
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/DataAssert.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/DataAssert.java
new file mode 100644
index 0000000..59a4124
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/DataAssert.java
@@ -0,0 +1,35 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.assertor;
+
+import com.google.gson.GsonBuilder;
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
+import org.apache.skywalking.plugin.test.agent.tool.validator.entity.Data;
+
+public class DataAssert {
+    private static Logger logger = LogManager.getLogger(DataAssert.class);
+
+    public static void assertEquals(Data excepted, Data actual) {
+        logger.info("excepted data:\n{}", new GsonBuilder().setPrettyPrinting().create().toJson(excepted));
+        logger.info("actual data:\n{}", new GsonBuilder().setPrettyPrinting().create().toJson(actual));
+        RegistryItemsAssert.assertEquals(excepted.registryItems(), actual.registryItems());
+        SegmentItemsAssert.assertEquals(excepted.segmentItems(), actual.segmentItems());
+        logger.info("{} assert successful.", "segment items");
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/ExpressParser.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/ExpressParser.java
new file mode 100644
index 0000000..84ff2d0
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/ExpressParser.java
@@ -0,0 +1,63 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.assertor;
+
+import org.apache.skywalking.plugin.test.agent.tool.validator.assertor.element.ElementAssertor;
+import org.apache.skywalking.plugin.test.agent.tool.validator.assertor.element.EqualsAssertor;
+import org.apache.skywalking.plugin.test.agent.tool.validator.assertor.element.GreatThanAssertor;
+import org.apache.skywalking.plugin.test.agent.tool.validator.assertor.element.GreetEqualAssertor;
+import org.apache.skywalking.plugin.test.agent.tool.validator.assertor.element.NoopAssertor;
+import org.apache.skywalking.plugin.test.agent.tool.validator.assertor.element.NotEqualsAssertor;
+import org.apache.skywalking.plugin.test.agent.tool.validator.assertor.element.NotNullAssertor;
+import org.apache.skywalking.plugin.test.agent.tool.validator.assertor.element.NullAssertor;
+
+public class ExpressParser {
+    public static ElementAssertor parse(String express) {
+        if (express == null) {
+            return new NoopAssertor();
+        }
+
+        String expressTrim = express.trim();
+        if (expressTrim.equals("not null")) {
+            return new NotNullAssertor();
+        }
+
+        if (expressTrim.equals("null")) {
+            return new NullAssertor();
+        }
+
+        String[] expressSegment = expressTrim.split(" ");
+        if (expressSegment.length == 1) {
+            return new EqualsAssertor(expressSegment[0]);
+        } else if (expressSegment.length == 2) {
+            String exceptedValue = expressSegment[1];
+            switch (expressSegment[0].trim()) {
+                case "nq":
+                    return new NotEqualsAssertor(exceptedValue);
+                case "eq":
+                    return new EqualsAssertor(exceptedValue);
+                case "gt":
+                    return new GreatThanAssertor(exceptedValue);
+                case "ge":
+                    return new GreetEqualAssertor(exceptedValue);
+            }
+        }
+
+        return new EqualsAssertor(express);
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/InstanceAssert.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/InstanceAssert.java
new file mode 100644
index 0000000..c4af5e6
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/InstanceAssert.java
@@ -0,0 +1,53 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.assertor;
+
+import java.util.List;
+import org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception.RegistryInstanceOfApplicationNotFoundException;
+import org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception.RegistryInstanceSizeNotEqualsException;
+import org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception.ValueAssertFailedException;
+import org.apache.skywalking.plugin.test.agent.tool.validator.entity.RegistryInstance;
+
+public class InstanceAssert {
+    public static void assertEquals(List<RegistryInstance> expected, List<RegistryInstance> actual) {
+
+        if (expected == null) {
+            return;
+        }
+
+        for (RegistryInstance instance : expected) {
+            RegistryInstance actualInstance = getMatchApplication(actual, instance);
+            try {
+                ExpressParser.parse(actualInstance.expressValue())
+                             .assertValue(String.format("The registry instance of %s", instance.applicationCode()), actualInstance
+                                 .expressValue());
+            } catch (ValueAssertFailedException e) {
+                throw new RegistryInstanceSizeNotEqualsException(instance.applicationCode(), e);
+            }
+        }
+    }
+
+    private static RegistryInstance getMatchApplication(List<RegistryInstance> actual, RegistryInstance application) {
+        for (RegistryInstance registryApplication : actual) {
+            if (registryApplication.applicationCode().equals(application.applicationCode())) {
+                return registryApplication;
+            }
+        }
+        throw new RegistryInstanceOfApplicationNotFoundException(application.applicationCode());
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/OperationNameAssert.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/OperationNameAssert.java
new file mode 100644
index 0000000..91974cb
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/OperationNameAssert.java
@@ -0,0 +1,62 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.assertor;
+
+import java.util.List;
+import org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception.ActualRegistryOperationNameEmptyException;
+import org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception.RegistryOperationNameNotFoundException;
+import org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception.RegistryOperationNamesOfApplicationNotFoundException;
+import org.apache.skywalking.plugin.test.agent.tool.validator.entity.RegistryOperationName;
+
+public class OperationNameAssert {
+    public static void assertEquals(List<RegistryOperationName> expected, List<RegistryOperationName> actual) {
+        if (expected == null) {
+            return;
+        }
+
+        for (RegistryOperationName operationName : expected) {
+            RegistryOperationName actualOperationName = findActualRegistryOperationName(actual, operationName);
+            assertOperationEquals(actualOperationName.serviceName(), operationName.operationName(), actualOperationName
+                .operationName());
+        }
+    }
+
+    private static void assertOperationEquals(String applicationCode, List<String> expectedOperationName,
+        List<String> actualOperationName) {
+        for (String operationName : expectedOperationName) {
+            if (!actualOperationName.contains(operationName)) {
+                throw new RegistryOperationNameNotFoundException(applicationCode, operationName);
+            }
+        }
+    }
+
+    private static RegistryOperationName findActualRegistryOperationName(List<RegistryOperationName> actual,
+        RegistryOperationName registryOperationName) {
+        if (actual == null) {
+            throw new ActualRegistryOperationNameEmptyException(registryOperationName);
+        }
+
+        for (RegistryOperationName operationName : actual) {
+            if (operationName.serviceName().equals(registryOperationName.serviceName())) {
+                return operationName;
+            }
+        }
+
+        throw new RegistryOperationNamesOfApplicationNotFoundException(registryOperationName);
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/ParentSegmentIdExpressParser.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/ParentSegmentIdExpressParser.java
new file mode 100644
index 0000000..0284e95
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/ParentSegmentIdExpressParser.java
@@ -0,0 +1,47 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.assertor;
+
+import java.util.List;
+import org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception.ParentSegmentNotFoundException;
+import org.apache.skywalking.plugin.test.agent.tool.validator.entity.SegmentItem;
+
+public class ParentSegmentIdExpressParser {
+    public static String parse(String express, List<SegmentItem> actual) {
+        if (!express.trim().startsWith("${") && !express.trim().endsWith("}")) {
+            return express;
+        }
+
+        String parentSegmentExpress = express.trim().substring(2, express.trim().length() - 1);
+
+        int startIndexOfIndex = parentSegmentExpress.indexOf("[");
+        String applicationCode = parentSegmentExpress.substring(0, startIndexOfIndex);
+        int endIndexOfIndex = parentSegmentExpress.indexOf("]", startIndexOfIndex);
+        int expectedSize = Integer.parseInt(parentSegmentExpress.substring(startIndexOfIndex + 1, endIndexOfIndex));
+        for (SegmentItem segmentItem : actual) {
+            if (segmentItem.serviceName().equals(applicationCode)) {
+                if (segmentItem.segments().size() <= expectedSize) {
+                    throw new ParentSegmentNotFoundException(parentSegmentExpress);
+                }
+
+                return segmentItem.segments().get(expectedSize).segmentId();
+            }
+        }
+        return express;
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/RegistryItemsAssert.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/RegistryItemsAssert.java
new file mode 100644
index 0000000..5c5e791
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/RegistryItemsAssert.java
@@ -0,0 +1,35 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.assertor;
+
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
+import org.apache.skywalking.plugin.test.agent.tool.validator.entity.RegistryItems;
+
+public class RegistryItemsAssert {
+    private static Logger logger = LogManager.getLogger(RegistryItemsAssert.class);
+
+    public static void assertEquals(RegistryItems excepted, RegistryItems actual) {
+        ApplicationAssert.assertEquals(excepted.applications(), actual.applications());
+        logger.info("{} assert successful.", "registry applications");
+        InstanceAssert.assertEquals(excepted.instances(), actual.instances());
+        logger.info("{} assert successful.", "registry instances");
+        OperationNameAssert.assertEquals(excepted.operationNames(), actual.operationNames());
+        logger.info("{} assert successful.", "registry operation name");
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/SegmentAssert.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/SegmentAssert.java
new file mode 100644
index 0000000..1c50b58
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/SegmentAssert.java
@@ -0,0 +1,224 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.assertor;
+
+import java.util.ArrayList;
+import java.util.List;
+import org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception.ActualSegmentRefIsEmptyException;
+import org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception.KeyValueNotEqualsException;
+import org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception.LogEventKeyNotEqualsException;
+import org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception.LogEventSizeNotEqualsException;
+import org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception.LogEventValueNotEqualsException;
+import org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception.LogSizeNotEqualsException;
+import org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception.RefSizeNotEqualsException;
+import org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception.SegmentNotFoundException;
+import org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception.SegmentRefAssertFailedException;
+import org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception.SegmentRefNotFoundException;
+import org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception.SpanAssertFailedException;
+import org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception.SpanSizeNotEqualsException;
+import org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception.TagKeyNotEqualsException;
+import org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception.TagSizeNotEqualsException;
+import org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception.TagValueNotEqualsException;
+import org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception.ValueAssertFailedException;
+import org.apache.skywalking.plugin.test.agent.tool.validator.entity.KeyValuePair;
+import org.apache.skywalking.plugin.test.agent.tool.validator.entity.LogEvent;
+import org.apache.skywalking.plugin.test.agent.tool.validator.entity.Segment;
+import org.apache.skywalking.plugin.test.agent.tool.validator.entity.SegmentItem;
+import org.apache.skywalking.plugin.test.agent.tool.validator.entity.SegmentRef;
+import org.apache.skywalking.plugin.test.agent.tool.validator.entity.Span;
+import org.apache.skywalking.plugin.test.agent.tool.validator.exception.AssertFailedException;
+
+public class SegmentAssert {
+    public static void assertEquals(SegmentItem expected, SegmentItem actual) {
+        if (expected.segments() == null) {
+            return;
+        }
+
+        for (Segment segment : expected.segments()) {
+            Segment actualSegment = findSegment(actual, segment);
+            segment.setSegmentId(actualSegment.segmentId());
+        }
+    }
+
+    private static Segment findSegment(SegmentItem actual, Segment expectedSegment) {
+        List<SegmentPredictionFailedCause> exceptions = new ArrayList<>();
+        for (Segment actualSegment : actual.segments()) {
+            try {
+                if (spansEquals(expectedSegment.spans(), actualSegment.spans())) {
+                    return actualSegment;
+                }
+            } catch (SpanSizeNotEqualsException e) {
+            } catch (SpanAssertFailedException e) {
+                exceptions.add(new SegmentPredictionFailedCause(e, actualSegment));
+            }
+        }
+
+        throw new SegmentNotFoundException(expectedSegment, exceptions);
+    }
+
+    private static boolean spansEquals(List<Span> excepted, List<Span> actual) {
+        if (excepted == null) {
+            return true;
+        }
+
+        if (actual == null || excepted.size() != actual.size()) {
+            throw new SpanSizeNotEqualsException(excepted.size(), (actual != null) ? actual.size() : 0);
+        }
+
+        int equalSpans = 0;
+        for (int index = 0; index < excepted.size(); index++, equalSpans++) {
+            Span exceptedSpan = excepted.get(index);
+            Span actualSpan = actual.get(index);
+            try {
+                spanEquals(exceptedSpan, actualSpan);
+            } catch (AssertFailedException e) {
+                throw new SpanAssertFailedException(e, exceptedSpan, actualSpan);
+            }
+        }
+
+        return true;
+    }
+
+    private static void spanEquals(Span excepted, Span actualSpan) {
+        ExpressParser.parse(excepted.operationName()).assertValue("operation name", actualSpan.operationName());
+        ExpressParser.parse(excepted.componentId()).assertValue("component id", actualSpan.componentId());
+        ExpressParser.parse(excepted.componentName()).assertValue("component name", actualSpan.componentName());
+        ExpressParser.parse(excepted.startTime()).assertValue("start time", actualSpan.startTime());
+        ExpressParser.parse(excepted.endTime()).assertValue("end time", actualSpan.endTime());
+        ExpressParser.parse(excepted.parentSpanId()).assertValue("parent span id", actualSpan.parentSpanId());
+        ExpressParser.parse(excepted.spanId()).assertValue("span id", actualSpan.spanId());
+        ExpressParser.parse(excepted.operationId()).assertValue("operation id", actualSpan.operationId());
+        ExpressParser.parse(excepted.peer()).assertValue("peer", actualSpan.peer());
+        ExpressParser.parse(excepted.spanLayer()).assertValue("span layer", actualSpan.spanLayer());
+        ExpressParser.parse(excepted.peerId()).assertValue("peer id", actualSpan.peerId());
+        ExpressParser.parse(excepted.error()).assertValue("is error", actualSpan.error());
+        ExpressParser.parse(excepted.spanType()).assertValue("span type", actualSpan.spanType());
+        tagsEquals(excepted.tags(), actualSpan.tags());
+        logsEquals(excepted.logs(), actualSpan.logs());
+        refEquals(excepted.refs(), actualSpan.refs());
+        excepted.setActualRefs(actualSpan.refs());
+
+    }
+
+    private static void refEquals(List<SegmentRef> excepted, List<SegmentRef> actual) {
+        if (excepted == null) {
+            return;
+        }
+
+        if (actual == null) {
+            throw new ActualSegmentRefIsEmptyException(excepted.size());
+        }
+
+        if (excepted.size() != actual.size()) {
+            throw new RefSizeNotEqualsException(excepted.size(), actual.size());
+        }
+
+        for (SegmentRef ref : excepted) {
+            findSegmentRef(actual, ref);
+        }
+    }
+
+    private static void tagsEquals(List<KeyValuePair> excepted, List<KeyValuePair> actual) {
+        if (excepted.size() != actual.size()) {
+            throw new TagSizeNotEqualsException(excepted.size(), actual.size());
+        }
+
+        for (int index = 0; index < excepted.size(); index++) {
+            tagEquals(excepted.get(index), actual.get(index));
+        }
+    }
+
+    private static void logsEquals(List<LogEvent> excepted, List<LogEvent> actual) {
+        if (excepted.size() != actual.size()) {
+            throw new LogSizeNotEqualsException(excepted.size(), actual.size());
+        }
+
+        for (int index = 0; index < excepted.size(); index++) {
+            logEventEquals(excepted.get(index), actual.get(index));
+        }
+
+    }
+
+    private static void logEventEquals(LogEvent exceptedEvent, LogEvent actualEvent) {
+        List<KeyValuePair> exceptedKey = exceptedEvent.events();
+        List<KeyValuePair> actualKey = actualEvent.events();
+
+        if (exceptedKey.size() != actualKey.size()) {
+            throw new LogEventSizeNotEqualsException(exceptedKey.size(), actualKey.size());
+        }
+
+        for (int index = 0; index < exceptedKey.size(); index++) {
+            logEventPairEquals(exceptedKey.get(index), actualKey.get(index));
+        }
+    }
+
+    private static void keyValuePairEquals(KeyValuePair excepted, KeyValuePair actual) {
+        if (!excepted.key().equals(actual.key())) {
+            throw new KeyValueNotEqualsException();
+        }
+
+        ExpressParser.parse(excepted.value()).assertValue("", actual.value());
+    }
+
+    private static void logEventPairEquals(KeyValuePair excepted, KeyValuePair actual) {
+        try {
+            keyValuePairEquals(excepted, actual);
+        } catch (KeyValueNotEqualsException e) {
+            throw new LogEventKeyNotEqualsException(excepted.key(), actual.key());
+        } catch (ValueAssertFailedException e) {
+            throw new LogEventValueNotEqualsException(excepted.key(), excepted.value(), actual.value());
+        }
+    }
+
+    private static void tagEquals(KeyValuePair excepted, KeyValuePair actual) {
+        try {
+            keyValuePairEquals(excepted, actual);
+        } catch (KeyValueNotEqualsException e) {
+            throw new TagKeyNotEqualsException(excepted.key(), actual.key());
+        } catch (ValueAssertFailedException e) {
+            throw new TagValueNotEqualsException(excepted.key(), excepted.value(), actual.value());
+        }
+    }
+
+    private static SegmentRef findSegmentRef(List<SegmentRef> actual, SegmentRef expected) {
+        List<SegmentRefAssertFailedCause> causes = new ArrayList<>();
+        for (SegmentRef segmentRef : actual) {
+            try {
+                if (simpleSegmentRefEquals(expected, segmentRef)) {
+                    return segmentRef;
+                }
+            } catch (SegmentRefAssertFailedException e) {
+                causes.add(new SegmentRefAssertFailedCause(e, segmentRef));
+            }
+        }
+        throw new SegmentRefNotFoundException(expected, causes);
+    }
+
+    private static boolean simpleSegmentRefEquals(SegmentRef expected, SegmentRef actual) {
+        try {
+            ExpressParser.parse(expected.entryEndpointName())
+                         .assertValue("entry service name", actual.entryEndpointName());
+            ExpressParser.parse(expected.parentEndpointName())
+                         .assertValue("parent service name", actual.parentEndpointName());
+            ExpressParser.parse(expected.refType()).assertValue("ref type", actual.refType());
+            return true;
+        } catch (ValueAssertFailedException e) {
+            throw new SegmentRefAssertFailedException(e, expected, actual);
+        }
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/SegmentItemsAssert.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/SegmentItemsAssert.java
new file mode 100644
index 0000000..e834ff6
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/SegmentItemsAssert.java
@@ -0,0 +1,102 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.assertor;
+
+import java.util.List;
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
+import org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception.ActualSegmentItemEmptyException;
+import org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception.SegmentItemNotFoundException;
+import org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception.SegmentSizeNotEqualsException;
+import org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception.ValueAssertFailedException;
+import org.apache.skywalking.plugin.test.agent.tool.validator.entity.Segment;
+import org.apache.skywalking.plugin.test.agent.tool.validator.entity.SegmentItem;
+import org.apache.skywalking.plugin.test.agent.tool.validator.entity.SegmentRef;
+import org.apache.skywalking.plugin.test.agent.tool.validator.entity.Span;
+
+public class SegmentItemsAssert {
+    private static Logger logger = LogManager.getLogger(SegmentItemsAssert.class);
+
+    public static void assertEquals(List<SegmentItem> expected, List<SegmentItem> actual) {
+        if (expected == null) {
+            logger.info("ignore segment items. because expected segment item is null.");
+            return;
+        }
+
+        for (SegmentItem item : expected) {
+            SegmentItem actualSegmentItem = findSegmentItem(actual, item);
+            try {
+                assertSegmentSize(item.segmentSize(), actualSegmentItem.segmentSize());
+            } catch (ValueAssertFailedException e) {
+                throw new SegmentSizeNotEqualsException(item.serviceName(), item.segmentSize(), actualSegmentItem.segmentSize());
+            }
+            SegmentAssert.assertEquals(item, actualSegmentItem);
+        }
+
+        for (SegmentItem item : expected) {
+            if (item.segments() == null) {
+                continue;
+            }
+
+            for (Segment segment : item.segments()) {
+                convertParentSegmentId(segment, expected);
+
+                for (Span span : segment.spans()) {
+                    if (span.refs() == null || span.refs().size() == 0) {
+                        continue;
+                    }
+                    SegmentRefAssert.assertEquals(span.refs(), span.actualRefs());
+                }
+            }
+        }
+    }
+
+    private static void convertParentSegmentId(Segment segment, List<SegmentItem> actual) {
+        for (Span span : segment.spans()) {
+            if (span.refs() == null || span.refs().size() == 0) {
+                continue;
+            }
+
+            for (SegmentRef ref : span.refs()) {
+                String actualParentSegmentId = ParentSegmentIdExpressParser.parse(ref.parentTraceSegmentId(), actual);
+                ref.parentTraceSegmentId(actualParentSegmentId);
+            }
+        }
+    }
+
+    private static void assertSegmentSize(String expected, String actual) {
+        if (expected == null) {
+            return;
+        }
+        ExpressParser.parse(expected).assertValue("segment size", actual);
+    }
+
+    private static SegmentItem findSegmentItem(List<SegmentItem> actual, SegmentItem expected) {
+        if (actual == null) {
+            throw new ActualSegmentItemEmptyException(expected);
+        }
+
+        for (SegmentItem segmentItem : actual) {
+            if (expected.serviceName().equals(segmentItem.serviceName())) {
+                return segmentItem;
+            }
+        }
+
+        throw new SegmentItemNotFoundException(expected.serviceName());
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/SegmentPredictionFailedCause.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/SegmentPredictionFailedCause.java
new file mode 100644
index 0000000..9fa3efd
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/SegmentPredictionFailedCause.java
@@ -0,0 +1,39 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.assertor;
+
+import org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception.SpanAssertFailedException;
+import org.apache.skywalking.plugin.test.agent.tool.validator.entity.Segment;
+
+public class SegmentPredictionFailedCause {
+    private final Segment actualSegment;
+    private final SpanAssertFailedException spanAssertFailedCause;
+
+    public SegmentPredictionFailedCause(SpanAssertFailedException spanAssertFailedCause, Segment actualSegment) {
+        this.spanAssertFailedCause = spanAssertFailedCause;
+        this.actualSegment = actualSegment;
+    }
+
+    public Segment getActualSegment() {
+        return actualSegment;
+    }
+
+    public SpanAssertFailedException getSpanAssertFailedCause() {
+        return spanAssertFailedCause;
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/SegmentRefAssert.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/SegmentRefAssert.java
new file mode 100644
index 0000000..7e6b2d6
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/SegmentRefAssert.java
@@ -0,0 +1,83 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.assertor;
+
+import java.util.ArrayList;
+import java.util.List;
+import org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception.SegmentRefAssertFailedException;
+import org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception.SegmentRefNotFoundException;
+import org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception.SegmentRefSizeNotEqualsException;
+import org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception.ValueAssertFailedException;
+import org.apache.skywalking.plugin.test.agent.tool.validator.entity.SegmentRef;
+
+public class SegmentRefAssert {
+
+    public static void assertEquals(List<SegmentRef> excepted, List<SegmentRef> actual) {
+        if (excepted == null) {
+            return;
+        }
+
+        if (actual == null || excepted.size() != actual.size()) {
+            throw new SegmentRefSizeNotEqualsException(excepted.size(), actual.size());
+        }
+
+        for (SegmentRef ref : excepted) {
+            findSegmentRef(actual, ref);
+        }
+    }
+
+    private static SegmentRef findSegmentRef(List<SegmentRef> actual, SegmentRef expected) {
+        List<SegmentRefAssertFailedCause> causes = new ArrayList<>();
+        for (SegmentRef segmentRef : actual) {
+            try {
+                if (segmentRefEquals(expected, segmentRef)) {
+                    return segmentRef;
+                }
+            } catch (SegmentRefAssertFailedException e) {
+                causes.add(new SegmentRefAssertFailedCause(e, segmentRef));
+            }
+        }
+        throw new SegmentRefNotFoundException(expected, causes);
+    }
+
+    private static boolean segmentRefEquals(SegmentRef expected, SegmentRef actual) {
+        try {
+            ExpressParser.parse(expected.entryEndpointName())
+                         .assertValue("entry endpoint name", actual.entryEndpointName());
+            ExpressParser.parse(expected.networkAddress()).assertValue("network address", actual.networkAddress());
+            ExpressParser.parse(expected.parentTraceSegmentId())
+                         .assertValue("parent segment id", actual.parentTraceSegmentId());
+            ExpressParser.parse(expected.parentSpanId()).assertValue("span id", actual.parentSpanId());
+            ExpressParser.parse(expected.entryEndpointId()).assertValue("entry endpoint id", actual.entryEndpointId());
+            ExpressParser.parse(expected.networkAddressId())
+                         .assertValue("network address id", actual.networkAddressId());
+            ExpressParser.parse(expected.parentServiceInstanceId())
+                         .assertValue("parent application instance id", actual.parentServiceInstanceId());
+            ExpressParser.parse(expected.parentEndpointId())
+                         .assertValue("parent endpoint id", actual.parentEndpointId());
+            ExpressParser.parse(expected.parentEndpointName())
+                         .assertValue("parent endpoint name", actual.parentEndpointName());
+            ExpressParser.parse(expected.refType()).assertValue("ref type", actual.refType());
+            ExpressParser.parse(expected.entryServiceInstanceId())
+                         .assertValue("entry application instance id", actual.entryServiceInstanceId());
+            return true;
+        } catch (ValueAssertFailedException e) {
+            throw new SegmentRefAssertFailedException(e, expected, actual);
+        }
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/SegmentRefAssertFailedCause.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/SegmentRefAssertFailedCause.java
new file mode 100644
index 0000000..571a4c8
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/SegmentRefAssertFailedCause.java
@@ -0,0 +1,39 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.assertor;
+
+import org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception.SegmentRefAssertFailedException;
+import org.apache.skywalking.plugin.test.agent.tool.validator.entity.SegmentRef;
+
+public class SegmentRefAssertFailedCause {
+    private final SegmentRefAssertFailedException failedCause;
+    private final SegmentRef actual;
+
+    public SegmentRefAssertFailedCause(SegmentRefAssertFailedException failedCause, SegmentRef actual) {
+        this.failedCause = failedCause;
+        this.actual = actual;
+    }
+
+    public SegmentRefAssertFailedException getFailedCause() {
+        return failedCause;
+    }
+
+    public SegmentRef getActual() {
+        return actual;
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/element/ElementAssertor.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/element/ElementAssertor.java
new file mode 100644
index 0000000..452fe8f
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/element/ElementAssertor.java
@@ -0,0 +1,31 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.assertor.element;
+
+public abstract class ElementAssertor {
+
+    public ElementAssertor(String exceptedValue) {
+        if (exceptedValue != null) {
+            this.exceptedValue = exceptedValue.trim();
+        }
+    }
+
+    protected String exceptedValue;
+
+    public abstract void assertValue(String desc, String actualValue);
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/element/EqualsAssertor.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/element/EqualsAssertor.java
new file mode 100644
index 0000000..c7cd568
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/element/EqualsAssertor.java
@@ -0,0 +1,34 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.assertor.element;
+
+import org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception.ValueAssertFailedException;
+
+public class EqualsAssertor extends ElementAssertor {
+
+    public EqualsAssertor(String exceptedValue) {
+        super(exceptedValue);
+    }
+
+    @Override
+    public void assertValue(String desc, String actualValue) {
+        if (!exceptedValue.equals(actualValue)) {
+            throw new ValueAssertFailedException(desc, exceptedValue, actualValue);
+        }
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/element/GreatThanAssertor.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/element/GreatThanAssertor.java
new file mode 100644
index 0000000..ca2fecd
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/element/GreatThanAssertor.java
@@ -0,0 +1,34 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.assertor.element;
+
+import org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception.ValueAssertFailedException;
+
+public class GreatThanAssertor extends ElementAssertor {
+
+    public GreatThanAssertor(String exceptedValue) {
+        super(exceptedValue);
+    }
+
+    @Override
+    public void assertValue(String desc, String actualValue) {
+        if (Long.parseLong(actualValue) <= Long.parseLong(exceptedValue)) {
+            throw new ValueAssertFailedException(desc, " gt " + exceptedValue, actualValue);
+        }
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/element/GreetEqualAssertor.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/element/GreetEqualAssertor.java
new file mode 100644
index 0000000..8c97fd6
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/element/GreetEqualAssertor.java
@@ -0,0 +1,34 @@
+/*
+ * 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.
+ *
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.assertor.element;
+
+import org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception.ValueAssertFailedException;
+
+public class GreetEqualAssertor extends ElementAssertor {
+    public GreetEqualAssertor(String exceptedValue) {
+        super(exceptedValue);
+    }
+
+    @Override
+    public void assertValue(String desc, String actualValue) {
+        if (Long.parseLong(actualValue) < Long.parseLong(exceptedValue)) {
+            throw new ValueAssertFailedException(desc, " ge " + exceptedValue, actualValue);
+        }
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/element/NoopAssertor.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/element/NoopAssertor.java
new file mode 100644
index 0000000..bcec8f6
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/element/NoopAssertor.java
@@ -0,0 +1,29 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.assertor.element;
+
+public class NoopAssertor extends ElementAssertor {
+    public NoopAssertor() {
+        super(null);
+    }
+
+    @Override
+    public void assertValue(String desc, String actualValue) {
+
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/element/NotEqualsAssertor.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/element/NotEqualsAssertor.java
new file mode 100644
index 0000000..9f85d76
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/element/NotEqualsAssertor.java
@@ -0,0 +1,34 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.assertor.element;
+
+import org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception.ValueAssertFailedException;
+
+public class NotEqualsAssertor extends ElementAssertor {
+
+    public NotEqualsAssertor(String exceptedValue) {
+        super(exceptedValue);
+    }
+
+    @Override
+    public void assertValue(String desc, String actualValue) {
+        if (exceptedValue.equals(actualValue.trim())) {
+            throw new ValueAssertFailedException(desc, " not eq " + exceptedValue, actualValue);
+        }
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/element/NotNullAssertor.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/element/NotNullAssertor.java
new file mode 100644
index 0000000..dcc5f2d
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/element/NotNullAssertor.java
@@ -0,0 +1,33 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.assertor.element;
+
+import org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception.ValueAssertFailedException;
+
+public class NotNullAssertor extends ElementAssertor {
+    public NotNullAssertor() {
+        super(null);
+    }
+
+    @Override
+    public void assertValue(String desc, String actualValue) {
+        if (actualValue == null) {
+            throw new ValueAssertFailedException(desc, "not null", actualValue);
+        }
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/element/NullAssertor.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/element/NullAssertor.java
new file mode 100644
index 0000000..b30c3fa
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/element/NullAssertor.java
@@ -0,0 +1,33 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.assertor.element;
+
+import org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception.ValueAssertFailedException;
+
+public class NullAssertor extends ElementAssertor {
+    public NullAssertor() {
+        super(null);
+    }
+
+    @Override
+    public void assertValue(String desc, String actualValue) {
+        if (actualValue != null && actualValue.length() > 0) {
+            throw new ValueAssertFailedException(desc, "null", actualValue);
+        }
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/ActualRegistryOperationNameEmptyException.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/ActualRegistryOperationNameEmptyException.java
new file mode 100644
index 0000000..6600b63
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/ActualRegistryOperationNameEmptyException.java
@@ -0,0 +1,36 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception;
+
+import org.apache.skywalking.plugin.test.agent.tool.validator.entity.RegistryOperationName;
+import org.apache.skywalking.plugin.test.agent.tool.validator.exception.AssertFailedException;
+
+public class ActualRegistryOperationNameEmptyException extends AssertFailedException {
+
+    private final RegistryOperationName registryOperationName;
+
+    public ActualRegistryOperationNameEmptyException(RegistryOperationName registryOperationName) {
+        this.registryOperationName = registryOperationName;
+    }
+
+    @Override
+    public String getCauseMessage() {
+        return String.format("ActualRegistryOperationNameEmptyException\nexpected:%s\nactual:%s\n", registryOperationName
+            .operationName(), "Empty");
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/ActualSegmentItemEmptyException.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/ActualSegmentItemEmptyException.java
new file mode 100644
index 0000000..4ce4c53
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/ActualSegmentItemEmptyException.java
@@ -0,0 +1,35 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception;
+
+import org.apache.skywalking.plugin.test.agent.tool.validator.entity.SegmentItem;
+import org.apache.skywalking.plugin.test.agent.tool.validator.exception.AssertFailedException;
+
+public class ActualSegmentItemEmptyException extends AssertFailedException {
+
+    private final SegmentItem expected;
+
+    public ActualSegmentItemEmptyException(SegmentItem expected) {
+        this.expected = expected;
+    }
+
+    @Override
+    public String getCauseMessage() {
+        return String.format("ActualSegmentItemEmptyException\nexpected: %s\nactual: %s", expected, "Empty");
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/ActualSegmentRefIsEmptyException.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/ActualSegmentRefIsEmptyException.java
new file mode 100644
index 0000000..23a5566
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/ActualSegmentRefIsEmptyException.java
@@ -0,0 +1,33 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception;
+
+import org.apache.skywalking.plugin.test.agent.tool.validator.exception.AssertFailedException;
+
+public class ActualSegmentRefIsEmptyException extends AssertFailedException {
+    private final int expectedSize;
+
+    public ActualSegmentRefIsEmptyException(int expectedSize) {
+        this.expectedSize = expectedSize;
+    }
+
+    @Override
+    public String getCauseMessage() {
+        return String.format("ActualSegmentRefIsEmptyException\nexpected: %d\nactual: %s\n", expectedSize, "Not found");
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/KeyValueNotEqualsException.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/KeyValueNotEqualsException.java
new file mode 100644
index 0000000..e3eb65f
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/KeyValueNotEqualsException.java
@@ -0,0 +1,21 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception;
+
+public class KeyValueNotEqualsException extends RuntimeException {
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/LogEventKeyNotEqualsException.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/LogEventKeyNotEqualsException.java
new file mode 100644
index 0000000..c649c96
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/LogEventKeyNotEqualsException.java
@@ -0,0 +1,35 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception;
+
+import org.apache.skywalking.plugin.test.agent.tool.validator.exception.AssertFailedException;
+
+public class LogEventKeyNotEqualsException extends AssertFailedException {
+    private final String expected;
+    private final String actual;
+
+    public LogEventKeyNotEqualsException(String expected, String actual) {
+        this.expected = expected;
+        this.actual = actual;
+    }
+
+    @Override
+    public String getCauseMessage() {
+        return String.format("[log event key]: expected=>{%s}, actual=>{%s}\n", expected, actual);
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/LogEventSizeNotEqualsException.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/LogEventSizeNotEqualsException.java
new file mode 100644
index 0000000..e79bb89
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/LogEventSizeNotEqualsException.java
@@ -0,0 +1,35 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception;
+
+import org.apache.skywalking.plugin.test.agent.tool.validator.exception.AssertFailedException;
+
+public class LogEventSizeNotEqualsException extends AssertFailedException {
+    private final int expected;
+    private final int actual;
+
+    public LogEventSizeNotEqualsException(int expected, int actual) {
+        this.expected = expected;
+        this.actual = actual;
+    }
+
+    @Override
+    public String getCauseMessage() {
+        return String.format("[log event size]: expected=>{%d}, actual=>{%d}\n", expected, actual);
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/LogEventValueNotEqualsException.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/LogEventValueNotEqualsException.java
new file mode 100644
index 0000000..407b27c
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/LogEventValueNotEqualsException.java
@@ -0,0 +1,37 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception;
+
+import org.apache.skywalking.plugin.test.agent.tool.validator.exception.AssertFailedException;
+
+public class LogEventValueNotEqualsException extends AssertFailedException {
+    private final String eventKey;
+    private final String expected;
+    private final String actual;
+
+    public LogEventValueNotEqualsException(String eventKey, String expected, String actual) {
+        this.eventKey = eventKey;
+        this.expected = expected;
+        this.actual = actual;
+    }
+
+    @Override
+    public String getCauseMessage() {
+        return String.format("[log(%s} value]: expected=>{%s}, actual=>{%s}\n", eventKey, expected, actual);
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/LogSizeNotEqualsException.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/LogSizeNotEqualsException.java
new file mode 100644
index 0000000..73f1573
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/LogSizeNotEqualsException.java
@@ -0,0 +1,35 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception;
+
+import org.apache.skywalking.plugin.test.agent.tool.validator.exception.AssertFailedException;
+
+public class LogSizeNotEqualsException extends AssertFailedException {
+    private final int expected;
+    private final int actual;
+
+    public LogSizeNotEqualsException(int expected, int actual) {
+        this.expected = expected;
+        this.actual = actual;
+    }
+
+    @Override
+    public String getCauseMessage() {
+        return String.format("[log size]: expected=>{%d}, actual=>{%d}", expected, actual);
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/ParentSegmentNotFoundException.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/ParentSegmentNotFoundException.java
new file mode 100644
index 0000000..dc59c13
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/ParentSegmentNotFoundException.java
@@ -0,0 +1,34 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception;
+
+import org.apache.skywalking.plugin.test.agent.tool.validator.exception.AssertFailedException;
+
+public class ParentSegmentNotFoundException extends AssertFailedException {
+
+    private final String express;
+
+    public ParentSegmentNotFoundException(String express) {
+        this.express = express;
+    }
+
+    @Override
+    public String getCauseMessage() {
+        return String.format("ParentSegmentNotFoundException\nexpected: %s\nactual: %s\n", express, "NOT FOUND");
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/RefSizeNotEqualsException.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/RefSizeNotEqualsException.java
new file mode 100644
index 0000000..c7a2c7b
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/RefSizeNotEqualsException.java
@@ -0,0 +1,36 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception;
+
+import org.apache.skywalking.plugin.test.agent.tool.validator.exception.AssertFailedException;
+
+public class RefSizeNotEqualsException extends AssertFailedException {
+
+    private final int expected;
+    private final int actual;
+
+    public RefSizeNotEqualsException(int expected, int actual) {
+        this.expected = expected;
+        this.actual = actual;
+    }
+
+    @Override
+    public String getCauseMessage() {
+        return String.format("[segment ref size]: expected=>{%s}, actual=>{%s}", expected, actual);
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/RegistryApplicationNotFoundException.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/RegistryApplicationNotFoundException.java
new file mode 100644
index 0000000..449207c
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/RegistryApplicationNotFoundException.java
@@ -0,0 +1,33 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception;
+
+import org.apache.skywalking.plugin.test.agent.tool.validator.exception.AssertFailedException;
+
+public class RegistryApplicationNotFoundException extends AssertFailedException {
+    private final String applicationCode;
+
+    public RegistryApplicationNotFoundException(String applicationCode) {
+        this.applicationCode = applicationCode;
+    }
+
+    @Override
+    public String getCauseMessage() {
+        return String.format("RegistryApplicationNotFoundException\nexpected: %s\nactual: %s\n", applicationCode, "Not Found");
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/RegistryApplicationSizeNotEqualsException.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/RegistryApplicationSizeNotEqualsException.java
new file mode 100644
index 0000000..b6e17ee
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/RegistryApplicationSizeNotEqualsException.java
@@ -0,0 +1,36 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception;
+
+import org.apache.skywalking.plugin.test.agent.tool.validator.exception.AssertFailedException;
+
+public class RegistryApplicationSizeNotEqualsException extends AssertFailedException {
+    private final String applicationCode;
+    private final ValueAssertFailedException cause;
+
+    public RegistryApplicationSizeNotEqualsException(String applicationCode, ValueAssertFailedException cause) {
+        this.applicationCode = applicationCode;
+        this.cause = cause;
+    }
+
+    @Override
+    public String getCauseMessage() {
+        return String.format("RegistryApplicationSizeNotEqualsException: %s\nexpected: %s\nactual: %s\n", applicationCode, cause
+            .getExpected(), cause.getActual());
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/RegistryInstanceOfApplicationNotFoundException.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/RegistryInstanceOfApplicationNotFoundException.java
new file mode 100644
index 0000000..ba41bd1
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/RegistryInstanceOfApplicationNotFoundException.java
@@ -0,0 +1,34 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception;
+
+import org.apache.skywalking.plugin.test.agent.tool.validator.exception.AssertFailedException;
+
+public class RegistryInstanceOfApplicationNotFoundException extends AssertFailedException {
+
+    private final String applicationCode;
+
+    public RegistryInstanceOfApplicationNotFoundException(String applicationCode) {
+        this.applicationCode = applicationCode;
+    }
+
+    @Override
+    public String getCauseMessage() {
+        return String.format("RegistryInstanceOfApplicationNotFoundException\nexpected: Instances of Service(%s)" + "\nactual: %s\n", applicationCode, "NOT FOUND");
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/RegistryInstanceSizeNotEqualsException.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/RegistryInstanceSizeNotEqualsException.java
new file mode 100644
index 0000000..283e72a
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/RegistryInstanceSizeNotEqualsException.java
@@ -0,0 +1,37 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception;
+
+import org.apache.skywalking.plugin.test.agent.tool.validator.exception.AssertFailedException;
+
+public class RegistryInstanceSizeNotEqualsException extends AssertFailedException {
+
+    private final String applicationCode;
+    private final ValueAssertFailedException cause;
+
+    public RegistryInstanceSizeNotEqualsException(String applicationCode, ValueAssertFailedException cause) {
+        this.applicationCode = applicationCode;
+        this.cause = cause;
+    }
+
+    @Override
+    public String getCauseMessage() {
+        return String.format("RegistryInstanceSizeNotEqualsException %s\nexpected: %s\nactual: %s\n", applicationCode, cause
+            .getExpected(), cause.getActual());
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/RegistryOperationNameNotFoundException.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/RegistryOperationNameNotFoundException.java
new file mode 100644
index 0000000..1cf2ec7
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/RegistryOperationNameNotFoundException.java
@@ -0,0 +1,35 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception;
+
+import org.apache.skywalking.plugin.test.agent.tool.validator.exception.AssertFailedException;
+
+public class RegistryOperationNameNotFoundException extends AssertFailedException {
+    private final String applicationCode;
+    private final String operationName;
+
+    public RegistryOperationNameNotFoundException(String applicationCode, String operationName) {
+        this.applicationCode = applicationCode;
+        this.operationName = operationName;
+    }
+
+    @Override
+    public String getCauseMessage() {
+        return String.format("RegistryOperationNameNotFoundException %s\nexpected: %s\nactual: %s\n", applicationCode, operationName, "NOT FOUND");
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/RegistryOperationNamesOfApplicationNotFoundException.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/RegistryOperationNamesOfApplicationNotFoundException.java
new file mode 100644
index 0000000..c416841
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/RegistryOperationNamesOfApplicationNotFoundException.java
@@ -0,0 +1,35 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception;
+
+import org.apache.skywalking.plugin.test.agent.tool.validator.entity.RegistryOperationName;
+import org.apache.skywalking.plugin.test.agent.tool.validator.exception.AssertFailedException;
+
+public class RegistryOperationNamesOfApplicationNotFoundException extends AssertFailedException {
+    private final RegistryOperationName applicationCode;
+
+    public RegistryOperationNamesOfApplicationNotFoundException(RegistryOperationName applicationCode) {
+        this.applicationCode = applicationCode;
+    }
+
+    @Override
+    public String getCauseMessage() {
+        return String.format("RegistryOperationNamesOfApplicationNotFoundException %s\nexpected: %s\nactual: %s\n", applicationCode
+            .serviceName(), applicationCode.operationName(), "NOT FOUND");
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/SegmentItemNotFoundException.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/SegmentItemNotFoundException.java
new file mode 100644
index 0000000..038fd41
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/SegmentItemNotFoundException.java
@@ -0,0 +1,33 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception;
+
+import org.apache.skywalking.plugin.test.agent.tool.validator.exception.AssertFailedException;
+
+public class SegmentItemNotFoundException extends AssertFailedException {
+    private final String applicationCode;
+
+    public SegmentItemNotFoundException(String applicationCode) {
+        this.applicationCode = applicationCode;
+    }
+
+    @Override
+    public String getCauseMessage() {
+        return String.format("SegmentItemNotFoundException\nexpected: %s\nactual: %s", applicationCode, "Not Found");
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/SegmentNotFoundException.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/SegmentNotFoundException.java
new file mode 100644
index 0000000..28ba9db
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/SegmentNotFoundException.java
@@ -0,0 +1,56 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception;
+
+import java.util.List;
+import org.apache.skywalking.plugin.test.agent.tool.validator.assertor.SegmentPredictionFailedCause;
+import org.apache.skywalking.plugin.test.agent.tool.validator.entity.Segment;
+import org.apache.skywalking.plugin.test.agent.tool.validator.entity.Span;
+import org.apache.skywalking.plugin.test.agent.tool.validator.exception.AssertFailedException;
+
+public class SegmentNotFoundException extends AssertFailedException {
+    private final Segment expectedSegment;
+    private final List<SegmentPredictionFailedCause> failedCauses;
+
+    public SegmentNotFoundException(Segment expectedSegment, List<SegmentPredictionFailedCause> failedCauses) {
+        this.expectedSegment = expectedSegment;
+        this.failedCauses = failedCauses;
+    }
+
+    @Override
+    public String getCauseMessage() {
+        StringBuilder expectedMessage = new StringBuilder("\n  Segment:\n");
+        for (Span span : expectedSegment.spans()) {
+            expectedMessage.append(String.format("  - span[%s, %s] %s\n", span.parentSpanId(), span.spanId(), span.operationName()));
+        }
+
+        StringBuilder causeMessage = new StringBuilder();
+        for (SegmentPredictionFailedCause cause : failedCauses) {
+            Segment actualSegment = cause.getActualSegment();
+            Span actualSpan = cause.getSpanAssertFailedCause().getActualSpan();
+            Span expectedSpan = cause.getSpanAssertFailedCause().getExceptedSpan();
+
+            causeMessage.append(String.format("\n  Segment[%s] e\n  expected:\tSpan[%s, %s] %s\n  " + "actual:" + "\tspan[%s, %s] %s\n  reason:\t%s\n", actualSegment
+                .segmentId(), expectedSpan.parentSpanId(), expectedSpan.spanId(), expectedSpan.operationName(), actualSpan
+                .parentSpanId(), actualSpan.spanId(), actualSpan.operationName(), cause.getSpanAssertFailedCause()
+                                                                                       .getCauseMessage()));
+        }
+
+        return String.format("SegmentNotFoundException:\nexpected: %s\nactual: %s\n", expectedMessage, causeMessage);
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/SegmentRefAssertFailedException.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/SegmentRefAssertFailedException.java
new file mode 100644
index 0000000..f616190
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/SegmentRefAssertFailedException.java
@@ -0,0 +1,38 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception;
+
+import org.apache.skywalking.plugin.test.agent.tool.validator.entity.SegmentRef;
+import org.apache.skywalking.plugin.test.agent.tool.validator.exception.AssertFailedException;
+
+public class SegmentRefAssertFailedException extends AssertFailedException {
+    private final ValueAssertFailedException e;
+    private final SegmentRef expected;
+    private final SegmentRef actual;
+
+    public SegmentRefAssertFailedException(ValueAssertFailedException e, SegmentRef expected, SegmentRef actual) {
+        this.e = e;
+        this.expected = expected;
+        this.actual = actual;
+    }
+
+    @Override
+    public String getCauseMessage() {
+        return e.getCauseMessage();
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/SegmentRefNotFoundException.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/SegmentRefNotFoundException.java
new file mode 100644
index 0000000..49f4e1f
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/SegmentRefNotFoundException.java
@@ -0,0 +1,56 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception;
+
+import java.util.List;
+import org.apache.skywalking.plugin.test.agent.tool.validator.assertor.SegmentRefAssertFailedCause;
+import org.apache.skywalking.plugin.test.agent.tool.validator.entity.SegmentRef;
+import org.apache.skywalking.plugin.test.agent.tool.validator.exception.AssertFailedException;
+
+public class SegmentRefNotFoundException extends AssertFailedException {
+    private final SegmentRef expected;
+    private final List<SegmentRefAssertFailedCause> causes;
+
+    public SegmentRefNotFoundException(SegmentRef expected, List<SegmentRefAssertFailedCause> causes) {
+        this.expected = expected;
+        this.causes = causes;
+    }
+
+    @Override
+    public String getCauseMessage() {
+
+        StringBuilder actualMessage = new StringBuilder();
+        for (SegmentRefAssertFailedCause cause : causes) {
+            SegmentRef actual = cause.getActual();
+            String reason = cause.getFailedCause().getCauseMessage();
+
+            StringBuilder actualSegmentRef = new StringBuilder(String.format("\nSegmentRef:\t%s\n", reason));
+            actualSegmentRef.append(String.format(" - entryServiceName:\t\t%s\n", actual.entryEndpointName()))
+                            .append(String.format(" - networkAddress:\t\t\t%s\n", actual.networkAddress()))
+                            .append(String.format(" - parentServiceName:\t\t%s\n", actual.parentEndpointName()))
+                            .append(String.format(" - parentSpanId:\t\t\t%s\n", actual.parentSpanId()))
+                            .append(String.format(" - parentTraceSegmentId:\t%s\n", actual.parentTraceSegmentId()))
+                            .append(String.format(" - refType:\t\t\t\t\t%s", actual.refType()))
+                            .toString();
+
+            actualMessage.append(String.format("%s\n", actualSegmentRef));
+        }
+
+        return String.format("SegmentRefNotFoundException\nexpected: %s\nactual: %s\n", expected, actualMessage);
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/SegmentRefSizeNotEqualsException.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/SegmentRefSizeNotEqualsException.java
new file mode 100644
index 0000000..fa57496
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/SegmentRefSizeNotEqualsException.java
@@ -0,0 +1,35 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception;
+
+import org.apache.skywalking.plugin.test.agent.tool.validator.exception.AssertFailedException;
+
+public class SegmentRefSizeNotEqualsException extends AssertFailedException {
+    private final int expected;
+    private final int actual;
+
+    public SegmentRefSizeNotEqualsException(int expected, int actual) {
+        this.expected = expected;
+        this.actual = actual;
+    }
+
+    @Override
+    public String getCauseMessage() {
+        return String.format("SegmentRefSizeNotEqualsException\nexpected:\t%s\nactual:\t%s\n", expected, actual);
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/SegmentSizeNotEqualsException.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/SegmentSizeNotEqualsException.java
new file mode 100644
index 0000000..6ec8e56
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/SegmentSizeNotEqualsException.java
@@ -0,0 +1,37 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception;
+
+import org.apache.skywalking.plugin.test.agent.tool.validator.exception.AssertFailedException;
+
+public class SegmentSizeNotEqualsException extends AssertFailedException {
+    private final String applicationCode;
+    private final String expected;
+    private final String actual;
+
+    public SegmentSizeNotEqualsException(String applicationCode, String expected, String actual) {
+        this.applicationCode = applicationCode;
+        this.expected = expected;
+        this.actual = actual;
+    }
+
+    @Override
+    public String getCauseMessage() {
+        return String.format("SegmentSizeNotEqualsException:\t%s\nexpected:\t%s\nactual:\t\t%s\n", applicationCode, expected, actual);
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/SpanAssertFailedException.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/SpanAssertFailedException.java
new file mode 100644
index 0000000..e5ae437
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/SpanAssertFailedException.java
@@ -0,0 +1,46 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception;
+
+import org.apache.skywalking.plugin.test.agent.tool.validator.entity.Span;
+import org.apache.skywalking.plugin.test.agent.tool.validator.exception.AssertFailedException;
+
+public class SpanAssertFailedException extends AssertFailedException {
+    private final AssertFailedException failedCause;
+    private final Span exceptedSpan;
+    private final Span actualSpan;
+
+    public SpanAssertFailedException(AssertFailedException failedCause, Span exceptedSpan, Span actualSpan) {
+        this.failedCause = failedCause;
+        this.exceptedSpan = exceptedSpan;
+        this.actualSpan = actualSpan;
+    }
+
+    public Span getExceptedSpan() {
+        return exceptedSpan;
+    }
+
+    public Span getActualSpan() {
+        return actualSpan;
+    }
+
+    @Override
+    public String getCauseMessage() {
+        return failedCause.getCauseMessage();
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/SpanSizeNotEqualsException.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/SpanSizeNotEqualsException.java
new file mode 100644
index 0000000..702ab45
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/SpanSizeNotEqualsException.java
@@ -0,0 +1,36 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception;
+
+import org.apache.skywalking.plugin.test.agent.tool.validator.exception.AssertFailedException;
+
+public class SpanSizeNotEqualsException extends AssertFailedException {
+
+    private final int expected;
+    private final int actual;
+
+    public SpanSizeNotEqualsException(int expected, int actual) {
+        this.expected = expected;
+        this.actual = actual;
+    }
+
+    @Override
+    public String getCauseMessage() {
+        return String.format("[span size]: expected=>{%s}, actual=>{%s}\n", expected, actual);
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/TagKeyNotEqualsException.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/TagKeyNotEqualsException.java
new file mode 100644
index 0000000..8eef92d
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/TagKeyNotEqualsException.java
@@ -0,0 +1,35 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception;
+
+import org.apache.skywalking.plugin.test.agent.tool.validator.exception.AssertFailedException;
+
+public class TagKeyNotEqualsException extends AssertFailedException {
+    private final String expected;
+    private final String actual;
+
+    public TagKeyNotEqualsException(String expected, String actual) {
+        this.expected = expected;
+        this.actual = actual;
+    }
+
+    @Override
+    public String getCauseMessage() {
+        return String.format("[tag key]: expected=>{%s}, actual=>{%s}\n", expected, actual);
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/TagSizeNotEqualsException.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/TagSizeNotEqualsException.java
new file mode 100644
index 0000000..b09e6bf
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/TagSizeNotEqualsException.java
@@ -0,0 +1,35 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception;
+
+import org.apache.skywalking.plugin.test.agent.tool.validator.exception.AssertFailedException;
+
+public class TagSizeNotEqualsException extends AssertFailedException {
+    private final int expected;
+    private final int actual;
+
+    public TagSizeNotEqualsException(int expected, int actual) {
+        this.expected = expected;
+        this.actual = actual;
+    }
+
+    @Override
+    public String getCauseMessage() {
+        return String.format("[tag size]: expected=>{%s}, actual=>{%s}\n", expected, actual);
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/TagValueNotEqualsException.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/TagValueNotEqualsException.java
new file mode 100644
index 0000000..6c8d41f
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/TagValueNotEqualsException.java
@@ -0,0 +1,37 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception;
+
+import org.apache.skywalking.plugin.test.agent.tool.validator.exception.AssertFailedException;
+
+public class TagValueNotEqualsException extends AssertFailedException {
+    private final String tagKey;
+    private final String expected;
+    private final String actual;
+
+    public TagValueNotEqualsException(String tagKey, String expected, String actual) {
+        this.tagKey = tagKey;
+        this.expected = expected;
+        this.actual = actual;
+    }
+
+    @Override
+    public String getCauseMessage() {
+        return String.format("[tag(%s) value]: expected=>{}, actual=>{%s}\n", tagKey, expected, actual);
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/TypeUndefinedException.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/TypeUndefinedException.java
new file mode 100644
index 0000000..aef9b1a
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/TypeUndefinedException.java
@@ -0,0 +1,27 @@
+/*
+ * 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.
+ *
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception;
+
+public class TypeUndefinedException extends Exception {
+
+    public TypeUndefinedException(String message) {
+        super(message);
+    }
+
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/ValueAssertFailedException.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/ValueAssertFailedException.java
new file mode 100644
index 0000000..7f7d120
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/assertor/exception/ValueAssertFailedException.java
@@ -0,0 +1,49 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception;
+
+import org.apache.skywalking.plugin.test.agent.tool.validator.exception.AssertFailedException;
+
+public class ValueAssertFailedException extends AssertFailedException {
+    private final String desc;
+    private final String expected;
+    private final String actual;
+
+    public ValueAssertFailedException(String desc, String expected, String actual) {
+        this.desc = desc;
+        this.expected = expected;
+        this.actual = actual;
+    }
+
+    public String getDesc() {
+        return desc;
+    }
+
+    public String getExpected() {
+        return expected;
+    }
+
+    public String getActual() {
+        return actual;
+    }
+
+    @Override
+    public String getCauseMessage() {
+        return String.format("[%s]: expected=>{%s}, actual=>{%s}", desc, expected, actual);
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/entity/Data.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/entity/Data.java
new file mode 100644
index 0000000..fa45668
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/entity/Data.java
@@ -0,0 +1,76 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.entity;
+
+import java.io.File;
+import java.io.FileInputStream;
+import java.io.InputStream;
+import java.util.List;
+import org.apache.skywalking.plugin.test.agent.tool.validator.exception.IllegalDataFileException;
+import org.yaml.snakeyaml.TypeDescription;
+import org.yaml.snakeyaml.Yaml;
+import org.yaml.snakeyaml.constructor.Constructor;
+import org.yaml.snakeyaml.representer.Representer;
+
+public interface Data {
+    RegistryItems registryItems();
+
+    List<SegmentItem> segmentItems();
+
+    class Loader {
+        public static Data loadData(String fileName, File file) {
+            try {
+                return loadData(new FileInputStream(file));
+            } catch (Exception e) {
+                throw new IllegalDataFileException(fileName);
+            }
+        }
+
+        public static Data loadData(InputStream inputStream) {
+            Constructor constructor = new Constructor(DataForRead.class);
+            TypeDescription configDescription = new TypeDescription(DataForRead.class);
+            configDescription.putListPropertyType("data", DataForRead.class);
+
+            Representer representer = new Representer();
+            representer.getPropertyUtils().setSkipMissingProperties(true);
+            Yaml yaml = new Yaml(constructor, representer);
+            Data result = yaml.loadAs(inputStream, DataForRead.class);
+            if (result == null) {
+                throw new RuntimeException();
+            } else {
+                return result;
+            }
+        }
+
+        public static Data loadData(String data) {
+            Constructor constructor = new Constructor(DataForRead.class);
+            TypeDescription configDescription = new TypeDescription(DataForRead.class);
+            configDescription.putListPropertyType("data", DataForRead.class);
+
+            Representer representer = new Representer();
+            representer.getPropertyUtils().setSkipMissingProperties(true);
+            Yaml yaml = new Yaml(constructor, representer);
+            Data result = yaml.loadAs(data, DataForRead.class);
+            if (result == null) {
+                throw new RuntimeException();
+            } else {
+                return result;
+            }
+        }
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/entity/DataForRead.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/entity/DataForRead.java
new file mode 100644
index 0000000..c206f9f
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/entity/DataForRead.java
@@ -0,0 +1,42 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.entity;
+
+import java.util.ArrayList;
+import java.util.List;
+
+@lombok.Data
+public class DataForRead implements Data {
+    private RegistryItemsForRead registryItems;
+    private List<SegmentItemForRead> segmentItems;
+
+    @Override
+    public RegistryItemsForRead registryItems() {
+        return registryItems;
+    }
+
+    @Override
+    public List<SegmentItem> segmentItems() {
+        if (this.segmentItems == null) {
+            return null;
+        }
+
+        return new ArrayList<>(this.segmentItems);
+    }
+
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/entity/KeyValuePair.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/entity/KeyValuePair.java
new file mode 100644
index 0000000..8032baa
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/entity/KeyValuePair.java
@@ -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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.entity;
+
+public interface KeyValuePair {
+    String key();
+
+    String value();
+
+    class Impl implements KeyValuePair {
+        private String key;
+        private String value;
+
+        public Impl(String key, String value) {
+            this.key = key;
+            this.value = value;
+        }
+
+        @Override
+        public String key() {
+            return key;
+        }
+
+        @Override
+        public String value() {
+            return value;
+        }
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/entity/LogEvent.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/entity/LogEvent.java
new file mode 100644
index 0000000..f4158f7
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/entity/LogEvent.java
@@ -0,0 +1,42 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.entity;
+
+import java.util.ArrayList;
+import java.util.List;
+
+public interface LogEvent {
+    List<KeyValuePair> events();
+
+    class Impl implements LogEvent {
+        private List<KeyValuePair> keyValuePairs;
+
+        Impl() {
+            keyValuePairs = new ArrayList<>();
+        }
+
+        void add(String key, String value) {
+            keyValuePairs.add(new KeyValuePair.Impl(key, value));
+        }
+
+        @Override
+        public List<KeyValuePair> events() {
+            return keyValuePairs;
+        }
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/entity/RegistryApplication.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/entity/RegistryApplication.java
new file mode 100644
index 0000000..760fa70
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/entity/RegistryApplication.java
@@ -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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.entity;
+
+public interface RegistryApplication {
+    String applicationCode();
+
+    String expressValue();
+
+    class Impl implements RegistryApplication {
+        private String applicationCode;
+        private String express;
+
+        Impl(String code, String express) {
+            this.applicationCode = code;
+            this.express = express;
+        }
+
+        @Override
+        public String applicationCode() {
+            return applicationCode;
+        }
+
+        @Override
+        public String expressValue() {
+            return express;
+        }
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/entity/RegistryInstance.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/entity/RegistryInstance.java
new file mode 100644
index 0000000..766fdf0
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/entity/RegistryInstance.java
@@ -0,0 +1,46 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.entity;
+
+public interface RegistryInstance {
+
+    String applicationCode();
+
+    String expressValue();
+
+    class Impl implements RegistryInstance {
+
+        private final String code;
+        private final String express;
+
+        Impl(String code, String express) {
+            this.code = code;
+            this.express = express;
+        }
+
+        @Override
+        public String applicationCode() {
+            return code;
+        }
+
+        @Override
+        public String expressValue() {
+            return express;
+        }
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/entity/RegistryItems.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/entity/RegistryItems.java
new file mode 100644
index 0000000..279f41a
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/entity/RegistryItems.java
@@ -0,0 +1,28 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.entity;
+
+import java.util.List;
+
+public interface RegistryItems {
+    List<RegistryApplication> applications();
+
+    List<RegistryInstance> instances();
+
+    List<RegistryOperationName> operationNames();
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/entity/RegistryItemsForRead.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/entity/RegistryItemsForRead.java
new file mode 100644
index 0000000..071a1af
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/entity/RegistryItemsForRead.java
@@ -0,0 +1,75 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.entity;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+import lombok.Data;
+
+@Data
+public class RegistryItemsForRead implements RegistryItems {
+    private List<Map<String, String>> applications;
+    private List<Map<String, String>> instances;
+    private List<Map<String, List<String>>> operationNames;
+
+    @Override
+    public List<RegistryApplication> applications() {
+        if (this.applications == null) {
+            return null;
+        }
+
+        List<RegistryApplication> registryApplications = new ArrayList<>();
+        for (Map<String, String> registryApplication : applications) {
+            String applicationCode = new ArrayList<String>(registryApplication.keySet()).get(0);
+            String express = String.valueOf(registryApplication.get(applicationCode));
+            registryApplications.add(new RegistryApplication.Impl(applicationCode, express));
+        }
+        return registryApplications;
+    }
+
+    @Override
+    public List<RegistryInstance> instances() {
+        if (this.instances == null) {
+            return null;
+        }
+
+        List<RegistryInstance> registryInstances = new ArrayList<>();
+        instances.forEach((registryInstance) -> {
+            String applicationCode = new ArrayList<String>(registryInstance.keySet()).get(0);
+            String express = String.valueOf(registryInstance.get(applicationCode));
+            registryInstances.add(new RegistryInstance.Impl(applicationCode, express));
+        });
+        return registryInstances;
+    }
+
+    @Override
+    public List<RegistryOperationName> operationNames() {
+        if (this.operationNames == null) {
+            return null;
+        }
+
+        List<RegistryOperationName> registryOperationNames = new ArrayList<>();
+        operationNames.forEach((registryInstance) -> {
+            String applicationCode = new ArrayList<String>(registryInstance.keySet()).get(0);
+            List<String> express = registryInstance.get(applicationCode);
+            registryOperationNames.add(new RegistryOperationName.Impl(applicationCode, express));
+        });
+        return registryOperationNames;
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/entity/RegistryOperationName.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/entity/RegistryOperationName.java
new file mode 100644
index 0000000..bcff123
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/entity/RegistryOperationName.java
@@ -0,0 +1,46 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.entity;
+
+import java.util.List;
+
+public interface RegistryOperationName {
+    String serviceName();
+
+    List<String> operationName();
+
+    class Impl implements RegistryOperationName {
+        private final String code;
+        private final List<String> express;
+
+        Impl(String code, List<String> express) {
+            this.code = code;
+            this.express = express;
+        }
+
+        @Override
+        public String serviceName() {
+            return code;
+        }
+
+        @Override
+        public List<String> operationName() {
+            return express;
+        }
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/entity/Segment.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/entity/Segment.java
new file mode 100644
index 0000000..6f42e22
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/entity/Segment.java
@@ -0,0 +1,28 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.entity;
+
+import java.util.List;
+
+public interface Segment {
+    String segmentId();
+
+    List<Span> spans();
+
+    void setSegmentId(String segmentId);
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/entity/SegmentForRead.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/entity/SegmentForRead.java
new file mode 100644
index 0000000..36e5fdc
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/entity/SegmentForRead.java
@@ -0,0 +1,378 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.entity;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+import lombok.Data;
+
+public class SegmentForRead implements Segment {
+    private String segmentId;
+    private List<SpanForRead> spans;
+
+    @Override
+    public String segmentId() {
+        return segmentId;
+    }
+
+    @Override
+    public List<Span> spans() {
+        if (spans == null) {
+            return null;
+        }
+        return new ArrayList<>(spans);
+    }
+
+    @Data
+    public static class SegmentRefForRead implements SegmentRef {
+        private String parentEndpointId;
+        private String parentEndpoint;
+        private String networkAddressId;
+        private String entryEndpointId;
+        private String refType;
+        private String parentSpanId;
+        private String parentTraceSegmentId;
+        private String parentServiceInstanceId;
+        private String networkAddress;
+        private String entryEndpoint;
+        private String entryServiceInstanceId;
+
+        public SegmentRefForRead() {
+        }
+
+        public SegmentRefForRead(Map<String, Object> ref) {
+            this.networkAddress = ref.get("networkAddress").toString();
+            this.entryEndpoint = ref.get("entryEndpoint").toString();
+            this.parentEndpoint = ref.get("parentEndpoint").toString();
+            this.parentTraceSegmentId = ref.get("parentTraceSegmentId").toString();
+            this.entryServiceInstanceId = ref.get("entryServiceInstanceId").toString();
+            this.refType = ref.get("refType") == null ? null : ref.get("refType").toString();
+            this.parentSpanId = ref.get("parentSpanId") == null ? null : ref.get("parentSpanId").toString();
+            this.entryEndpointId = ref.get("entryEndpointId") == null ? null : ref.get("entryEndpointId").toString();
+            this.parentEndpointId = ref.get("parentEndpointId") == null ? null : ref.get("parentEndpointId").toString();
+            this.networkAddressId = ref.get("networkAddressId") == null ? null : ref.get("networkAddressId").toString();
+            this.parentServiceInstanceId = ref.get("parentServiceInstanceId") == null ? null : ref.get("parentServiceInstanceId")
+                                                                                                  .toString();
+        }
+
+        @Override
+        public String parentEndpointId() {
+            return parentEndpointId;
+        }
+
+        @Override
+        public String parentEndpointName() {
+            return parentEndpoint;
+        }
+
+        @Override
+        public String networkAddressId() {
+            return networkAddressId;
+        }
+
+        @Override
+        public String entryEndpointId() {
+            return entryEndpointId;
+        }
+
+        @Override
+        public String refType() {
+            return refType;
+        }
+
+        @Override
+        public String parentSpanId() {
+            return parentSpanId;
+        }
+
+        @Override
+        public String parentTraceSegmentId() {
+            return parentTraceSegmentId;
+        }
+
+        @Override
+        public String parentServiceInstanceId() {
+            return parentServiceInstanceId;
+        }
+
+        @Override
+        public String networkAddress() {
+            return networkAddress;
+        }
+
+        @Override
+        public String entryEndpointName() {
+            return entryEndpoint;
+        }
+
+        @Override
+        public void parentTraceSegmentId(String parentTraceSegmentId) {
+            this.parentTraceSegmentId = parentTraceSegmentId;
+        }
+
+        @Override
+        public String entryServiceInstanceId() {
+            return entryServiceInstanceId;
+        }
+
+        @Override
+        public String toString() {
+            StringBuilder actualSegmentRef = new StringBuilder("\nSegmentRef:\n");
+            return actualSegmentRef.append(String.format(" - entryServiceName:\t\t%s\n", entryEndpointName()))
+                                   .append(String.format(" - networkAddress:\t\t\t%s\n", networkAddress()))
+                                   .append(String.format(" - parentServiceName:\t\t%s\n", parentEndpointName()))
+                                   .append(String.format(" - parentSpanId:\t\t\t%s\n", parentSpanId()))
+                                   .append(String.format(" - parentTraceSegmentId:\t%s\n", parentTraceSegmentId()))
+                                   .append(String.format(" - refType:\t\t\t\t\t%s", refType()))
+                                   .toString();
+        }
+    }
+
+    public static class SpanForRead implements Span {
+        private String operationName;
+        private String operationId;
+        private String parentSpanId;
+        private String spanId;
+        private String spanLayer;
+        private List<Map<String, String>> tags;
+        private List<Map<String, List<Map<String, String>>>> logs;
+        private List<Map<String, Object>> refs;
+        private List<SegmentRef> formatedRefs;
+        private List<SegmentRef> actualRefs;
+        private String startTime;
+        private String endTime;
+        private String componentId;
+        private String componentName;
+        private String isError;
+        private String spanType;
+        private String peer;
+        private String peerId;
+
+        public void setOperationName(String operationName) {
+            this.operationName = operationName;
+        }
+
+        public void setOperationId(String operationId) {
+            this.operationId = operationId;
+        }
+
+        public void setParentSpanId(String parentSpanId) {
+            this.parentSpanId = parentSpanId;
+        }
+
+        public void setSpanId(String spanId) {
+            this.spanId = spanId;
+        }
+
+        public void setSpanLayer(String spanLayer) {
+            this.spanLayer = spanLayer;
+        }
+
+        public void setTags(List<Map<String, String>> tags) {
+            this.tags = tags;
+        }
+
+        public void setLogs(List<Map<String, List<Map<String, String>>>> logs) {
+            this.logs = logs;
+        }
+
+        public void setStartTime(String startTime) {
+            this.startTime = startTime;
+        }
+
+        public void setEndTime(String endTime) {
+            this.endTime = endTime;
+        }
+
+        public void setComponentId(String componentId) {
+            this.componentId = componentId;
+        }
+
+        public void setComponentName(String componentName) {
+            this.componentName = componentName;
+        }
+
+        public void setError(String error) {
+            isError = error;
+        }
+
+        public void setSpanType(String spanType) {
+            this.spanType = spanType;
+        }
+
+        public void setPeer(String peer) {
+            this.peer = peer;
+        }
+
+        public void setPeerId(String peerId) {
+            this.peerId = peerId;
+        }
+
+        public void setRefs(List<Map<String, Object>> refs) {
+            this.refs = refs;
+        }
+
+        @Override
+        public String operationName() {
+            return operationName;
+        }
+
+        @Override
+        public String operationId() {
+            return operationId;
+        }
+
+        @Override
+        public String parentSpanId() {
+            return parentSpanId;
+        }
+
+        @Override
+        public String spanId() {
+            return spanId;
+        }
+
+        @Override
+        public String spanLayer() {
+            return spanLayer;
+        }
+
+        @Override
+        public List<KeyValuePair> tags() {
+            if (tags == null) {
+                return new ArrayList<>();
+            }
+            List<KeyValuePair> result = new ArrayList<>();
+            for (Map<String, String> tag : tags) {
+                result.add(new KeyValuePair.Impl(tag.get("key"), tag.get("value")));
+            }
+            return result;
+        }
+
+        @Override
+        public List<LogEvent> logs() {
+            if (logs == null) {
+                return new ArrayList<>();
+            }
+            List<LogEvent> result = new ArrayList<>();
+            for (Map<String, List<Map<String, String>>> log : logs) {
+                List<Map<String, String>> events = log.get("logEvent");
+                LogEvent.Impl logEvent = new LogEvent.Impl();
+                for (Map<String, String> event : events) {
+                    logEvent.add(event.get("key"), event.get("value"));
+                }
+                result.add(logEvent);
+            }
+
+            return result;
+        }
+
+        @Override
+        public String startTime() {
+            return startTime;
+        }
+
+        @Override
+        public String endTime() {
+            return endTime;
+        }
+
+        @Override
+        public String componentId() {
+            return componentId;
+        }
+
+        @Override
+        public String componentName() {
+            return componentName;
+        }
+
+        @Override
+        public String error() {
+            return isError;
+        }
+
+        @Override
+        public String spanType() {
+            return spanType;
+        }
+
+        @Override
+        public String peer() {
+            return peer;
+        }
+
+        @Override
+        public String peerId() {
+            return peerId;
+        }
+
+        @Override
+        public List<SegmentRef> refs() {
+            if (formatedRefs == null && refs != null) {
+                List<SegmentRef> segmentRefs = new ArrayList<>();
+                for (Map<String, Object> ref : refs) {
+                    segmentRefs.add(new SegmentRefForRead(ref));
+                }
+
+                this.formatedRefs = segmentRefs;
+            }
+            return formatedRefs;
+        }
+
+        @Override
+        public void setActualRefs(List<SegmentRef> refs) {
+            this.actualRefs = refs;
+        }
+
+        @Override
+        public List<SegmentRef> actualRefs() {
+            return actualRefs;
+        }
+    }
+
+    public static class LogEventForRead {
+        private List<Map<String, String>> logEvent;
+
+        public List<Map<String, String>> getLogEvent() {
+            return logEvent;
+        }
+
+        public void setLogEvent(List<Map<String, String>> logEvent) {
+            this.logEvent = logEvent;
+        }
+    }
+
+    public String getSegmentId() {
+        return segmentId;
+    }
+
+    public List<SpanForRead> getSpans() {
+        return spans;
+    }
+
+    @Override
+    public void setSegmentId(String segmentId) {
+        this.segmentId = segmentId;
+    }
+
+    public void setSpans(List<SpanForRead> spans) {
+        this.spans = spans;
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/entity/SegmentItem.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/entity/SegmentItem.java
new file mode 100644
index 0000000..7b0bc67
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/entity/SegmentItem.java
@@ -0,0 +1,28 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.entity;
+
+import java.util.List;
+
+public interface SegmentItem {
+    String serviceName();
+
+    String segmentSize();
+
+    List<Segment> segments();
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/entity/SegmentItemForRead.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/entity/SegmentItemForRead.java
new file mode 100644
index 0000000..ab4b3c6
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/entity/SegmentItemForRead.java
@@ -0,0 +1,54 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.entity;
+
+import java.util.ArrayList;
+import java.util.List;
+import lombok.Data;
+
+@Data
+public class SegmentItemForRead implements SegmentItem {
+    private String serviceName;
+    private String segmentSize;
+    private List<SegmentForRead> segments;
+
+    @Override
+    public String serviceName() {
+        return serviceName;
+    }
+
+    @Override
+    public String segmentSize() {
+        return segmentSize;
+    }
+
+    @Override
+    public List<Segment> segments() {
+        if (segments == null) {
+            return null;
+        }
+        return new ArrayList<>(segments);
+    }
+
+    @Override
+    public String toString() {
+        StringBuilder message = new StringBuilder(String.format("\nSegment Item[%s]", serviceName));
+        message.append(String.format(" - segment size:\t\t%s\n", segmentSize));
+        return message.toString();
+    }
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/entity/SegmentRef.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/entity/SegmentRef.java
new file mode 100644
index 0000000..77cf0b7
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/entity/SegmentRef.java
@@ -0,0 +1,45 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.entity;
+
+public interface SegmentRef {
+
+    String parentEndpointId();
+
+    String parentEndpointName();
+
+    String networkAddressId();
+
+    String entryEndpointId();
+
+    String refType();
+
+    String parentSpanId();
+
+    String parentTraceSegmentId();
+
+    String parentServiceInstanceId();
+
+    String networkAddress();
+
+    String entryEndpointName();
+
+    void parentTraceSegmentId(String parentTraceSegmentId);
+
+    String entryServiceInstanceId();
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/entity/Span.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/entity/Span.java
new file mode 100644
index 0000000..ea1bc99
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/entity/Span.java
@@ -0,0 +1,58 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.entity;
+
+import java.util.List;
+
+public interface Span {
+    String operationName();
+
+    String operationId();
+
+    String parentSpanId();
+
+    String spanId();
+
+    String spanLayer();
+
+    List<KeyValuePair> tags();
+
+    List<LogEvent> logs();
+
+    String startTime();
+
+    String endTime();
+
+    String componentId();
+
+    String componentName();
+
+    String error();
+
+    String spanType();
+
+    String peer();
+
+    String peerId();
+
+    List<SegmentRef> refs();
+
+    void setActualRefs(List<SegmentRef> refs);
+
+    List<SegmentRef> actualRefs();
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/exception/AssertFailedException.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/exception/AssertFailedException.java
new file mode 100644
index 0000000..902c346
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/exception/AssertFailedException.java
@@ -0,0 +1,29 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.exception;
+
+public abstract class AssertFailedException extends RuntimeException {
+    protected AssertFailedException(String message) {
+        super(message);
+    }
+
+    protected AssertFailedException() {
+    }
+
+    public abstract String getCauseMessage();
+}
diff --git a/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/exception/IllegalDataFileException.java b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/exception/IllegalDataFileException.java
new file mode 100644
index 0000000..a80fa67
--- /dev/null
+++ b/test/e2e/validator/src/main/java/org/apache/skywalking/plugin/test/agent/tool/validator/exception/IllegalDataFileException.java
@@ -0,0 +1,31 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.agent.tool.validator.exception;
+
+public class IllegalDataFileException extends AssertFailedException {
+    private final String fileName;
+
+    public IllegalDataFileException(String fileName) {
+        this.fileName = fileName;
+    }
+
+    @Override
+    public String getCauseMessage() {
+        return String.format("IllegalDataFileException %s ", fileName);
+    }
+}
diff --git a/test/e2e/validator/src/main/resources/log4j2.xml b/test/e2e/validator/src/main/resources/log4j2.xml
new file mode 100644
index 0000000..342bd6d
--- /dev/null
+++ b/test/e2e/validator/src/main/resources/log4j2.xml
@@ -0,0 +1,37 @@
+<?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 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.
+  ~
+  -->
+<Configuration status="INFO">
+    <Appenders>
+        <Console name="console_out" target="SYSTEM_OUT">
+            <ThresholdFilter level="INFO"/>
+            <PatternLayout charset="UTF-8" pattern="[%d{yyyy-MM-dd HH:mm:ss:SSS}] [%p] - %l - %m%n"/>
+        </Console>
+
+        <Console name="console_err" target="SYSTEM_ERR">
+            <ThresholdFilter level="ERROR"/>
+            <PatternLayout charset="UTF-8" pattern="[%d{yyyy-MM-dd HH:mm:ss:SSS}] [%p] - %l - %m%n"/>
+        </Console>
+    </Appenders>
+    <Loggers>
+        <Root level="INFO">
+            <AppenderRef ref="console_err"/>
+            <AppenderRef ref="console_out"/>
+        </Root>
+    </Loggers>
+</Configuration>
\ No newline at end of file
diff --git a/test/e2e/validator/src/test/java/org/apache/skywalking/plugin/test/validator/validator/assertor/DataAssertIT.java b/test/e2e/validator/src/test/java/org/apache/skywalking/plugin/test/validator/validator/assertor/DataAssertIT.java
new file mode 100644
index 0000000..4b7377c
--- /dev/null
+++ b/test/e2e/validator/src/test/java/org/apache/skywalking/plugin/test/validator/validator/assertor/DataAssertIT.java
@@ -0,0 +1,114 @@
+/*
+ * 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.
+ */
+
+package org.apache.skywalking.plugin.test.validator.validator.assertor;
+
+import com.google.common.io.ByteStreams;
+import com.google.gson.Gson;
+import com.google.gson.JsonArray;
+import com.google.gson.JsonElement;
+import com.google.gson.JsonParser;
+import java.io.File;
+import java.io.IOException;
+import java.net.URL;
+import java.net.URLConnection;
+import java.nio.file.Files;
+import java.util.List;
+import java.util.concurrent.TimeUnit;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.skywalking.plugin.test.agent.tool.validator.assertor.DataAssert;
+import org.apache.skywalking.plugin.test.agent.tool.validator.assertor.exception.TypeUndefinedException;
+import org.apache.skywalking.plugin.test.agent.tool.validator.entity.Data;
+import org.apache.skywalking.plugin.test.agent.tool.validator.entity.DataForRead;
+import org.junit.Test;
+import org.yaml.snakeyaml.Yaml;
+
+@Slf4j
+public class DataAssertIT {
+    private static final Gson gson = new Gson();
+
+    @Test
+    public void testAssertFunction() throws InterruptedException, IOException, TypeUndefinedException {
+        TimeUnit.SECONDS.sleep(10L); // wait for agent registry
+
+        URLConnection connection = new URL(System.getProperty("ping.url")).openConnection();
+        connection.connect();
+        log.info("Http Response: {}", new String(ByteStreams.toByteArray(connection.getInputStream())));
+
+        TimeUnit.SECONDS.sleep(6L);
+
+        for (int times = 0; times < 30; times++) { // retry 30 times, that will spend 60s in the worst case.
+            final DataCollector collector = new DataCollector();
+            URL url = DataAssertIT.class.getResource("/logs/trace.log");
+            List<String> lines = Files.readAllLines(new File(url.getFile()).toPath());
+            log.info("lines : {}", lines.size());
+
+            for (int i = 0; i < lines.size() - 1; i++) {
+                String[] pair = lines.get(i).split(" ", 2);
+
+                JsonElement element = new JsonParser().parse(pair[1].replaceAll("\\\\", "").trim());
+                switch (pair[0]) {
+                    case Type.HEART_BEAT:
+                        break;
+                    case Type.SERVICE_REGISTER: {
+                        element.getAsJsonObject().get("services").getAsJsonArray().forEach(e -> {
+                            collector.serviceRegistry(e.getAsJsonObject().get("serviceName").getAsString());
+                        });
+                        break;
+                    }
+                    case Type.INSTANCE_REGISTER: {
+                        JsonArray instances = element.getAsJsonObject().getAsJsonArray("instances");
+                        instances.forEach(el -> {
+                            collector.instanceRegistry(el.getAsJsonObject().get("serviceId").getAsInt());
+                        });
+                        break;
+                    }
+                    case Type.SEGMENTS: {
+                        collector.addSegmentItem(element);
+                        break;
+                    }
+                    default: {
+                        throw new TypeUndefinedException("Type " + pair[0] + " undefined.");
+                    }
+                }
+            }
+
+            try {
+                if (!collector.hasSegments()) {
+                    throw new NullPointerException();
+                }
+
+                DataAssert.assertEquals(
+                    Data.Loader.loadData(DataCollector.class.getResourceAsStream("/expectedData.yaml")),
+                    Data.Loader.loadData(gson.toJson(collector.collect()))
+                );
+                return;
+            } catch (Exception e) {
+                TimeUnit.SECONDS.sleep(2L);
+                log.error(e.getMessage(), e);
+            }
+        }
+    }
+
+    static interface Type {
+        String HEART_BEAT = "/v2/instance/heartbeat";
+        String SEGMENTS = "/v2/segments";
+        String INSTANCE_REGISTER = "/v2/instance/register";
+        String SERVICE_REGISTER = "/v2/service/register";
+    }
+
+}
\ No newline at end of file
diff --git a/test/e2e/validator/src/test/java/org/apache/skywalking/plugin/test/validator/validator/assertor/DataCollector.java b/test/e2e/validator/src/test/java/org/apache/skywalking/plugin/test/validator/validator/assertor/DataCollector.java
new file mode 100644
index 0000000..7eb2669
--- /dev/null
+++ b/test/e2e/validator/src/test/java/org/apache/skywalking/plugin/test/validator/validator/assertor/DataCollector.java
@@ -0,0 +1,167 @@
+/*
+ * 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.
+ *
+ */
+
+package org.apache.skywalking.plugin.test.validator.validator.assertor;
+
+import com.google.common.collect.Lists;
+import com.google.common.collect.Maps;
+import com.google.gson.JsonArray;
+import com.google.gson.JsonElement;
+import com.google.gson.JsonObject;
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.skywalking.plugin.test.validator.validator.assertor.entity.ExpectedDataEntity;
+import org.apache.skywalking.plugin.test.validator.validator.assertor.entity.RegistryItemsEntity;
+
+@Slf4j
+public class DataCollector {
+    // For SegmentItems
+    private Map<String, List<JsonObject>> serviceAndSegments = Maps.newHashMap();
+
+    // For RegistryItems
+    private final Map<String, Integer> instanceMap = Maps.newHashMap();
+    private final Map<Integer, String> serviceMap = Maps.newHashMap();
+    private Map<String, List<String>> serviceAndOperations = Maps.newHashMap();
+    private int serviceIdGenerator = 0;
+
+    public DataCollector serviceRegistry(String serviceName) {
+        if (!serviceMap.containsValue(serviceName)) {
+            serviceMap.put(++serviceIdGenerator, serviceName);
+        }
+        return this;
+    }
+
+    public DataCollector instanceRegistry(int serviceId) {
+        String serviceName = serviceMap.get(serviceId);
+        instanceMap.put(serviceName, instanceMap.getOrDefault(serviceName, 0) + 1);
+        return this;
+    }
+
+    public DataCollector addSegmentItem(JsonElement element) {
+        final JsonElement spans = element.getAsJsonObject().get("spans");
+        if (spans.getAsJsonArray().size() == 0) {
+            return this;
+        }
+
+        try {
+            JsonObject segment = new JsonObject();
+            segment.addProperty("segmentId", "1.159.00000000000000000");
+            segment.add("spans", spans);
+
+            final int serviceId = element.getAsJsonObject().get("serviceId").getAsInt();
+            final String serviceName = serviceMap.get(serviceId);
+
+            spans.getAsJsonArray().forEach(span -> {
+                JsonObject jsonObject = span.getAsJsonObject();
+
+                // extract operation name
+                List<String> operations = serviceAndOperations.getOrDefault(serviceName, Lists.newArrayList());
+                operations.add(jsonObject.get("operationName").getAsString());
+                serviceAndOperations.put(serviceName, operations);
+
+                // remove unless properties
+                JsonElement refs = jsonObject.get("refs");
+                if (refs != null) {
+                    if (refs.isJsonObject()) {
+                        jsonObject.remove("refs");
+                    } else {
+                        refs.getAsJsonArray().forEach(el -> {
+                            el.getAsJsonObject().addProperty("parentTraceSegmentId", "parentTraceSegmentId");
+                        });
+                    }
+                }
+                JsonElement logs = jsonObject.get("logs");
+                if (logs != null) {
+                    if (logs.isJsonObject()) {
+                        jsonObject.remove("logs");
+                    }
+                }
+                JsonElement tags = jsonObject.get("tags");
+                if (tags != null) {
+                    if (tags.isJsonObject()) {
+                        jsonObject.remove("tags");
+                    }
+                }
+            });
+
+            List<JsonObject> segments = serviceAndSegments.getOrDefault(serviceName, Lists.newArrayList());
+            segments.add(segment);
+
+            serviceAndSegments.put(serviceName, segments);
+        } catch (Exception e) {
+            log.error(element.toString(), e);
+        }
+        return this;
+    }
+
+    public boolean hasSegments() {
+        return !serviceAndOperations.isEmpty();
+    }
+
+    public ExpectedDataEntity collect() {
+        RegistryItemsEntity registryItems = new RegistryItemsEntity();
+        registryItems.setInstances(getInstances());
+        registryItems.setApplications(getApplications());
+        registryItems.setOperationNames(getOperationNames());
+
+        ExpectedDataEntity entity = new ExpectedDataEntity();
+        entity.setRegistryItems(registryItems);
+        entity.setSegmentItems(getSegmentItems());
+        return entity;
+    }
+
+    private List<JsonObject> getSegmentItems() {
+        return serviceAndSegments.entrySet().stream().map(e -> {
+            JsonObject item = new JsonObject();
+            item.addProperty("serviceName", e.getKey());
+            item.addProperty("segmentSize", e.getValue().size());
+
+            List<JsonObject> values = e.getValue();
+            JsonArray elements = new JsonArray();
+            values.forEach(elements::add);
+            item.add("segments", elements);
+            return item;
+        }).collect(Collectors.toList());
+    }
+
+    private List<Map<String, List<String>>> getOperationNames() {
+        return serviceAndOperations.entrySet().stream().map(e -> {
+            Map<String, List<String>> instance = Maps.newHashMap();
+            instance.put(e.getKey(), e.getValue());
+            return instance;
+        }).collect(Collectors.toList());
+    }
+
+    private List<Map<String, Integer>> getInstances() {
+        return instanceMap.entrySet().stream().map(entry -> {
+            Map<String, Integer> instance = Maps.newHashMap();
+            instance.put(entry.getKey(), entry.getValue());
+            return instance;
+        }).collect(Collectors.toList());
+    }
+
+    private List<Map<String, Integer>> getApplications() {
+        return serviceMap.entrySet().stream().map(entry -> {
+            Map<String, Integer> instance = Maps.newHashMap();
+            instance.put(entry.getValue(), entry.getKey() + 1);
+            return instance;
+        }).collect(Collectors.toList());
+    }
+}
diff --git a/test/e2e/validator/src/test/java/org/apache/skywalking/plugin/test/validator/validator/assertor/entity/ExpectedDataEntity.java b/test/e2e/validator/src/test/java/org/apache/skywalking/plugin/test/validator/validator/assertor/entity/ExpectedDataEntity.java
new file mode 100644
index 0000000..c01a559
--- /dev/null
+++ b/test/e2e/validator/src/test/java/org/apache/skywalking/plugin/test/validator/validator/assertor/entity/ExpectedDataEntity.java
@@ -0,0 +1,29 @@
+/*
+ * 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.
+ *
+ */
+
+package org.apache.skywalking.plugin.test.validator.validator.assertor.entity;
+
+import com.google.gson.JsonObject;
+import java.util.List;
+import lombok.Data;
+
+@Data
+public class ExpectedDataEntity {
+    private RegistryItemsEntity registryItems;
+    private List<JsonObject> segmentItems;
+}
diff --git a/test/e2e/validator/src/test/java/org/apache/skywalking/plugin/test/validator/validator/assertor/entity/RegistryItemsEntity.java b/test/e2e/validator/src/test/java/org/apache/skywalking/plugin/test/validator/validator/assertor/entity/RegistryItemsEntity.java
new file mode 100644
index 0000000..aeb3948
--- /dev/null
+++ b/test/e2e/validator/src/test/java/org/apache/skywalking/plugin/test/validator/validator/assertor/entity/RegistryItemsEntity.java
@@ -0,0 +1,30 @@
+/*
+ * 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.
+ *
+ */
+
+package org.apache.skywalking.plugin.test.validator.validator.assertor.entity;
+
+import java.util.List;
+import java.util.Map;
+import lombok.Data;
+
+@Data
+public class RegistryItemsEntity {
+    private List<Map<String, Integer>> applications;
+    private List<Map<String, Integer>> instances;
+    private List<Map<String, List<String>>> operationNames;
+}
diff --git a/test/e2e/validator/src/test/resources/expectedData.yaml b/test/e2e/validator/src/test/resources/expectedData.yaml
new file mode 100644
index 0000000..96e6de0
--- /dev/null
+++ b/test/e2e/validator/src/test/resources/expectedData.yaml
@@ -0,0 +1,63 @@
+registryItems:
+  applications:
+    - {'User_Service_Name': 2}
+  instances:
+    - {'User_Service_Name': 1}
+  operationNames:
+    - User_Service_Name: [/tier2/lb, /tier2/lb, /ingress, /ingress]
+segmentItems:
+  - serviceName: User_Service_Name
+    segmentSize: eq 2
+    segments:
+      - segmentId: not null
+        spans:
+          - operationName: /tier2/lb
+            startTime: gt 0
+            endTime: gt 0
+            spanType: Exit
+            spanId: 1
+            isError: false
+            parentSpanId: 0
+            componentId: 6000
+            peer: 'User_Service_Name-nginx:upstream_ip:port'
+            spanLayer: HTTP
+          - operationName: /tier2/lb
+            startTime: gt 0
+            tags:
+              - {key: http.method, value: GET}
+              - {key: http.params, value: 'http://127.0.0.1/tier2/lb'}
+            endTime: gt 0
+            spanType: Entry
+            spanId: 0
+            isError: false
+            parentSpanId: -1
+            componentId: 6000
+            refs:
+              - {parentEndpointId: 0, entryEndpointId: 0, parentServiceInstanceId: 1, parentEndpoint: /ingress, parentTraceSegmentId: parentTraceSegmentId,
+                 networkAddress: '#User_Service_Name-nginx:upstream_ip:port', parentSpanId: 1,
+                 entryServiceInstanceId: 1, networkAddressId: 0, entryEndpoint: /ingress}
+            spanLayer: HTTP
+      - segmentId: not null
+        spans:
+          - operationName: /ingress
+            startTime: gt 0
+            endTime: gt 0
+            spanType: Exit
+            spanId: 1
+            isError: false
+            parentSpanId: 0
+            componentId: 6000
+            peer: 'User_Service_Name-nginx:upstream_ip:port'
+            spanLayer: HTTP
+          - operationName: /ingress
+            startTime: gt 0
+            tags:
+              - {key: http.method, value: GET}
+              - {key: http.params, value: 'not null'}
+            endTime: gt 0
+            spanType: Entry
+            spanId: 0
+            parentSpanId: -1
+            isError: false
+            spanLayer: HTTP
+            componentId: 6000
\ No newline at end of file