| Age | Commit message (Collapse) | Author |
|
[Improve][core] Add CheckUDFContextUtil for verifying UDF configurations....
See merge request galaxy/platform/groot-stream!126
|
|
|
|
Rename lookup_fields and output_fields to lookupFields and outputFields.
|
|
Feature/udf encrypt
See merge request galaxy/platform/groot-stream!123
|
|
|
|
|
|
功能解耦,放在具体算子中进行。
|
|
数。支持对日期/字符串/数字进行处理,考虑性能等因素,暂不支持识别字符串类型的日期。
|
|
byte_array,原value_field由lookup_fields替代。FROM_UNIX_TIMESTAMP修改毫秒时间格式为yyyy-MM-dd HH:mm:ss.SSS
|
|
n_rule_metric任务以及单元测试
|
|
|
|
|
|
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
|
|
|
|
支持引用外部的schema, ck sink支持http动态schema
|
|
|
|
to get current version.
|
|
# Conflicts:
# groot-bootstrap/src/test/java/com/geedgenetworks/bootstrap/main/simple/SimpleJobTest.java
|