big-data/flink-test
1
1
Fork 0
Code Issues Pull Requests Releases Wiki Activity

vscode 项目

Browse Source
This commit is contained in:
LingZhaoHui 2021-03-21 12:59:20 +08:00
parent a58fd1b3a1
commit a8be2b40b3
2 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/main/java/com/thinker/main/App.java
View File

@ -14,6 +14,11 @@ public class App {
public static final class LineSplitter implements FlatMapFunction<String, Tuple2<String, Integer>> { public static final class LineSplitter implements FlatMapFunction<String, Tuple2<String, Integer>> {
/**
*
*/
private static final long serialVersionUID = -8040066741965799728L;
@Override @Override
public void flatMap(String s, Collector<Tuple2<String, Integer>> collector) throws Exception { public void flatMap(String s, Collector<Tuple2<String, Integer>> collector) throws Exception {
String[] tokens = s.toLowerCase().split("\\W+"); String[] tokens = s.toLowerCase().split("\\W+");

4
src/main/java/com/thinker/sql/SourceFromMySQL.java
View File

@ -18,6 +18,10 @@ import java.sql.ResultSet;
public class SourceFromMySQL extends RichSourceFunction<Student> { public class SourceFromMySQL extends RichSourceFunction<Student> {
/**
*
*/
private static final long serialVersionUID = 1L;
private PreparedStatement ps; private PreparedStatement ps;
private Connection connection; private Connection connection;