涉及到一些源码修改的地方-未完

￡神魔★判官ぃ 2022-12-14 13:53 85阅读 0赞

1，zeppelin的interpreter开发

思路：

可以直接参考修改FlinkInterpreter

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODY2Nzkz_size_16_color_FFFFFF_t_70][]

正常流程：

1） 创建子项目：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODY2Nzkz_size_16_color_FFFFFF_t_70 1][]

2）resource放入json文件

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODY2Nzkz_size_16_color_FFFFFF_t_70 2][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODY2Nzkz_size_16_color_FFFFFF_t_70 3][]

3）开发主类，关键就是继承Interpreter

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODY2Nzkz_size_16_color_FFFFFF_t_70 4][]

4）重新编译，推荐直接参考Flink interpreter修改

核心在于：

> public abstract class Interpreter \{  
>       
>   /\*\*  
>   \* 初始化的时候调用，可以在这个里面加一些系统初始化的工作，这个方法只调用一次。  
>   \* 写过flink自定义source和sink的同学应该不会陌生。  
>    \*/  
>   @ZeppelinApi  
>   public abstract void open() throws InterpreterException;  
>   
>   /\*\*  
>    \*   
>    \* 释放Interpreter资源，也只会被调用一次。  
>    \*/  
>   @ZeppelinApi  
>   public abstract void close() throws InterpreterException;  
>       
>     /\*\*  
>    \* 异步的运行输入框里面的代码并返回结果。.  
>    \*  
>    \* @param st 就是页面那个框里你输入的东西  
>    \*/  
>   @ZeppelinApi  
>   public abstract InterpreterResult interpret(String st,  
>                                               InterpreterContext context)  
>       throws InterpreterException;      
>       
> \}

参考：

[https://zeppelin.apache.org/docs/0.9.0-preview1/development/writing\_zeppelin\_interpreter.html][https_zeppelin.apache.org_docs_0.9.0-preview1_development_writing_zeppelin_interpreter.html]

[https://github.com/apache/zeppelin/tree/master/flink/interpreter/src/main/java/org/apache/zeppelin/flink][https_github.com_apache_zeppelin_tree_master_flink_interpreter_src_main_java_org_apache_zeppelin_flink]

[https://github.com/apache/zeppelin/blob/master/flink/interpreter/src/main/resources/interpreter-setting.json][https_github.com_apache_zeppelin_blob_master_flink_interpreter_src_main_resources_interpreter-setting.json]

[https://blog.csdn.net/weixin\_33785972/article/details/91719817][https_blog.csdn.net_weixin_33785972_article_details_91719817]

2，Flink CDC源码学习

思路：

参考：

[https://www.jianshu.com/p/22ab72c270cd][https_www.jianshu.com_p_22ab72c270cd]

3，Flink jdbcCatalog开发

思路：

参考：

[https://github.com/ververica/flink-cdc-connectors][https_github.com_ververica_flink-cdc-connectors]

[https://www.jianshu.com/p/aef22cf8e33f][https_www.jianshu.com_p_aef22cf8e33f]

4，

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODY2Nzkz_size_16_color_FFFFFF_t_70]: /images/20221123/5c4cddd786764c90a6c2208b9b4553b0.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODY2Nzkz_size_16_color_FFFFFF_t_70 1]: /images/20221123/0c1c3a34ee09489183533ae9aac3205a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODY2Nzkz_size_16_color_FFFFFF_t_70 2]: /images/20221123/6d4bc02797784f48874227413540ed5e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODY2Nzkz_size_16_color_FFFFFF_t_70 3]: /images/20221123/d79ba50a2d454e499edf487d92c13be9.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMxODY2Nzkz_size_16_color_FFFFFF_t_70 4]: /images/20221123/df258ec3182d4c5cba2ffaf85473b6f2.png
[https_zeppelin.apache.org_docs_0.9.0-preview1_development_writing_zeppelin_interpreter.html]: https://zeppelin.apache.org/docs/0.9.0-preview1/development/writing_zeppelin_interpreter.html
[https_github.com_apache_zeppelin_tree_master_flink_interpreter_src_main_java_org_apache_zeppelin_flink]: https://github.com/apache/zeppelin/tree/master/flink/interpreter/src/main/java/org/apache/zeppelin/flink
[https_github.com_apache_zeppelin_blob_master_flink_interpreter_src_main_resources_interpreter-setting.json]: https://github.com/apache/zeppelin/blob/master/flink/interpreter/src/main/resources/interpreter-setting.json
[https_blog.csdn.net_weixin_33785972_article_details_91719817]: https://blog.csdn.net/weixin_33785972/article/details/91719817
[https_www.jianshu.com_p_22ab72c270cd]: https://www.jianshu.com/p/22ab72c270cd
[https_github.com_ververica_flink-cdc-connectors]: https://github.com/ververica/flink-cdc-connectors
[https_www.jianshu.com_p_aef22cf8e33f]: https://www.jianshu.com/p/aef22cf8e33f