From 8ed1398ad9c939303b83a5858830fc367c5d8538 Mon Sep 17 00:00:00 2001 From: aceld Date: Thu, 28 Mar 2024 14:57:35 +0800 Subject: [PATCH] update --- common/const.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/common/const.go b/common/const.go index 9fcaa13..238730c 100644 --- a/common/const.go +++ b/common/const.go @@ -24,16 +24,16 @@ const ( // V 为校验特征的KisFunction, 主要进行数据的过滤，验证，字段梳理，幂等等前置数据处理 V KisMode = "Verify" - // S 为存储特征的KisFunction, S会通过NsConnector进行将数据进行存储，数据的临时声明周期为NsWindow + // S 为存储特征的KisFunction, S会通过KisConnector进行将数据进行存储. S Function 会通过KisConnector进行数据存储,具备相同Connector的Function在逻辑上可以进行并流 S KisMode = "Save" - // L 为加载特征的KisFunction，L会通过KisConnector进行数据加载，通过该Function可以从逻辑上与对应的S Function进行并流 + // L 为加载特征的KisFunction，L会通过KisConnector进行数据加载，L Function 会通过KisConnector进行数据读取，具备相同Connector的Function可以从逻辑上与对应的S Function进行并流 L KisMode = "Load" - // C 为计算特征的KisFunction, C会通过KisFlow中的数据计算，生成新的字段，将数据流传递给下游S进行存储，或者自己也已直接通过KisConnector进行存储 + // C 为计算特征的KisFunction, 可以生成新的字段，计算新的值，进行数据的聚合，分析等 C KisMode = "Calculate" - // E 为扩展特征的KisFunction，作为流式计算的自定义特征Function，如，Notify 调度器触发任务的消息发送，删除一些数据，重置状态等。 + // E 为扩展特征的KisFunction，作为流式计算的自定义特征Function，也同时是KisFlow当前流中的最后一个Function，概念类似Sink。 E KisMode = "Expand" )