上注册一个TemporalTableFunction作为函数编译器错误

Question

我下面弗林克的Defining Temporal Table Function例如，编译器拒绝接受该代码：

TemporalTableFunction rates = 
    ratesHistory.createTemporalTableFunction("r_proctime", "r_currency");
tEnv.registerFunction("Rates", rates);  

我的编译器告诉我：“在类型TableEnvironment的方法registerFunction（字符串，ScalarFunction）不适用的参数（字符串，TemporalTableFunction）”

我已经走遍了源代码here和here，确实没有registerFunction有TemporalTableFunction签名。只有ScalarFunction类型。我百思不得其解，为什么它会编译;但they do have a test on it。

我只是不能导航，其中TemporalJoinITCase从获取其registerFunction。

弗林克1.7.1使用Scala 2.11和以下构件：弗林克核，弗林克-java的，弗林克-clients_，弗林克-流式JAVA_，弗林克-table_，弗林克串流-scala_，弗林克-JSON，弗林克-运行时web_ 。

我不知道还有斯卡拉是如何工作的;难道是一些特质是我从另一个神器失踪？

最良好的问候！

Answer 1

弄清楚了：

我需要从一个特定的包中导入StreamTableEnvironment：org.apache.flink.table.api.java.StreamTableEnvironment。我的自动完成功能没有被正确地更新的时间，这让我觉得没有合适的方法。但它的存在。