| Age | Commit message (Collapse) | Author |
|
|
|
回滚CollectList和CollectSet,新增数组聚合函数ArrayContactAgg及相关单元测试
|
|
|
|
Feature/udf encrypt
See merge request galaxy/platform/groot-stream!123
|
|
|
|
|
|
[feature][core]删除原NumberMax,NumberMin。支持更通用的Max,Min函数。支持对日期/字符串/数字进行处理,考虑性能等因素,暂不支持识别字符串类型的日期。
See merge request galaxy/platform/groot-stream!118
|
|
数。支持对日期/字符串/数字进行处理,考虑性能等因素,暂不支持识别字符串类型的日期。
|
|
# Conflicts:
# config/udf.plugins
|
|
n_rule_metric任务以及单元测试
|
|
|
|
conventions.
|
|
PATH_UNROLL
|
|
app-protocol-stat-traffic-merge application
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
�名为scalarFunction,时间戳转换函数支持设置interval
|
|
函数增加分钟级别转换
|
|
|
|
|
|
与GENERATE_STRING_ARRAY
|
|
Rename作为内置UDF函数,按英文首字母排列UDF注册列表。新增kafka_to_print, inline_to_print配置模版,使其集成测试更高效。
|
|
|
|
|
|
|
|
��命名为CurrentUnixTimestamp。
|
|
�加默认参数的方式加载全局配置文件和UDF配置。
|
|
|
|
�取方式相同,修改配置文件名
|
|
|
|
|
|
增加定时任务工具类,部分udf优化,tsg任务所有功能配置,grootstream全局参数修改(暂时只修改配置文件,没有去掉engine待讨论)
|
|
|
|
�补全函数,知识库调度任务工具类开发(待优化)
|
|
函数待持续优化)
|
|
动态读取配置文件,以JSON方式存储到GlobalJobParameters
|
|
|
|
|
|
��暂移除注册列表
|
|
重命名UDF,初始化方法修改为init。传递数据改为UDFContext,提供除输入参数外及其它执行相关信息。
|
|
�为便于测试,暂时对groot-bootstrap基于shade封装各个模块打一个jar包。
|
|
�立打包,去掉函数注册main_class
|