在上一篇文章《Zepplin如何下载第三方依赖包?》讲解了zeppelin是如何下载第三方依赖的。本文讲讲这些依赖包如何和Flink进行交互?
通过源码阅读,可以查到,总结如下图:
FlinkScalaInterpreter是FlinkInterpreter的子类,在open方法中下载依赖包,在interpret方法中加载到类路径。看看FlinkInterpreter的interpret源码:
@Override
public InterpreterResult interpret(<