Commit 8b5732e6 by fudahua

feat: 新版本的下载

parent 77371187
...@@ -67,8 +67,8 @@ public class FlatQueryResultServiceImpl implements IFlatQueryResultService { ...@@ -67,8 +67,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";
...@@ -106,12 +106,12 @@ public class FlatQueryResultServiceImpl implements IFlatQueryResultService { ...@@ -106,12 +106,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