| Age | Commit message (Collapse) | Author |
|
|
|
|
|
# Conflicts:
# config/udf.plugins
|
|
n_rule_metric任务以及单元测试
|
|
Feature/udf uuid
See merge request galaxy/platform/groot-stream!114
|
|
|
|
|
|
|
|
encryption.
|
|
|
|
|
|
|
|
stream相对应。rules中name标签修改为tag。完善单元测试,target_type新增test模式。
|
|
|
|
�properties配置变更
|
|
|
|
from application/properties to application/env/properties, and add support for defining variables via the runtime CLI. (GAL-651)
|
|
|
|
|
|
Stream支持在作业(Job)级别定义变量,修改命名,并统一存储至Flink grootstream.config
|
|
|
|
configuration data
|
|
|
|
Operator实现动态分流
|
|
description.
|
|
[feature][core][common][bootstrap]支持tableProcessor,增加UnRoll函数
See merge request galaxy/platform/groot-stream!90
|
|
|
|
Feature/e2e clickhouse
See merge request galaxy/platform/groot-stream!89
|
|
Flink job
|
|
Feature/aggregate
See merge request galaxy/platform/groot-stream!87
|
|
|
|
[feature][bootstrap][core][common]支持自定义聚合函数,udf接口重命名为scalarFunction,时间戳转换函数支持设置interval
See merge request galaxy/platform/groot-stream!78
|
|
�名为scalarFunction,时间戳转换函数支持设置interval
|
|
|
|
Stream各个处理阶段Type命名与实现类解耦,实例通过spi方式注册,兼容旧版本
|
|
|
|
��元测试
|
|
|
|
|
|
|
|
|
|
|
|
sl.truststore.password),(kafka.ssl.truststore.password)
|
|
|
|
Feature/testcontainers
See merge request galaxy/platform/groot-stream!25
|
|
|
|
Improve/knowledgebase
See merge request galaxy/platform/groot-stream!24
|
|
|
|
支持引用外部的schema, ck sink支持http动态schema
|
|
|