标签：String app Castled private connector 源码 NotNull WarehousePollContext 定义

connector模块中的WarehousePollContext是比较重要的

代码说明

• 关于pipeline 格式的定义
  了解pipeline格式定义，对于分析后边的代码是很有意义的,可以知道依赖的模块

 

public class PipelineConfigDTO {

 

    @NotNull

    private String name; // 名称

 

    @NotNull

    private JobSchedule schedule; // 调度信息，主要是关于任务调度的

 

    @NotNull

    private Long appId; // 关联的appid，外部服务在Castled 中称之为app

 

    @NotNull

    private Long warehouseId; // 配置的warehouse 定义

 

    @NotNull

    private String sourceQuery; // 数据查询sql

 

    @NotNull

    private QueryMode queryMode; // 处理模式，全量以及增量

 

    private AppSyncConfig appSyncConfig; // 关于app 的一些配置，从定义上来说属于重复定义，因为appid 可以代表

 

    private CastledDataMapping mapping; //  datawarehouse 与app 的数据schema 映射处理（基于了cfl处理）同时注意Castled 是需要主键的，这个在好多reverse ETL 都有说明

 

}

• WarehousePollContext定义
  WarehousePollContext 在poller 中是比较重要的，poller大部分都是需要依赖此对象的数据进行处理的，依赖上边定义的pipeline参数

 

public class WarehousePollContext {

 

    private WarehouseConfig warehouseConfig;

    private List<String> primaryKeys;

    private String query;

 

    private QueryMode queryMode;

 

    //uuid and not the incrementing id;

    private String pipelineUUID;

 

    private Long pipelineId;

    private Long pipelineRunId;

 

    private String dataEncryptionKey;

 

    private RecordSchema warehouseSchema;

}

说明

pipeline 以及context 是将app 以及poller 关联的对象，是比较重要的，后续web app 会用到这些

参考资料

https://github.com/castledio/castled
https://oss-docs.castled.io/

标签：String,app,Castled,private,connector,源码,NotNull,WarehousePollContext,定义
来源： https://www.cnblogs.com/rongfengliang/p/15858706.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。