add video link

datavane · Aug 5, 2021 · 338d3cc · 338d3cc
1 parent 5303a03
commit 338d3cc
Show file tree

Hide file tree

Showing 2 changed files with 25 additions and 28 deletions.
diff --git a/README.md b/README.md
@@ -20,6 +20,14 @@ TIS平台是一套为企业级用户提供大数据多维、实时、查询的
 
 ## 功能一瞥 
 
+- 视频示例
+    * [安装示例](https://www.bilibili.com/video/BV18q4y1p73B/)
+    * [启用分布式执行功能](https://www.bilibili.com/video/BV1Cq4y1D7z4?share_source=copy_web)
+    * [MySQL导入ElasticSearch](https://www.bilibili.com/video/BV1G64y1B7wm?share_source=copy_web)
+    * [MySQL导入Hive](https://www.bilibili.com/video/BV1Vb4y1z7DN?share_source=copy_web)
+    * [MySQL导入Clickhouse](https://www.bilibili.com/video/BV1x64y1B7V8/)
+
+
 选择Reader/Writer插件类型
   ![tis](docs/datax-add-step2.png)
 

diff --git a/tis-console/src/main/java/com/qlangtech/tis/coredefine/module/action/PluginAction.java b/tis-console/src/main/java/com/qlangtech/tis/coredefine/module/action/PluginAction.java
@@ -73,23 +73,26 @@ public class PluginAction extends BasicModule {
       public void afterSaved(PluginItems.PluginItemsSaveEvent event) {
         final String extendPoint = event.heteroEnum.extensionPoint.getName();
         // @see "com.qlangtech.tis.fullbuild.servlet.TaskStatusServlet"
-        try {
-          URL url = new URL(Config.getAssembleHttpHost() + "/task_status?" + DescriptorsJSON.KEY_EXTEND_POINT + "=" + extendPoint);
-          HttpUtils.get(url, new ConfigFileContext.StreamProcess<Void>() {
-            @Override
-            public Void p(int status, InputStream stream, Map<String, List<String>> headerFields) {
-              logger.info("has apply clean pluginStore cache by " + DescriptorsJSON.KEY_EXTEND_POINT + " " + extendPoint);
-              return null;
-            }
-          });
-        } catch (Exception e) {
-          //throw new RuntimeException("extendPoint:" + extendPoint, e);
-          logger.warn("apply clean pluginStore cache faild " + e.getMessage());
-        }
+        notifyPluginUpdate2AssembleNode(DescriptorsJSON.KEY_EXTEND_POINT + "=" + extendPoint, "pluginStore");
       }
     }));
   }
 
+  private static void notifyPluginUpdate2AssembleNode(String applyParams, String targetResource) {
+    try {
+      URL url = new URL(Config.getAssembleHttpHost() + "/task_status?" + applyParams);
+      HttpUtils.get(url, new ConfigFileContext.StreamProcess<Void>() {
+        @Override
+        public Void p(int status, InputStream stream, Map<String, List<String>> headerFields) {
+          logger.info("has apply clean " + targetResource + " cache by " + applyParams);
+          return null;
+        }
+      });
+    } catch (Exception e) {
+      logger.warn("apply clean " + targetResource + " cache faild " + e.getMessage());
+    }
+  }
+
   /**
    * 取得字段的帮助信息
    *
@@ -256,21 +259,7 @@ public void run() {
 
             InstallUtil.proceedToNextStateFrom(InstallState.INITIAL_PLUGINS_INSTALLING);
             // 为了让Assemble等节点的uberClassLoader重新加载一次，需要主动向Assemble等节点发送一个指令
-            try {
-              URL url = new URL(Config.getAssembleHttpHost() + "/task_status?" + TIS.KEY_ACTION_CLEAN_TIS + "=true");
-              HttpUtils.get(url, new ConfigFileContext.StreamProcess<Void>() {
-                @Override
-                public Void p(int status, InputStream stream, Map<String, List<String>> headerFields) {
-                  logger.info("has apply clean TIS cache " + TIS.KEY_ACTION_CLEAN_TIS);
-                  return null;
-                }
-              });
-            } catch (Exception e) {
-              //throw new RuntimeException("extendPoint:" + extendPoint, e);
-              logger.warn("apply clean TIS cache faild " + e.getMessage());
-            }
-
-
+            notifyPluginUpdate2AssembleNode(TIS.KEY_ACTION_CLEAN_TIS + "=true", "TIS");
           }
         }
       }.start();