[feature][core] TSG-22596 add EXPLODE_APP_AND_PROTOCOL function for app-protocol-stat-traffic-merge application

2 files changed, 16 insertions, 3 deletions

diff --git a/groot-connectors/connector-mock/src/main/java/com/geedgenetworks/connectors/mock/faker/FakerUtils.java b/groot-connectors/connector-mock/src/main/java/com/geedgenetworks/connectors/mock/faker/FakerUtils.java
index 5101fa1..0a36100 100644
--- a/groot-connectors/connector-mock/src/main/java/com/geedgenetworks/connectors/mock/faker/FakerUtils.java
+++ b/groot-connectors/connector-mock/src/main/java/com/geedgenetworks/connectors/mock/faker/FakerUtils.java
@@ -165,7 +165,8 @@ public class FakerUtils {
     private static Faker<?> parseSequenceFaker(JSONObject obj) {

         long start = obj.getLongValue("start", 0L);

         long step = obj.getLongValue("step", 1L);

-        return new SequenceFaker(start, step);

+        int batch = obj.getIntValue("batch", 1);

+        return new SequenceFaker(start, step, batch);

     }

 

     private static Faker<?> parseStringFaker(JSONObject obj) {

diff --git a/groot-connectors/connector-mock/src/main/java/com/geedgenetworks/connectors/mock/faker/SequenceFaker.java b/groot-connectors/connector-mock/src/main/java/com/geedgenetworks/connectors/mock/faker/SequenceFaker.java
index 0005234..867f138 100644
--- a/groot-connectors/connector-mock/src/main/java/com/geedgenetworks/connectors/mock/faker/SequenceFaker.java
+++ b/groot-connectors/connector-mock/src/main/java/com/geedgenetworks/connectors/mock/faker/SequenceFaker.java
@@ -3,22 +3,34 @@ package com.geedgenetworks.connectors.mock.faker;
 public class SequenceFaker extends Faker<Long> {

     private final long start;

     private final long step;

+    private final int batch;

     private long value;

+    private int cnt;

 

     public SequenceFaker(long start) {

-        this(start, 1);

+        this(start, 1, 1);

     }

 

     public SequenceFaker(long start, long step) {

+        this(start, step, 1);

+    }

+

+    public SequenceFaker(long start, long step, int batch) {

         this.start = start;

         this.step = step;

+        this.batch = batch;

         this.value = start;

+        this.cnt = 0;

     }

 

     @Override

     public Long geneValue() throws Exception {

         Long rst = value;

-        value += step;

+        cnt++;

+        if(cnt == batch){

+            cnt = 0;

+            value += step;

+        }

         return rst;

     }