支持带CREATE VIEW 视图流的血缘解析吗？ about flink-sql-lineage HOT 1 CLOSED

@Test
public void testInsertSelectViewCep() {
    context.execute("DROP VIEW IF EXISTS temperature_view ");

    context.execute("CREATE VIEW IF NOT EXISTS temperature_view AS " +
            "SELECT                                                     " +
            "   *                                                       " +
            "FROM                                                       " +
            "   temperature_source MATCH_RECOGNIZE (                    " +
            "       PARTITION BY rack_id                                " +
            "       ORDER BY ts                                         " +
            "       MEASURES                                            " +
            "           A.ts as start_ts,                               " +
            "           LAST(B.ts) as end_ts,                           " +
            "           A.temperature as start_temp,                    " +
            "           LAST(B.temperature) as end_temp,                " +
            "           AVG(B.temperature) as avg_temp                  " +
            "           ONE ROW PER MATCH                               " +
            "           AFTER MATCH SKIP TO NEXT ROW                    " +
            "           PATTERN (A B+ C) WITHIN INTERVAL '90' second    " +
            "           DEFINE                                          " +
            "               A as A.temperature < 50,                    " +
            "               B as B.temperature >=50,                    " +
            "               C as C.temperature < 50                     " +
            "   )"
    );

    String sql = "INSERT INTO print_sink (rack_id, start_ts, end_ts, start_temp, end_temp, avg_temp) " +
            "SELECT " +
            "   rack_id     ," +
            "   start_ts    ," +
            "   end_ts      ," +
            "   start_temp  ," +
            "   end_temp    ," +
            "   avg_temp     " +
            "FROM" +
            "   temperature_view";

    // variables A and B in transform are not replaced. LAST and AVG functions have also been replaced, and add CAST function.
    String[][] expectedArray = {
            {"temperature_source", "rack_id", "print_sink", "rack_id"},
            {"temperature_source", "ts", "print_sink", "start_ts", "CAST(A.ts):TIMESTAMP(3)"},
            {"temperature_source", "ts", "print_sink", "end_ts", "CAST(LAST(B.ts, 0)):TIMESTAMP(3)"},
            {"temperature_source", "temperature", "print_sink", "start_temp", "A.temperature"},
            {"temperature_source", "temperature", "print_sink", "end_temp", "LAST(B.temperature, 0)"},
            {"temperature_source", "temperature", "print_sink", "avg_temp", "CAST(/(SUM(B.temperature), COUNT(B.temperature))):INTEGER"}
    };

    analyzeLineage(sql, expectedArray);
}