划船小子
2021-06-06
可以的,官方的包有
帝国大学
2021-05-10
应该是Java8 lambda+匿名内部类 语法
BigDataGreenHand
2020-10-28
它们都支持流式计算,Fink是一行一行处理,是基于操作符的连续流模型,而Spark是基于数据片集合(RDD)进行小批量处理,所以Spark在流式处理方面会增加一些延迟。Flink可以支持毫秒级计算,而Spark则只能支持秒级计算。如果是要求对实时性要求非常高的场景(如高频实时交易),Spark是难以满足的,可以考虑Flink或Storm。
庄学爸
2020-06-27
好吧,自问自答,懂了。
视频上说sliding size为5s,其实就是每隔5s计算一次最近30s出现的数据,那么肯定数据是会重叠的,因为滑动窗口之间的时间线会有重叠。?
宝慕林8491863
2020-03-30
免费课程应该没有文档资料的
galileo2008
2020-02-10
用啊,我们都是用Scala开发的,只不过有人不会Scala
peggy_fei
2020-01-02
window
慕粉18511892991
2019-12-05
Linux也行。
大志君哒哒哒
2019-12-05
滑动值。
goaler
2019-08-13
电脑性能问题,再加上flink本身是大数据处理框架,你数据量小的时候,根本发挥不出flink的能力。
慕的地5420249
2019-08-12
去Apache.flink.org官网下载,代码是自动生成的
Laivy
2019-07-18
嗯优秀
慕盖茨5726191
2019-05-26
KeyedStream<WikipediaEditEvent, String> keyedEdits = edits
.keyBy(new KeySelector<WikipediaEditEvent, String>() {
@Override
public String getKey(WikipediaEditEvent event) {
return event.getUser();
}
});
weixin_慕前端2055968
2019-05-07
一丢丢的小罪恶
2019-02-13
你好,我才看到你的留言。这个问题比较可能是因为:你这个类中import的是不是StreamExecutionEnvironment,或者看看Tuple2是不是引用对了。
慕数据1565473
2019-01-12
我来回答下吧。单机版确实不需要。
实际生产环境一般是on yarn,是需要hadoop环境的。
但是,注意啦!
flink本身已经和hadoop继承在一个包里了。大家可以去官网看,安装包带了对应版本的hadoop。
所以,结论是,需要。但是安装过程大大简化。大概比安装spark集群简单60%以上。
希望对你有帮助。
ownheart
2018-12-23
已经在规划了。免费实战课。这个主要是做入门使用。另外flink版本迭代过快。自己也要随时关注官网。
努力前进的蜗牛
2018-10-31
同学,别在windows上玩这个。安装一个虚拟机。
qq_小小zt_bkory4
2018-10-30
你们在玩啥。。。带上我
tjcu
2018-10-20