summaryrefslogtreecommitdiff
path: root/groot-formats
AgeCommit message (Collapse)Author
2024-05-03[Improve][test-e2e-kafka] Support error json format testdoufenghu
2024-04-26Merge remote-tracking branch 'origin/develop' into hotfix/arithmetic-operationschaochaoc
# Conflicts: # groot-bootstrap/pom.xml # groot-formats/pom.xml # groot-release/pom.xml # groot-release/src/main/assembly/assembly-bin-ci.xml # pom.xml
2024-04-22[improve][format-raw] GAL-550 Groot Stream Data Format支持Rawlifengchao
2024-04-22GAL-550 Groot Stream Data Format支持Rawlifengchao
2024-04-16[improve][format-msgpack] GAL-536 Groot Stream Data Format支持MessagePack ↵lifengchao
漏提factory文件
2024-04-11[improve][format-msgpack] GAL-536 Groot Stream Data Format支持MessagePacklifengchao
2024-03-13[feature][connector] GAL-508 Source/Sink Connector ↵lifengchao
支持引用外部的schema, ck sink支持http动态schema
2024-02-22[feature][connector-kafka] kafka ↵lifengchao
sink增加log.failures.only配置控制log发送失败是否抛出异常
2024-02-22[feature][connector-kafka][connector-clickhouse] GAL-486 kafka clickhouse ↵lifengchao
source sink输出Metrics
2024-01-27Fix some detailsdoufenghu
2024-01-23[feature][format-protobuf] groot-shaded实现改为简便方式。lifengchao
2024-01-20[Improve]doufenghu
[Bootstrap] - 按功能定义DataStream上的各个元素,包括Source/Sink connector,Filter Operator,Projection Processor - 优化任务配置校验,构建拓扑时对必需及至少任选一个参数进行校验 [Common] - 将Event,UDF,UDFContext 移至公共模块,便于引用继承 [Core] - ProjectionProcessFunction 不配置函数也可运行,用于定义下游事件支持部分字段筛选场景
2024-01-11[improve][core] print sink ↵lifengchao
支持数组data,支持配置发送数据数和每条数据延时
2024-01-09[feature][format-protobuf] 添加测试类和shaded实现。lifengchao
2024-01-04[feature][format-protobuf] 添加format-protobuf。lifengchao
2023-12-29[improve] [connector-kafka] 删除不引用的代码lifengchao
2023-12-22[fix] [format-json] TSG-18100 GrootStream ↵lifengchao
kafkasource反序列化数据处理逻辑修改
2023-12-07[fix][realease] add stop.sh and fix format-json not output lib directory.doufenghu
2023-12-01source dataType为null判断lifengchao
2023-12-01json formatlifengchao
2023-12-01GAL-442 优化Connector的source和sink接口lifengchao