add flink adn update package

yanghaiji · Jan 7, 2021 · d55f676 · d55f676
1 parent 71e92c9
commit d55f676
Show file tree

Hide file tree

Showing 135 changed files with 330 additions and 276 deletions.
diff --git a/note/datastructureAlgorithm/book/datastructure/HuffmanTree.md b/note/datastructureAlgorithm/book/datastructure/HuffmanTree.md
@@ -60,7 +60,7 @@ public class HuffManTree {
      * @version 1.0.0
      * @since 12/31/2020
      * @param array     需要构建的数组
-     * @return com.javayh.advanced.datastructure.tree.huffman.Node 构建后的赫夫曼树
+     * @return Node 构建后的赫夫曼树
      */
     public static Node createHuffmanTree(int[] array) {
         // 第一步为了操作方便

diff --git a/note/datastructureAlgorithm/book/datastructure/Tree.md b/note/datastructureAlgorithm/book/datastructure/Tree.md
@@ -135,7 +135,7 @@ public class TreeLinkedList<E> implements Tree<E> {
      * <p>
      *     返回当前节点的最大弟弟；若没有弟弟，则返回null
      * </p>
-     * @return com.javayh.advanced.datastructure.tree.linked.TreeLinkedList<E>
+     * @return TreeLinkedList<E>
      */
     @Override
     public TreeLinkedList<E> getNextSibling() {
@@ -377,7 +377,7 @@ public interface BinTree<E> {
      *     获取根节点
      * </p>
      * @param
-     * @return com.javayh.advanced.datastructure.tree.bin.BinTreePosition
+     * @return BinTreePosition
      */
     BinTreePosition getRoot();
 
@@ -410,7 +410,7 @@ public interface BinTree<E> {
      *      前序遍历
      * </p>
      * @param
-     * @return com.javayh.advanced.datastructure.Iterator<E>
+     * @return Iterator<E>
      */
     Iterator<E> elementsPreorder();
 
@@ -419,7 +419,7 @@ public interface BinTree<E> {
      *     中序遍历
      * </p>
      * @param
-     * @return com.javayh.advanced.datastructure.Iterator
+     * @return Iterator
      */
     Iterator<E> elementsInorder();
 
@@ -428,7 +428,7 @@ public interface BinTree<E> {
      *     后序遍历  
      * </p>
      * @param 
-     * @return com.javayh.advanced.datastructure.Iterator
+     * @return Iterator
      */
     Iterator<E> elementsPostorder();
 
@@ -437,7 +437,7 @@ public interface BinTree<E> {
      *     层次遍历
      * </p>
      * @param
-     * @return com.javayh.advanced.datastructure.Iterator
+     * @return Iterator
      */
     Iterator<E> elementsLevelorder();
 }

diff --git a/note/flink/README.md b/note/flink/README.md
diff --git a/note/flink/img/FlinkLogo.png b/note/flink/img/FlinkLogo.png
diff --git a/note/mybatis/book/扩展.md b/note/mybatis/book/扩展.md
@@ -91,18 +91,18 @@
 然后开始编写`resultMap`
 这里我只是三层的关系，更多的层次关系继续写就可以
 ```xml
-<resultMap type="com.javayh.advanced.mybatis.vo.LogisticsVO" id="logisticsMap">
+<resultMap type="LogisticsVO" id="logisticsMap">
     <result property="addressee" column="addressee"/>
     <result property="addressee_name" column="addressee_name"/>
     <result property="addressee_phone" column="addressee_phone"/>
     <collection property="senderVOList"  resultMap = "senderVOListMap"/>
 </resultMap>
-<resultMap type="com.javayh.advanced.mybatis.vo.LogisticsSenderVO" id="senderVOListMap">
+<resultMap type="LogisticsSenderVO" id="senderVOListMap">
     <result property="sender_add" column="sender_add"/>
     <result property="sender_name" column="sender_name"/>
     <collection property="informationVOS"  resultMap = "informationVOSMap"/>
 </resultMap>
-<resultMap type="com.javayh.advanced.mybatis.vo.OtherInformationVO" id="informationVOSMap">
+<resultMap type="OtherInformationVO" id="informationVOSMap">
     <result property="create_by" column="create_by"/>
     <result property="create_date" column="create_date"/>
     <result property="retreat_status" column="retreat_status"/>
@@ -126,7 +126,7 @@ void mapperMap() throws JsonProcessingException {
 大多数我们都是利用 `foreach` 来做某个字段的 `in` 查询，但是有一天一个朋友问我，`foreach` 里可以写`if`吗?
 我的第一反应是应该可以写，后来想了一下，肯定是可以的，当然我们也不能全部停留在自己的想法上，还是要去实现一下的;
 ```xml
-<select id="findListAndIf" resultType="com.javayh.advanced.mybatis.vo.LogisticsVO">
+<select id="findListAndIf" resultType="LogisticsVO">
      SELECT
         addressee,
         addressee_name,

diff --git a/note/spring/book/bean/FactoryBean.md b/note/spring/book/bean/FactoryBean.md
@@ -114,7 +114,7 @@ public class FactoryBeanLearn implements FactoryBean<BaseBean>,InitializingBean
      *       实例化对象
      * </p>
      * @param
-     * @return com.javayh.advanced.spring.bean.BaseBean
+     * @return BaseBean
      */
     private BaseBean buildBaseBean() {
         if (Objects.isNull(customConfigurationProperties)){

diff --git a/pom.xml b/pom.xml
@@ -2,6 +2,7 @@
 <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
     <modelVersion>4.0.0</modelVersion>
+    <packaging>pom</packaging>
     <parent>
         <groupId>org.springframework.boot</groupId>
         <artifactId>spring-boot-starter-parent</artifactId>
@@ -14,7 +15,8 @@
     <name>advanced-book</name>
     <description>advanced-book</description>
 	<modules>
-        <module>source-code</module>
+        <module>source-java-code</module>
+        <module>source-flink-code</module>
     </modules>
 
     <properties>
@@ -29,8 +31,48 @@
         <maven-source-plugin.version>3.0.1</maven-source-plugin.version>
         <maven-surefire-plugin.version>2.22.0</maven-surefire-plugin.version>
         <mybatis.version>2.0.0</mybatis.version>
+        <flink.version>1.9.1</flink.version>
     </properties>
 
+    <dependencies>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-validation</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-web</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-aop</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+            <optional>true</optional>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-test</artifactId>
+            <scope>test</scope>
+            <exclusions>
+                <exclusion>
+                    <groupId>org.junit.vintage</groupId>
+                    <artifactId>junit-vintage-engine</artifactId>
+                </exclusion>
+            </exclusions>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.restdocs</groupId>
+            <artifactId>spring-restdocs-mockmvc</artifactId>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.commons</groupId>
+            <artifactId>commons-lang3</artifactId>
+        </dependency>
+    </dependencies>
 
 
 </project>
diff --git a/source-flink-code/pom.xml b/source-flink-code/pom.xml
@@ -0,0 +1,54 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>java-advanced</artifactId>
+        <groupId>com.javayh.advanced</groupId>
+        <version>1.0.0.RELEASE</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>source-flink-code</artifactId>
+
+    <dependencies>
+        <!-- Start Flink -->
+        <dependency>
+            <groupId>org.apache.flink</groupId>
+            <artifactId>flink-java</artifactId>
+            <version>${flink.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.flink</groupId>
+            <artifactId>flink-streaming-java_2.11</artifactId>
+            <version>${flink.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.flink</groupId>
+            <artifactId>flink-clients_2.11</artifactId>
+            <version>${flink.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.flink</groupId>
+            <artifactId>flink-connector-kafka-0.11_2.11</artifactId>
+            <version>${flink.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.flink</groupId>
+            <artifactId>flink-table-api-java-bridge_2.11</artifactId>
+            <version>${flink.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.flink</groupId>
+            <artifactId>flink-table-planner_2.11</artifactId>
+            <version>${flink.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.flink</groupId>
+            <artifactId>flink-table-planner-blink_2.11</artifactId>
+            <version>${flink.version}</version>
+        </dependency>
+        <!-- End Flink -->
+    </dependencies>
+
+</project>
diff --git a/source-flink-code/src/main/java/com/javayh/advanced/flink/wc/WordCount.java b/source-flink-code/src/main/java/com/javayh/advanced/flink/wc/WordCount.java
@@ -0,0 +1,23 @@
+package com.javayh.advanced.flink.wc;
+
+import org.apache.flink.api.java.ExecutionEnvironment;
+
+/**
+ * <p>
+ * 批处理的demo
+ * </p>
+ *
+ * @author Dylan
+ * @version 1.0.0
+ * @since 2021-01-07
+ */
+public class WordCount {
+    public static void main(String[] args) throws Exception {
+        //创建执行环境
+        ExecutionEnvironment env = ExecutionEnvironment.createCollectionsEnvironment();
+        //从文件中读取数据
+        String inputPath = "";
+
+
+    }
+}
diff --git a/source-code/pom.xml → source-java-code/pom.xml b/source-code/pom.xml → source-java-code/pom.xml
@@ -9,43 +9,10 @@
     </parent>
     <artifactId>source-code</artifactId>
     <version>1.0.0.RELEASE</version>
-    <name>source-code</name>
-    <description>source-code</description>
+    <name>source-java-code</name>
+    <description>source-java-code</description>
 
     <dependencies>
-        <dependency>
-            <groupId>org.springframework.boot</groupId>
-            <artifactId>spring-boot-starter-validation</artifactId>
-        </dependency>
-        <dependency>
-            <groupId>org.springframework.boot</groupId>
-            <artifactId>spring-boot-starter-web</artifactId>
-        </dependency>
-        <dependency>
-            <groupId>org.springframework.boot</groupId>
-            <artifactId>spring-boot-starter-aop</artifactId>
-        </dependency>
-        <dependency>
-            <groupId>org.projectlombok</groupId>
-            <artifactId>lombok</artifactId>
-            <optional>true</optional>
-        </dependency>
-        <dependency>
-            <groupId>org.springframework.boot</groupId>
-            <artifactId>spring-boot-starter-test</artifactId>
-            <scope>test</scope>
-            <exclusions>
-                <exclusion>
-                    <groupId>org.junit.vintage</groupId>
-                    <artifactId>junit-vintage-engine</artifactId>
-                </exclusion>
-            </exclusions>
-        </dependency>
-        <dependency>
-            <groupId>org.springframework.restdocs</groupId>
-            <artifactId>spring-restdocs-mockmvc</artifactId>
-            <scope>test</scope>
-        </dependency>
         <dependency>
             <groupId>mysql</groupId>
             <artifactId>mysql-connector-java</artifactId>
@@ -60,10 +27,6 @@
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-logging</artifactId>
         </dependency>
-        <dependency>
-            <groupId>org.apache.commons</groupId>
-            <artifactId>commons-lang3</artifactId>
-        </dependency>
         <!--<dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-properties-migrator</artifactId>

diff --git a/.../javayh/advanced/AdvancedApplication.java → ...yh/advanced/java/AdvancedApplication.java b/.../javayh/advanced/AdvancedApplication.java → ...yh/advanced/java/AdvancedApplication.java
@@ -1,6 +1,6 @@
-package com.javayh.advanced;
+package com.javayh.advanced.java;
 
-import com.javayh.advanced.spring.config.CustomConfigurationProperties;
+import com.javayh.advanced.java.spring.config.CustomConfigurationProperties;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;

diff --git a/.../javayh/advanced/algorithm/SortUtils.java → ...yh/advanced/java/algorithm/SortUtils.java b/.../javayh/advanced/algorithm/SortUtils.java → ...yh/advanced/java/algorithm/SortUtils.java
@@ -1,4 +1,4 @@
-package com.javayh.advanced.algorithm;
+package com.javayh.advanced.java.algorithm;
 
 import org.apache.commons.lang3.time.DateFormatUtils;
 

diff --git a/...advanced/algorithm/example/sort/冒泡排序.java → ...ced/java/algorithm/example/sort/冒泡排序.java b/...advanced/algorithm/example/sort/冒泡排序.java → ...ced/java/algorithm/example/sort/冒泡排序.java
@@ -1,4 +1,4 @@
-package com.javayh.advanced.algorithm.example.sort;
+package com.javayh.advanced.java.algorithm.example.sort;
 
 import java.util.Arrays;
 

diff --git a/...advanced/algorithm/example/sort/快速排序.java → ...ced/java/algorithm/example/sort/快速排序.java b/...advanced/algorithm/example/sort/快速排序.java → ...ced/java/algorithm/example/sort/快速排序.java
@@ -1,4 +1,4 @@
-package com.javayh.advanced.algorithm.example.sort;
+package com.javayh.advanced.java.algorithm.example.sort;
 
 import java.util.Arrays;
 

diff --git a/...advanced/algorithm/example/sort/插入排序.java → ...ced/java/algorithm/example/sort/插入排序.java b/...advanced/algorithm/example/sort/插入排序.java → ...ced/java/algorithm/example/sort/插入排序.java
@@ -1,4 +1,4 @@
-package com.javayh.advanced.algorithm.example.sort;
+package com.javayh.advanced.java.algorithm.example.sort;
 
 import java.util.Arrays;
 

diff --git a/...vayh/advanced/algorithm/example/两数相加.java → ...advanced/java/algorithm/example/两数相加.java b/...vayh/advanced/algorithm/example/两数相加.java → ...advanced/java/algorithm/example/两数相加.java
@@ -1,4 +1,4 @@
-package com.javayh.advanced.algorithm.example;
+package com.javayh.advanced.java.algorithm.example;
 
 /**
  * <p>

diff --git a/...vayh/advanced/algorithm/example/二分查找.java → ...advanced/java/algorithm/example/二分查找.java b/...vayh/advanced/algorithm/example/二分查找.java → ...advanced/java/algorithm/example/二分查找.java
@@ -1,4 +1,4 @@
-package com.javayh.advanced.algorithm.example;
+package com.javayh.advanced.java.algorithm.example;
 
 /**
  * <p>

diff --git a/...vayh/advanced/algorithm/example/取模运算.java → ...advanced/java/algorithm/example/取模运算.java b/...vayh/advanced/algorithm/example/取模运算.java → ...advanced/java/algorithm/example/取模运算.java
@@ -1,4 +1,4 @@
-package com.javayh.advanced.algorithm.example;
+package com.javayh.advanced.java.algorithm.example;
 
 import java.util.concurrent.atomic.AtomicInteger;
 

diff --git a/...vayh/advanced/algorithm/example/排列组合.java → ...advanced/java/algorithm/example/排列组合.java b/...vayh/advanced/algorithm/example/排列组合.java → ...advanced/java/algorithm/example/排列组合.java
@@ -1,4 +1,4 @@
-package com.javayh.advanced.algorithm.example;
+package com.javayh.advanced.java.algorithm.example;
 
 import java.util.Arrays;
 

diff --git a/...avayh/advanced/algorithm/example/水仙花.java → .../advanced/java/algorithm/example/水仙花.java b/...avayh/advanced/algorithm/example/水仙花.java → .../advanced/java/algorithm/example/水仙花.java
@@ -1,4 +1,4 @@
-package com.javayh.advanced.algorithm.example;
+package com.javayh.advanced.java.algorithm.example;
 
 /**
  * <p>

diff --git a/.../advanced/algorithm/example/算法之递归求兔子.java → ...nced/java/algorithm/example/算法之递归求兔子.java b/.../advanced/algorithm/example/算法之递归求兔子.java → ...nced/java/algorithm/example/算法之递归求兔子.java
@@ -1,4 +1,4 @@
-package com.javayh.advanced.algorithm.example;
+package com.javayh.advanced.java.algorithm.example;
 
 /**
  * <p>

diff --git a/...ayh/advanced/algorithm/kmp/KmpSearch.java → ...dvanced/java/algorithm/kmp/KmpSearch.java b/...ayh/advanced/algorithm/kmp/KmpSearch.java → ...dvanced/java/algorithm/kmp/KmpSearch.java
@@ -1,4 +1,4 @@
-package com.javayh.advanced.algorithm.kmp;
+package com.javayh.advanced.java.algorithm.kmp;
 
 import java.util.Arrays;
 

diff --git a/...advanced/algorithm/kmp/ViolenceMatch.java → ...ced/java/algorithm/kmp/ViolenceMatch.java b/...advanced/algorithm/kmp/ViolenceMatch.java → ...ced/java/algorithm/kmp/ViolenceMatch.java
@@ -1,4 +1,4 @@
-package com.javayh.advanced.algorithm.kmp;
+package com.javayh.advanced.java.algorithm.kmp;
 
 /**
  * <p>

diff --git a/.../advanced/algorithm/recursion/MiGong.java → ...nced/java/algorithm/recursion/MiGong.java b/.../advanced/algorithm/recursion/MiGong.java → ...nced/java/algorithm/recursion/MiGong.java
@@ -1,4 +1,4 @@
-package com.javayh.advanced.algorithm.recursion;
+package com.javayh.advanced.java.algorithm.recursion;
 
 /**
  * <p>

diff --git a/...vanced/algorithm/search/BinarySearch.java → ...d/java/algorithm/search/BinarySearch.java b/...vanced/algorithm/search/BinarySearch.java → ...d/java/algorithm/search/BinarySearch.java
@@ -1,4 +1,4 @@
-package com.javayh.advanced.algorithm.search;
+package com.javayh.advanced.java.algorithm.search;
 
 /**
  * <p>