summaryrefslogtreecommitdiff
path: root/groot-formats
AgeCommit message (Collapse)Author
2024-11-18[Improve][format] format添加测试lifengchao
2024-11-18[fix][core][api]统一Aviator表达式语法和调用方式,所有processor� ↵wangkuan
��函数使用表达式不需要使用event.字段名。
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-31[feature][format-csv]GAL-687 Groot Stream 支持CSV Formatlifengchao
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