下面4種寫法大多數情況下完全等效(任選1種即可)

①tEnv.registerDataStream("orderA", orderA, "user,product,amount");

?

②Deprecated寫法

tEnv.createTemporaryView("orderA", orderA, "user,product,amount");

?

③

最新寫法,②的替代寫法

tEnv.createTemporaryView("orderA", orderA, $("user,product,amount"));

④

Table tableA = tEnv.fromDataStream(orderA, "user,product,amount");
tEnv.registerTable("orderA", tableA);

?

⑤當后續有使用as函數的需要時，必須采用下面這種寫法，此時禁止采用③的寫法

tEnv.createTemporaryView("Orders", orderA, $("user"), $("product"), $("amount"));

下面3種寫法完全等效(任選1種即可)

①tEnv.registerFunction("hashcode", new HashCode(10));

②tEnv.createTemporaryFunction("hashcode", new HashCode(10));

?

③tEnv.createTemporarySystemFunction("hashcode", new HashCode(10));

?

②③在概念上肯定會有差別，但是一般應用中，效果沒區別.

下面4種寫法完全等效(任選1種即可)

①需要注冊UDF 的情況下

Table result = tEnv.from("orderA").select("product,hashcode(product)");
tEnv.toAppendStream(result, Row.class).print();
env.execute();

?

②需要注冊UDF 的情況下

Table result=tEnv.from("orderA").select($("product"),call("hashcode","product"));
tEnv.toAppendStream(result, Row.class).print();
env.execute();

?

③需要注冊UDF 的情況下

Table result=tEnv.sqlQuery("select product,hashcode(product)?from orderA");
tEnv.toAppendStream(result,Row.class).print();
env.execute();

?

④需要注冊UDF 的情況下

tableA.select($("product"),call("hashcode","product")).execute().print();

?

?

⑤不注冊UDF情況下，直接使用UDF

Table result=tEnv.from("orderA").select($("product"),call(HashCode.class,"product"));
tEnv.toAppendStream(result, Row.class).print();
env.execute();

?

?

?