Flink janino，跟老铁又学到了

快来打我* 2022-09-10 15:21 205阅读 0赞

1，janino在flink-table里面有![watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA6buE55Oc54KW5ZWk6YWS6bit_size_20_color_FFFFFF_t_70_g_se_x_16][]

2，它的功能其实跟AviatorEvaluator 类似，我们还有对两者的用法 跟功能做对比。

3，找找相关的文档：

[https://blog.csdn.net/inrgihc/article/details/104399439/][https_blog.csdn.net_inrgihc_article_details_104399439]

Janino 是一个极小、极快的 开源Java 编译器（Janino is a super-small, super-fast Java™ compiler.）。Janino 不仅可以像 JAVAC 一样将 Java 源码文件编译为字节码文件，还可以编译内存中的 Java 表达式、块、类和源码文件，加载字节码并在 JVM 中直接执行。Janino 同样可以用于静态代码分析和代码操作。

项目地址：https://github.com/janino-compiler/janino

官网地址：http://janino-compiler.github.io/janino/

4，Janino可以用于flink cep的规则校验匹配，多一个方式多点知识嘛，毕竟Flink用的东西不会太差吧。

老铁的案例：

package com.sjb.cep;
    
    
    
    import org.codehaus.commons.compiler.IScriptEvaluator;
    import org.codehaus.janino.ExpressionEvaluator;
    import org.codehaus.janino.ScriptEvaluator;
    
    public class JaninoTest {
    
        public static void main(String[] args) {
    
            try {
                String content="System.out.println(\"Hello world\");";
                IScriptEvaluator evaluator = new ScriptEvaluator();
                evaluator.cook(content);
                evaluator.evaluate(null);
    
                String express = "0 > 1";
                ExpressionEvaluator evaluator1 = new ExpressionEvaluator();
                evaluator1.cook(express);
                Object res = evaluator1.evaluate(null);
                System.out.println(express + " = " + res);
    
                IScriptEvaluator se = new ScriptEvaluator();
                se.setReturnType(Event.class);
                se.cook("import com.sjb.cep.Event; "
                        + "Event o= new Event(\"1\",1000L,\"\"); "
                        + "return o; ");
    
                String express1 = "o.type != null && o.id.equals(\"java开发指南\") ";
                ExpressionEvaluator evaluator2 = new ExpressionEvaluator();
                evaluator2.setExpressionType(Boolean.class);
                evaluator2.setParameters(new String[] { "o" }, new Class[] { Event.class });
                evaluator2.cook(express1);
    
                Event event = new Event("java开发指南",2L,"");
                Object res1 = evaluator2.evaluate(new Object[]{event});
                System.out.println(express1 + " = " + res1);
    
    
    
            } catch (Exception e) {
                e.printStackTrace();
            }
    
        }
    
    }

实体类：

![watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA6buE55Oc54KW5ZWk6YWS6bit_size_20_color_FFFFFF_t_70_g_se_x_16 1][]

[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA6buE55Oc54KW5ZWk6YWS6bit_size_20_color_FFFFFF_t_70_g_se_x_16]: /images/20220829/d4a2874737034e5896cc437fcedb5eb3.png
[https_blog.csdn.net_inrgihc_article_details_104399439]: https://blog.csdn.net/inrgihc/article/details/104399439/
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA6buE55Oc54KW5ZWk6YWS6bit_size_20_color_FFFFFF_t_70_g_se_x_16 1]: /images/20220829/e68bec0f70954f3b8a571d042263a593.png