Commit f5adfddd by fudahua

feat: 耗时

parent 3ae200d2
...@@ -68,8 +68,8 @@ public class FlatQueryResultServiceImpl implements IFlatQueryResultService { ...@@ -68,8 +68,8 @@ public class FlatQueryResultServiceImpl implements IFlatQueryResultService {
private static LogPak log = new LogPak(FlatQueryResultServiceImpl.class); private static LogPak log = new LogPak(FlatQueryResultServiceImpl.class);
/** csv / xls 下载目录 */ /** csv / xls 下载目录 */
// public static final String SAVE_FOLDER = "/usr/local/data-hook-file"; public static final String SAVE_FOLDER = "/usr/local/data-hook-file";
public static final String SAVE_FOLDER = "D:\\testorder"; // public static final String SAVE_FOLDER = "D:\\testorder";
public static final String HDFS_URL = "/data/hook"; public static final String HDFS_URL = "/data/hook";
...@@ -107,12 +107,12 @@ public class FlatQueryResultServiceImpl implements IFlatQueryResultService { ...@@ -107,12 +107,12 @@ public class FlatQueryResultServiceImpl implements IFlatQueryResultService {
private FlatQueryResultServiceImpl() { private FlatQueryResultServiceImpl() {
log.debug("construct", "准备初始化 FlatQuery 查询服务"); log.debug("construct", "准备初始化 FlatQuery 查询服务");
// runDealHiveFile(3); runDealHiveFile(3);
//// runDistTask(3); // runDistTask(3);
// runDownloadTask(3); runDownloadTask(3);
// runBalaDownloadTask(3); runBalaDownloadTask(3);
// runBigDataDownloadTask(3); runBigDataDownloadTask(3);
// runApplyTask(5); // 每5秒钟进行任务状态检测 runApplyTask(5); // 每5秒钟进行任务状态检测
} }
private String cloudFileUpload(String enterpriseId,File file,String fileExt){ private String cloudFileUpload(String enterpriseId,File file,String fileExt){
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment