public void start()

in src/main/java/com/aliyun/odps/kafka/connect/MaxComputeSinkConnector.java [55:77]

• 17 lines of code
• 3 McCabe index (conditional complexity)

  public void start(Map<String, String> map) {
    config = new MaxComputeSinkConnectorConfig(map);

    LOGGER.info("Starting MaxCompute sink connector");
    for (Entry<String, String> entry : map.entrySet()) {
      LOGGER.info(entry.getKey() + ": " + entry.getValue());
    }

    Odps odps = OdpsUtils.getOdps(config);

    try {
      odps.projects().exists(config.getString(
          MaxComputeSinkConnectorConfig.BaseParameter.MAXCOMPUTE_PROJECT.getName()));
      odps.tables().exists(
          config.getString(MaxComputeSinkConnectorConfig.BaseParameter.MAXCOMPUTE_TABLE.getName()));
    } catch (OdpsException e) {
      throw new IllegalArgumentException("Cannot find configured MaxCompute project or table");
    }

    // TODO: validate table schema

    LOGGER.info("Connect to MaxCompute successfully!");
  }