diff options
| author | wangkuan <[email protected]> | 2024-09-10 17:14:50 +0800 |
|---|---|---|
| committer | wangkuan <[email protected]> | 2024-09-10 17:14:50 +0800 |
| commit | daf6ee08400b1102bb7e97af2c5663fc5cee24b4 (patch) | |
| tree | 0db262096e7f5f5681489ee406adb9a240dca071 /groot-core | |
| parent | e4047ae73ed837fcc931fd2dee45c7fca9741df4 (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.java | 2 |
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); } } |
