DataShardConfig.java 1.1 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061
  1. package com.primeton.damp.config;
  2. import lombok.Data;
  3. import lombok.extern.slf4j.Slf4j;
  4. import org.springframework.boot.context.properties.ConfigurationProperties;
  5. import org.springframework.stereotype.Component;
  6. import java.util.HashMap;
  7. import java.util.Map;
  8. /**
  9. * @author zhaopx
  10. * @date 2021/4/7 17:14
  11. */
  12. @Slf4j
  13. @Data
  14. @Component
  15. @ConfigurationProperties(ignoreUnknownFields = true, prefix = "datashard")
  16. public class DataShardConfig {
  17. /**
  18. * 文件系统
  19. */
  20. String type = "local";
  21. /**
  22. * Local,HDFS 等文件系统的基础路径
  23. */
  24. String basePath;
  25. /**
  26. * 上传后是否删除源文件
  27. */
  28. boolean delSrc = false;
  29. /**
  30. * 数据文件后缀
  31. */
  32. String fileSuffix = ".bcp";
  33. /**
  34. * ftp 配置
  35. */
  36. final Map<String, Object> ftp = new HashMap<>();
  37. /**
  38. * sftp 配置
  39. */
  40. final Map<String, Object> sftp = new HashMap<>();
  41. public void setFtp(Map<String, Object> ftp) {
  42. this.ftp.putAll(ftp);
  43. }
  44. public void setSftp(Map<String, Object> sftp) {
  45. this.sftp.putAll(sftp);
  46. }
  47. }