| Age | Commit message (Collapse) | Author |
|
|
|
回滚CollectList和CollectSet,新增数组聚合函数ArrayContactAgg及相关单元测试
|
|
��函数使用表达式不需要使用event.字段名。
|
|
Identifier 统一为type,与任务配置文件保持一致.
|
|
|
|
|
|
improve output logic for exceptional criteria. Rename non-compliant classes and methods.
|
|
Feature/udf encrypt
See merge request galaxy/platform/groot-stream!123
|
|
|
|
的function
|
|
|
|
[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
|
|
app-protocol-stat-traffic-merge application
|
|
https://git.mesalab.cn/galaxy/platform/groot-stream into fix/bootstrap
|
|
stream相对应。rules中name标签修改为tag。完善单元测试,target_type新增test模式。
|
|
|
|
from application/properties to application/env/properties, and add support for defining variables via the runtime CLI. (GAL-651)
|
|
|
|
|
|
configuration data
|
|
Feature/split
See merge request galaxy/platform/groot-stream!95
|
|
Operator实现动态分流
|
|
|
|
|
|
|
|
|
|
|
|
|
|
[improve][core]aggregate processor增加window_timestamp_field配置
See merge request galaxy/platform/groot-stream!85
|
|
|
|
[Feature][e2e-kafka] Flink image add flink-shaded-hadoop-2-uber-2.7.5-8.0.jar....
See merge request galaxy/platform/groot-stream!82
|
|
[improve][core]增加聚合函数LAST_VALUE和FIRST_VALUE
See merge request galaxy/platform/groot-stream!81
|
|
|
|
[improve][core]新增聚合函数LongCount,Mean以及相关单元测试
See merge request galaxy/platform/groot-stream!79
|
|
|
|
flink-shaded-hadoop-2-uber-2.7.5-8.0.jar. Add mock data to kafka integration test.
|
|
[feature][bootstrap][core][common]支持自定义聚合函数,udf接口重命名为scalarFunction,时间戳转换函数支持设置interval
See merge request galaxy/platform/groot-stream!78
|
|
�名为scalarFunction,时间戳转换函数支持设置interval
|