markilue
/
self_example
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

flink更新

This commit is contained in:
dingjiawen 2022-09-08 09:06:31 +08:00
parent c9f66d2929
commit 84ad855669
2 changed files with 12 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
Big_data_example/Flink/pom.xml
View File

@ -91,9 +91,6 @@
<version>${flink.verison}</version>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-log4j12</artifactId>
@ -127,15 +124,24 @@
<version>${flink.verison}</version>
</dependency>
<!-- <dependency>-->
<!-- <groupId>org.apache.bahir</groupId>-->
<!-- <artifactId>flink-connector-redis_2.11</artifactId>-->
<!-- <version>1.0</version>-->
<!-- </dependency>-->
<!-- https://mvnrepository.com/artifact/org.apache.bahir/flink-connector-redis -->
<dependency>
<groupId>org.apache.bahir</groupId>
<artifactId>flink-connector-redis_2.11</artifactId>
<version>1.0</version>
<artifactId>flink-connector-redis_2.12</artifactId>
<version>1.1.0</version>
</dependency>
</dependencies>

2
Big_data_example/Flink/src/main/java/day08/Example10.java
View File

@ -28,7 +28,7 @@ public class Example10 {
env.setParallelism(1);
SingleOutputStreamOperator<UserBehavior> stream = env
.readTextFile("E:\\Big_data_example\\Flink\\src\\main\\resources\\UserBehavior.csv")
.readTextFile("D:\\example\\self_example\\Big_data_example\\Flink\\src\\main\\resources\\UserBehavior.csv")
.map(
new MapFunction<String, UserBehavior>() {
@Override