FlinkSQL
2022-08-08
（1）定义一个UDFpackage com.udf;import org.apache.flink.table.functions.ScalarFunction;/** * Created by lj on 2022-07-25. */public class TestUDF extends ScalarFunct
2022-08-08
public static void main(String[] args) throws Exception { StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); e
2022-08-08
这里不展开zookeeper、kafka安装配置（1）首先需要启动zookeeper和kafka（2）定义一个kafka生产者package com.producers;import com.alibaba.fastjson.JSONObject;import com.pojo.
2022-08-06
public static void main(String[] args) throws Exception { StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); e
2022-08-06
滚动窗口（Tumbling Windows） 滚动窗口有固定的大小，是一种对数据进行均匀切片的划分方式。窗口之间没有重叠，也不会有间隔，是“首尾相接”的状态。滚动窗口可以基于时间定义，也可
2022-08-06
滑动窗口（Sliding Windows）与滚动窗口类似，滑动窗口的大小也是固定的。区别在于，窗口之间并不是首尾相接的，而是可以“错开”一定的位置。如果看作一个窗口的运动，那么就像是向前
热门文章
2023-03-06
青海新闻网·大美青海客户端讯(记者 崔永焘 摄影报道) “有时候，电影放到一半，观众只剩下老人和孩子，但放映员依然要有耐心，哪怕只有一个观众，也要把这部电影分毫不差地放完，
2023-03-06
演员返场谢幕三次观众掌声不断仍不愿离场这是昨晚发生在深圳保利剧院的一幕舞剧《咏春》迎来全国巡演的第二场这场超燃的精彩演出点燃了全场观众的热情原来，在两个半小时的演
2023-03-05
当影视行业逐渐摆脱了流量控制，开启最本源的以内容为导向的竞争态势之后，那些在演艺圈努力打拼数十年的优秀演员，再度迎来了全新的春天。于是影视界“叔圈”“姐圈”频频破圈，成
2023-03-04
著名表演艺术家、电影《刘三姐》中“刘三姐”的扮演者黄婉秋于３月４日凌晨３时１６分，在桂林医院重症监护室因抢救治疗无效逝世，享年８０岁。在２月１９日她发出的人生最后一条微信中，她写道：永别
2023-03-01
2023的开年大剧，当属《狂飙》。
《狂飙》为什么好看？有人说，一部《狂飙》，看的不仅是张译、张颂文的演技，更看的是他们的处世哲学。“建议查查张颂文，不像演的”登上微博热搜，张颂
2023-03-01
近日，韩国男团前WANNAONE成员尹智圣出演的综艺中，“妹妹碗里没有荷包蛋”片段引发争议。对此，尹智圣和妹妹分别发声回应。在节目中，尹智圣和妹妹因为泡面要不要放鸡蛋起了争执。