| Age | Commit message (Collapse) | Author |
|---|
|
operators.
|
|
标识已过期，后续任务将被移除。修复了 Split side output 下游节点存在其他边无法正确构建拓扑的问题。
|
|
FilterProcessorFactory.The Factory add supportsType method for supporting legency type of avaitor.
|
|
Feature/spi
See merge request galaxy/platform/groot-stream!136
|
|
Identifier 统一为type，与任务配置文件保持一致.
|
|
依赖库梳理，xxExecutor删除不必要的参数传递。
|
|
|
|
|
|
# Conflicts:
# pom.xml
|
|
|
|
improve output logic for exceptional criteria. Rename non-compliant classes and methods.
|
|
# Conflicts:
# groot-examples/end-to-end-example/src/main/resources/examples/inline_to_print_test.yaml
# pom.xml
|
|
configuration checks by using a common validation utility.
|
|
Rename lookup_fields and output_fields to lookupFields and outputFields.
|
|
|
|
test topology.
|
|
|
|
conventions.
|
|
|
|
the vault system.
|
|
# Conflicts:
# pom.xml
|
|
|
|
encryption.
|
|
[fix][core]修复预聚合功能相关bug，增加测试用例
See merge request galaxy/platform/groot-stream!108
|
|
|
|
|
|
from application/properties to application/env/properties, and add support for defining variables via the runtime CLI. (GAL-651)
|
|
|
|
|
|
|
|
description.
|
|
Flink job
|
|
|
|
configuration data
|
|
|
|
|
|
|
|
description.
|
|
Feature/e2e clickhouse
See merge request galaxy/platform/groot-stream!89
|
|
Flink job
|
|
|
|
|
|
flink-shaded-hadoop-2-uber-2.7.5-8.0.jar. Add mock data to kafka integration test.
|
|
longer executed by default during the mvn compile and deploy process. In the job template for processor and filter, describe the implementation type based on identifiers.
|
|
|
|
|
|
|
|
|
|
|
|
|
