public static Odps getOdps()

in src/main/java/com/aliyun/odps/kafka/connect/utils/OdpsUtils.java [17:50]
32 lines of code
4 McCabe index (conditional complexity)

  public static Odps getOdps(MaxComputeSinkConnectorConfig config) {
    String
        accountType =
        config.getString(MaxComputeSinkConnectorConfig.BaseParameter.ACCOUNT_TYPE.getName());
    Account account;
    if (accountType.equalsIgnoreCase(Account.AccountProvider.STS.toString())) {
      account = accountFactory.getGenerator(STSAccountGenerator.class).generate(config);
    } else if (accountType.equalsIgnoreCase(Account.AccountProvider.ALIYUN.toString())) {
      account = accountFactory.getGenerator(AliyunAccountGenerator.class).generate(config);
    } else {
      throw new RuntimeException(
          String.format("Please check your ACCOUNT_TYPE config. Current: [%s].", accountType));
    }

    Odps odps = new Odps(account);
    String
        endpoint =
        config.getString(MaxComputeSinkConnectorConfig.BaseParameter.MAXCOMPUTE_ENDPOINT.getName());
    String
        project =
        config.getString(MaxComputeSinkConnectorConfig.BaseParameter.MAXCOMPUTE_PROJECT.getName());
    odps.setDefaultProject(project);
    if (!StringUtils.isNullOrEmpty(config.getString(
        MaxComputeSinkConnectorConfig.BaseParameter.MAXCOMPUTE_SCHEMA.getName()))) {
      odps.setCurrentSchema(config.getString(
          MaxComputeSinkConnectorConfig.BaseParameter.MAXCOMPUTE_SCHEMA.getName()));
    }
    odps.setEndpoint(endpoint);
    odps.setUserAgent("aliyun-maxc-kafka-connector");
    odps.getRestClient().setRetryTimes(1);
    odps.getRestClient().setReadTimeout(20);

    return odps;
  }