summaryrefslogtreecommitdiff
path: root/groot-core
diff options
context:
space:
mode:
authorwangkuan <[email protected]>2024-09-10 17:14:50 +0800
committerwangkuan <[email protected]>2024-09-10 17:14:50 +0800
commitdaf6ee08400b1102bb7e97af2c5663fc5cee24b4 (patch)
tree0db262096e7f5f5681489ee406adb9a240dca071 /groot-core
parente4047ae73ed837fcc931fd2dee45c7fca9741df4 (diff)
[feature][bootstrap][common]node新增tags属性用于分流,需要与downstream相对应。rules中name标签修改为tag。完善单元测试,target_type新增test模式。
Diffstat (limited to 'groot-core')
-rw-r--r--groot-core/src/main/java/com/geedgenetworks/core/split/SplitFunction.java2
1 files changed, 1 insertions, 1 deletions
diff --git a/groot-core/src/main/java/com/geedgenetworks/core/split/SplitFunction.java b/groot-core/src/main/java/com/geedgenetworks/core/split/SplitFunction.java
index f07b568..07d4f9f 100644
--- a/groot-core/src/main/java/com/geedgenetworks/core/split/SplitFunction.java
+++ b/groot-core/src/main/java/com/geedgenetworks/core/split/SplitFunction.java
@@ -43,7 +43,7 @@ public class SplitFunction extends ProcessFunction<Event, Event> {
instance.setFunctionMissing(null);
Expression compiledExp = instance.compile(expression, true);
rule.setCompiledExpression(compiledExp);
- OutputTag<Event> outputTag = new OutputTag<>(rule.getName()){};
+ OutputTag<Event> outputTag = new OutputTag<>(rule.getTag()){};
rule.setOutputTag(outputTag);
}
}