-
flink table 与sql的算子操作
查看全部 -
Flink 1.7.2 开始支持支持 scala2.12，而之前只能支持到 2.11
查看全部 -
Kafka常用命令
启动zookeepernohup bin/zookeeper-server-start.sh config/zookeeper.properties.&
启动servernohup bin/kafka-server-start.sh sonfig/server.properties&
查看topicbin/kafka-topics.sh-list--zookeeper localhost2181
创建个topic bin/kafka-topics.sh--create--zookeeper localhost2181--replication-factor 1--partitions 1-topic
test
发送数据bin/kafka-console-producer.sh--broker-list localhost9092--topic test
消费数据bin/kafka-console-consumer.sh--bootstrap-server locallost：9092-topic test-from-beginning查看全部 -
public class TablesQL{
public static void main（String[]args）throws Exception{
//1.获取上下文环境table的环境
//2.读取score.csv
//3.注册成内存表
//4.编写5q1然后提交执行
合？//5.结果进行打印
}//查看全部 -
自定义函数
用户自定义函数UDF/UDAF/UDTF
◆继承函数ScalarFunction
◆覆写方法eval
注册函数
◆应用查看全部 -
Flink的编程模型和核心概念<br/>核心概念之并行度<br/>◆算子级别>运行环境级别>客户端级别>系统级别<br/>·并行度不能大于Slot个数查看全部
-
核心概念之并行度
◆算子级别设置flink的编程API修改
◆运行环境级别设置executionEnvironmentk的方法修改并行度
◆客户端级别$FLINK_HOME/bin/flink的-p参数
◆系统级别修改$轩LINK_HOME/conf/flink-confyaml文件查看全部 -
Datastream<String>lines=env. addSource(
new FlinkKafkaConsumer<>(…)); Datastream<Event> events=lines. map((line)->parse(line)); DataStream<Statistics> stats=evepts
. keyBy("id")
. timeWindow(Time. seconds(10))
. apply(new MyWindowAggregationFunction()); stats. addsink(new Rollingsink(path));查看全部 -
我是查看全部
-
呃呃呃呃呃呃呃呃呃呃呃呃呃呃呃呃呃呃呃
查看全部 -
7777777777777744444444444444444444444444444
查看全部 -
flink模型和特性查看全部
-
flink 1.7.2新版本的特性查看全部
-
flink SQL 课程查看全部
-
flink 的窗口： 滚动窗口，滑动窗口，会话窗口查看全部
举报