入口文件

src/main/scala/entry/Entry.scala

+package entry
+
+import flink.GetEnvironment
+
+/**
+ * Created with IntelliJ IDEA.
+ * Class: Entry
+ * Description: 
+ * User: lin
+ * Date: 2021-07-16
+ * Time: 9:34
+ */
+object Entry {
+  def main(args: Array[String]): Unit = {
+    //    创建flink环境
+    val env = GetEnvironment.env
+    //    添加kafka源
+    //    添加hive sink
+
+    env.execute()
+  }
+}