| Age | Commit message (Collapse) | Author |
|
|
|
回滚CollectList和CollectSet,新增数组聚合函数ArrayContactAgg及相关单元测试
|
|
env.jars parameter to specify the plugin/third-parth JAR file path.
|
|
标识已过期,后续任务将被移除。修复了 Split side output 下游节点存在其他边无法正确构建拓扑的问题。
|
|
FilterProcessorFactory.The Factory add supportsType method for supporting legency type of avaitor.
|
|
依赖库梳理,xxExecutor删除不必要的参数传递。
|
|
增加groot-spi模块,解耦core和common模块之间的复杂依赖关系,移除一些不需要的类库。
|
|
|
|
|
|
improve output logic for exceptional criteria. Rename non-compliant classes and methods.
|
|
configuration checks by using a common validation utility.
|
|
Rename lookup_fields and output_fields to lookupFields and outputFields.
|
|
Feature/udf encrypt
See merge request galaxy/platform/groot-stream!123
|
|
|
|
|
|
record headers
|
|
[feature][core]删除原NumberMax,NumberMin。支持更通用的Max,Min函数。支持对日期/字符串/数字进行处理,考虑性能等因素,暂不支持识别字符串类型的日期。
See merge request galaxy/platform/groot-stream!118
|
|
数。支持对日期/字符串/数字进行处理,考虑性能等因素,暂不支持识别字符串类型的日期。
|
|
# Conflicts:
# config/udf.plugins
|
|
n_rule_metric任务以及单元测试
|
|
|
|
conventions.
|
|
|
|
the vault system.
|
|
|
|
PATH_UNROLL
|
|
encryption.
|
|
app-protocol-stat-traffic-merge application
|
|
stream相对应。rules中name标签修改为tag。完善单元测试,target_type新增test模式。
|
|
|
|
|
|
Stream支持在作业(Job)级别定义变量,修改命名,并统一存储至Flink grootstream.config
|
|
|
|
configuration data
|
|
Feature/split
See merge request galaxy/platform/groot-stream!95
|
|
|
|
Operator实现动态分流
|
|
|
|
|
|
Feature/table
See merge request galaxy/platform/groot-stream!92
|
|
|
|
|
|
[improve][core]拆分聚合函数open方法,较少调用次数,优化性能
See merge request galaxy/platform/groot-stream!91
|
|
|
|
|
|
[docs][core] add aggregate processor documents.
See merge request galaxy/platform/groot-stream!86
|
|
|
|
[improve][core]aggregate processor增加window_timestamp_field配置
See merge request galaxy/platform/groot-stream!85
|
|
|
|
[improve][core]新增聚合函数LongCount,Mean以及相关单元测试
See merge request galaxy/platform/groot-stream!79
|