code: public EtlResult importData(List<String> params) {
          EtlResult etlResult = new EtlResult();
          List<String> errMsg = new ArrayList<>();
          try {
              MappingConfig.HbaseMapping hbaseMapping = config.getHbaseMapping();
  
              if (params != null && params.size() == 1 && "rebuild".equalsIgnoreCase(params.get(0))) {
                  logger.info(hbaseMapping.getHbaseTable() + " rebuild is starting!");
                  // 如果表存在则删除
                  if (hbaseTemplate.tableExists(hbaseMapping.getHbaseTable())) {
                      hbaseTemplate.disableTable(hbaseMapping.getHbaseTable());
                      hbaseTemplate.deleteTable(hbaseMapping.getHbaseTable());
                  }
                  params = null;
              } else {
                  logger.info(hbaseMapping.getHbaseTable() + " etl is starting!");
              }
              createTable();
  
              // 拼接sql
              String sql = "SELECT * FROM " + config.getHbaseMapping().getDatabase() + "." + hbaseMapping.getTable();
  
              return super.importData(sql, params);
          } catch (Exception e) {
              logger.error(e.getMessage(), e);
              errMsg.add("HBase etl error ==>" + e.getMessage());
          }
          etlResult.setErrorMessage(Joiner.on("\n").join(errMsg));
          return etlResult;
      }
docs: 导入数据
  
  @param params 筛选条件
  @return 导入结果