aviatorscript
aviatorscript copied to clipboard
flink等分布式计算框架中无法序列化
flink等分布式计算框架中无法序列化
Expression无法序列化,不过现在使用AviatorEvaluator.execute也可以实现需求
我们最近也打算在flink里面嵌入脚本引擎,把经常变动的计算逻辑抽取出来,会涉及到一些自定义函数。 请教下你们咋用的,自定义函数如何处理的?
@ZuoYiGeYouMuBiaoDeRen 你是怎么用的呢?可以在 flink 的 richfunction 的 open 方法中使用
v5.4.1 支持序列化 https://github.com/killme2008/aviatorscript/releases/tag/aviator-5.4.1
例子
https://github.com/killme2008/aviatorscript/blob/master/src/test/java/com/googlecode/aviator/example/SerializeExample.java