sql where 相等条件会生成怎么的代码

当使用 SQL 的 WHERE 子句中的等值条件时，Flink 会将其转换为 Flink 内部的表达式对象，并在代码生成阶段将其编译为字节码。

例如，假设有以下 SQL 语句：

SELECT * FROM myTable WHERE id = 123

Flink 会将等值条件 `id = 123` 转换为 Flink 内部的表达式对象，例如：

Expression equalsExpr = equal(field("id"), literal(123));

其中，`field("id")` 表示获取名为 `id` 的字段，`literal(123)` 表示常量表达式 `123`。`equal()` 函数表示比较两个表达式是否相等，返回一个布尔型表达式。

在代码生成阶段，Flink 会将上述表达式编译为字节码，并嵌入到生成的数据流程序中。具体来说，Flink 会使用 Java 代码生成器将表达式转换为 Java 代码，并使用 Java 编译器将其编译为字节码。最终生成的数据流程序会包含类似以下的代码：

// 创建条件表达式
Expression equalsExpr = equal(field("id"), literal(123));

// 构建数据源
DataStream<Row> input = env.createInput(...);

// 应用条件表达式
DataStream<Row> result = input.filter(new FilterFunction<Row>() {
    @Override
    public boolean filter(Row value) throws Exception {
        return (boolean) equalsExpr.eval(value);
    }
});

// 输出结果
result.print();

在上述代码中，`filter()` 函数表示使用条件表达式对数据进行过滤，并返回符合条件的数据。`eval()` 函数表示对表达式进行求值，返回一个布尔型结果。在运行时，Flink 会将表达式的字节码加载到 JVM 中，并使用反射机制调用 `eval()` 函数来实现条件过滤。