SQL API with Table API

[nragon]

Hi,

Can i expect the output from this:

Table revenue = tableEnv.sql(
    "SELECT TUMBLE_START(EventTime, INTERVAL '30' MINUTE) as tStart, " +
                        "TUMBLE_END(EventTime, INTERVAL '30' MINUTE) as tEnd, " +
                        "cID, " +
                        "cName, " +
                        "SUM(revenue) AS revSum " +
    "FROM Orders " +
    "WHERE cCountry = 'FRANCE' " +
    "GROUP BY TUMBLE(EventTime, INTERVAL '30' MINUTE), cID, cName"
  );

being the same as this:

Table revenue = tableEnv.sql(
    "SELECT cID, cName, SUM(revenue) AS revSum " +
    "FROM Orders " +
    "WHERE cCountry = 'FRANCE' " +
    "GROUP BY cID, cName"
  );
 
revenue
        .select("*, e.start, e.end")
        .window(Tumble.over("30.minute").on("EventTime").as("e"))
        .groupBy("e")


Or the second involves one query as nested of tumble query?

Thanks

[Fabian Hueske-2]

No, those are two different queries.

The second query would also not work because the revenue table does not have the EventTime attribute.

Best, Fabian

2017-08-01 13:03 GMT+02:00 nragon <[hidden email]>:

Hi,

Can i expect the output from this:

Table revenue = tableEnv.sql(
    "SELECT TUMBLE_START(EventTime, INTERVAL '30' MINUTE) as tStart, " +
                        "TUMBLE_END(EventTime, INTERVAL '30' MINUTE) as tEnd, " +
                        "cID, " +
                        "cName, " +
                        "SUM(revenue) AS revSum " +
    "FROM Orders " +
    "WHERE cCountry = 'FRANCE' " +
    "GROUP BY TUMBLE(EventTime, INTERVAL '30' MINUTE), cID, cName"
  );

being the same as this:

Table revenue = tableEnv.sql(
    "SELECT cID, cName, SUM(revenue) AS revSum " +
    "FROM Orders " +
    "WHERE cCountry = 'FRANCE' " +
    "GROUP BY cID, cName"
  );

revenue
        .select("*, e.start, e.end")
        .window(Tumble.over("30.minute").on("EventTime").as("e"))
        .groupBy("e")


Or the second involves one query as nested of tumble query?

Thanks




--
View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/SQL-API-with-Table-API-tp14599.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.

[nragon]

"No, those are two different queries. "

This is enough. The second part does not applies since i'm calculating EventTime from table source.

Thanks