flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Kaibo Zhou (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-6955) Add operation log for Table
Date Tue, 20 Jun 2017 10:53:00 GMT
Kaibo Zhou created FLINK-6955:

             Summary: Add operation log for Table
                 Key: FLINK-6955
                 URL: https://issues.apache.org/jira/browse/FLINK-6955
             Project: Flink
          Issue Type: Improvement
          Components: Table API & SQL
            Reporter: Kaibo Zhou
            Assignee: Kaibo Zhou

In some of the actual production scenarios, the operation of the Table is very complicated,
will go through a number of steps, hoping to record the operation about Table and can print


    val table1 = StreamTestData.getSmall3TupleDataStream(env).toTable(tEnv, 'a, 'b, 'c)
    val table2 = StreamTestData.get5TupleDataStream(env).toTable(tEnv, 'a, 'b, 'd, 'c, 'e)

    val unionDs = table1.unionAll(table2.select('a, 'b, 'c)).filter('b < 2).select('c)

    val results = unionDs.toDataStream[Row]
    val result = tEnv.getLog

    val expected =
      "UnnamedTable$1 = UnnamedTable$0.select('a, 'b, 'c)\n" +
        "UnnamedTable$5 = UnnamedTable$2.unionAll(UnnamedTable$1)\n" +
        "  .filter('b < 2)\n" +
        "  .select('c)\n"
    assertEquals(expected, result)

This message was sent by Atlassian JIRA

View raw message