summaryrefslogtreecommitdiff
path: root/groot-bootstrap
AgeCommit message (Collapse)Author
2024-11-26[feature][core]CN-1730 ↵wangkuan
回滚CollectList和CollectSet,新增数组聚合函数ArrayContactAgg及相关单元测试
2024-11-23[Improve][bootstrap] Enhance the dynamic loading of JAR files by configuring ↵doufenghu
env.jars parameter to specify the plugin/third-parth JAR file path.
2024-11-21[feature][core]CN-1730 ↵wangkuan
拓展CollectList和CollectSet,增加collect_type配置项用于区分对每个array元素或整个object聚合
2024-11-18[Improve][bootstrap] ↵lifengchao
删除getInputNode方法，直接参数中直接传入inputNode参数
2024-11-18[fix][core][api]解决udfEntity重命名冲突wangkuan
2024-11-18Merge branch 'develop' into 'fix/aviator-expression'王宽
# Conflicts: # groot-core/src/main/java/com/geedgenetworks/core/processor/aggregate/AbstractFirstAggregation.java # groot-core/src/main/java/com/geedgenetworks/core/processor/aggregate/AggregateProcessorFunction.java # groot-core/src/main/java/com/geedgenetworks/core/processor/projection/ProjectionProcessFunction.java
2024-11-18[fix][core][api]统一Aviator表达式语法和调用方式,所有processor� ↵wangkuan
��函数使用表达式不需要使用event.字段名。
2024-11-16[Improve][core] Preprocessing 和 postprocessing ↵doufenghu
标识已过期，后续任务将被移除。修复了 Split side output 下游节点存在其他边无法正确构建拓扑的问题。
2024-11-14[Improve][bootstrap] OperatorType has been renamed to JobStage, defined as a ↵doufenghu
job stream processing stage. Each stage can be configured with multiple types of operators.
2024-11-14[Feature][api] AviatorFilterProcessorFactory renamed to ↵doufenghu
FilterProcessorFactory.The Factory add supportsType method for supporting legency type of avaitor.
2024-11-13[Feature][SPI] ↵lifengchao
Factory接口只保留type方法；包位置移动；连接器类名xxTableFactory改为xxConnectorFactory
2024-11-13[Feature][API] 统一Operator实例生成接口为Factory. Connector Factory ↵doufenghu
Identifier 统一为type，与任务配置文件保持一致.
2024-11-10[Feature][SPI] SPI/Common module ↵doufenghu
依赖库梳理，xxExecutor删除不必要的参数传递。
2024-11-09[Feature][SPI] ↵doufenghu
增加groot-spi模块，解耦core和common模块之间的复杂依赖关系，移除一些不需要的类库。
2024-10-31Merge branch 'feature/format_csv' into 'develop'李奉超
[feature][format-csv]GAL-687 Groot Stream 支持CSV Format See merge request galaxy/platform/groot-stream!127
2024-10-31[feature][format-csv]GAL-687 Groot Stream 支持CSV Formatlifengchao
2024-10-30Merge branch 'improve/udf-config-check' into 'develop'窦凤虎
[Improve][core] Add CheckUDFContextUtil for verifying UDF configurations.... See merge request galaxy/platform/groot-stream!126
2024-10-30[fix][core] Encrypt函数适配网关动态获取加密字段接口侯晋川
2024-10-29[Improve][core] Add CheckUDFContextUtil for verifying UDF configurations. ↵doufenghu
Rename lookup_fields and output_fields to lookupFields and outputFields.
2024-10-28Merge branch 'feature/udf-encrypt' into 'develop'李奉超
Feature/udf encrypt See merge request galaxy/platform/groot-stream!123
2024-10-28[feature][core] 优化Encrypt和HMAC函数。新增Encrypt单元测试feature/udf-encrypt侯晋川
2024-10-25[feature][core]新增Encrypt和HMAC函数侯晋川
2024-10-25[feature][pack]支持外部自定义processor,filter,split。将配置检查 ↵wangkuan
功能解耦，放在具体算子中进行。
2024-10-22Merge branch 'feature/max-min' into 'develop'王宽
[feature][core]删除原NumberMax，NumberMin。支持更通用的Max,Min函数。支持对日期/字符串/数字进行处理，考虑性能等因素，暂不支持识别字符串类型的日期。 See merge request galaxy/platform/groot-stream!118
2024-10-22[feature][core]删除原NumberMax，NumberMin。支持更通用的Max,Min函 ↵feature/max-minwangkuan
数。支持对日期/字符串/数字进行处理，考虑性能等因素，暂不支持识别字符串类型的日期。
2024-10-22Merge branch 'fix/udfs' into 'develop'王宽
[fix][core]BASE64_ENCODE_TO_STRING函数新增参数input_type,支持string,byte_array,原value_... See merge request galaxy/platform/groot-stream!117
2024-10-22[fix][core]BASE64_ENCODE_TO_STRING函数新增参数input_type,支持string, ↵fix/udfswangkuan
byte_array,原value_field由lookup_fields替代。FROM_UNIX_TIMESTAMP修改毫秒时间格式为yyyy-MM-dd HH:mm:ss.SSS
2024-10-21Merge branch 'develop' into 'feature/dos'feature/dos王宽
# Conflicts: # config/udf.plugins
2024-10-21[feature][core]新增聚合函数NumberMax,NumberMin,增加agg-dos-protectio ↵wangkuan
n_rule_metric任务以及单元测试
2024-10-14Merge branch 'feature/udf-uuid' into 'develop'王宽
Feature/udf uuid See merge request galaxy/platform/groot-stream!114
2024-10-11[improve][core]UuidV5函数多个字段之间采用"_"拼接wangkuan
2024-10-11GAL-660 支持StarRocks Sinklifengchao
2024-10-10[improve][bootstrap]新增UUID单元测试wangkuan
2024-09-13[Improve][Common] Rename ConfigShade to CryptoShade for better describe data ↵doufenghu
encryption.
2024-09-13[fix][core]修复预聚合功能相关bug，增加测试用例wangkuan
2024-09-10[improve][test]单元测试类重命名feature/split-tagwangkuan
2024-09-10[improve][test]修改配置文件名称wangkuan
2024-09-10[feature][bootstrap][common]node新增tags属性用于分流，需要与down ↵wangkuan
stream相对应。rules中name标签修改为tag。完善单元测试,target_type新增test模式。
2024-09-04[improve][bootstrap]单元测试配置文件适配properties变更improve/splitwangkuan
2024-09-04[improve][bootstrap]优化代码，修改splitsset位置，单元测试适� ↵wangkuan
�properties配置变更
2024-09-02[Fix][e2e-common] Support user-defined variables via CLI when submitting a job.doufenghu
2024-09-01[Improve][bootstrap] Improve job-level user-defined variables, move the path ↵doufenghu
from application/properties to application/env/properties, and add support for defining variables via the runtime CLI. (GAL-651)
2024-08-30[improve][bootstrap][core]完善监控输出及单元测试,修改部分问题feature/pre-aggwangkuan
2024-08-29[feature][bootstrap][core]增加预聚合功能,相关函数支持mergewangkuan
2024-08-29[improve][bootstrap] GAL-651 Groot ↵feature/task-propertieswangkuan
Stream支持在作业(Job)级别定义变量,修改命名，并统一存储至Flink grootstream.config
2024-08-28[feature][bootstrap][common] GAL-651 Groot Stream支持配置task propertieswangkuan
2024-08-27[feature][bootstrap]Add the SM4 algorithm for encrypting sensitive ↵doufenghu
configuration data
2024-08-26[feature][core][common]单元测试优化，命名优化feature/splitwangkuan
2024-08-23[feature][core][common]GAL-646 Groot Stream支持Split ↵wangkuan
Operator实现动态分流
2024-08-15[docs][udf] Update scalar UDFs, user-defined aggregate functions (UDAFs) ↵doufenghu
description.
generated by cgit v1.2.3 (git 2.39.1) at 2025-12-30 13:32:26 +0000