package
1.0.4
Repository: https://github.com/aceld/kis-flow.git
Documentation: pkg.go.dev

# Constants

C 为计算特征的KisFunction, 可以生成新的字段,计算新的值,进行数据的聚合,分析等.
metrics.
metrics.
DefaultExpiration 默认GoCahce时间 ,永久保存.
单位 min.
E 为扩展特征的KisFunction,作为流式计算的自定义特征Function,也同时是KisFlow当前流中的最后一个Function,概念类似Sink。.
No description provided by the author
不启动.
启动.
FunctionIdFirstVirtual 为首结点Function上一层虚拟的Function ID.
FunctionIdLastVirtual 为尾结点Function下一层虚拟的Function ID.
metrics.
metrics.
metrics.
metrics.
metrics.
metrics.
metrics.
metrics.
metrics.
metrics.
No description provided by the author
用户生成KisId的字符串前缀.
用户生成KisId的字符串前缀.
用户生成KisId的字符串前缀.
用户生成KisId的字符串前缀.
用户生成KisId的字符串前缀.
L 为加载特征的KisFunction,L会通过KisConnector进行数据加载,L Function 会通过KisConnector进行数据读取,具备相同Connector的Function可以从逻辑上与对应的S Function进行并流.
metrics.
metrics.
metrics.
metrics.
metrics.
No description provided by the author
No description provided by the author
S 为存储特征的KisFunction, S会通过KisConnector进行将数据进行存储.
No description provided by the author
V 为校验特征的KisFunction, 主要进行数据的过滤,验证,字段梳理,幂等等前置数据处理.

# Interfaces

KisRow 一行数据.

# Type aliases

No description provided by the author
KisDataMap 当前Flow承载的全部数据 key : 数据所在的Function ID value: 对应的KisRow */.
No description provided by the author
是否启动Flow */.
KisRowArr 一次业务的批量数据.