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

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

?

②Deprecated寫(xiě)法

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

?

③

最新寫(xiě)法,②的替代寫(xiě)法

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

④

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

?

⑤當(dāng)后續(xù)有使用as函數(shù)的需要時(shí)，必須采用下面這種寫(xiě)法，此時(shí)禁止采用③的寫(xiě)法

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

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

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

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

?

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

?

②③在概念上肯定會(huì)有差別，但是一般應(yīng)用中，效果沒(méi)區(qū)別.

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

①需要注冊(cè)UDF 的情況下

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

?

②需要注冊(cè)UDF 的情況下

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

?

③需要注冊(cè)UDF 的情況下

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

?

④需要注冊(cè)UDF 的情況下

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

?

?

⑤不注冊(cè)UDF情況下，直接使用UDF

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

?

?

?