一种基于Flink的实时SQL扩展处理方法及装置

摘要

本发明提供了一种基于Flink的实时SQL扩展处理方法及装置，其中方法包括：获取SQL语句信息；将SQL语句信息进行分类；如果为SourceTable，则对SQL语句信息进行第一解析，生成SourceTableInfo；根据解析出的SourceTableInfo，创建kafka连接；如果为SideTable，则对SQL语句信息进行第二解析，生成SideTableInfo；根据解析出的SideTableInfo，读取缓存策略属性；如果为SinkTable，则对SQL语句信息进行第三解析，生成SinkTableInfo；根据解析出的SinkTableInfo，创建输出方式；提交到Flink集群。