如何在flink sql查询中使用sql客户端进行窗口连接？

baubqpgj 于 2021-06-24 发布在 Flink

关注(0)|答案(1)|浏览(540)

如何在flinksql查询中使用sql客户机进行窗口连接。窗口以同样的方式提到在下面的链接https://ci.apache.org/projects/flink/flink-docs-release-1.9/dev/stream/operators/joining.html
需要窗口化的示例查询从sourcekafka内部选择sourcekafka.*在sourcekafka上加入badips。 source.ip =badips.ip
sourcekafka是源表，kafka badips的连续流是另一个源表

streaming apache-flink flink-sql flink-streaming windowing

来源：https://stackoverflow.com/questions/57962044/how-do-we-window-join-using-sql-client-in-flink-sql-query

1条答案

按热度按时间

kknvjkwl1#

下面是使用flink sql的时间窗口联接示例：

SELECT *
FROM Orders o, Shipments s
WHERE o.id = s.orderId AND
  o.ordertime BETWEEN s.shiptime - INTERVAL '4' HOUR AND s.shiptime

详见文档。

赞(0）回复(0）举报 2021-06-24

我来回答

如何在flink sql查询中使用sql客户端进行窗口连接？

1条答案

相关问题

热门标签

最新问答