我试着用Flink的1.9的最后一个值。与阿里巴巴文档不同，它不接受订单的第二个参数，也不喜欢over（…）子句。所以，我不确定，如何把最后一个值输入一个标准？我希望，如果您将处理设置为“event time”，last\ u值将返回基于事件时间的最新值，但它将返回读取的最新值？
mkh04yzy1#
函数 LAST_VALUE 只有在flink上运行sql时，blink planner才支持。需要通过
LAST_VALUE
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment; import org.apache.flink.table.api.EnvironmentSettings; import org.apache.flink.table.api.java.StreamTableEnvironment; StreamExecutionEnvironment bsEnv = StreamExecutionEnvironment.getExecutionEnvironment(); EnvironmentSettings bsSettings = EnvironmentSettings.newInstance().useBlinkPlanner().inStreamingMode().build(); StreamTableEnvironment bsTableEnv = StreamTableEnvironment.create(bsEnv, bsSettings);
只有这样，您才能运行包含 LAST_VALUE 功能。
1条答案
按热度按时间mkh04yzy1#
函数
LAST_VALUE只有在flink上运行sql时，blink planner才支持。需要通过只有这样，您才能运行包含
LAST_VALUE功能。