public void validateInput()

in java/src/main/java/com/google/cloud/dataproc/templates/pubsub/PubSubToBigTable.java [155:200]
45 lines of code
6 McCabe index (conditional complexity)

  public void validateInput() {
    if (StringUtils.isAllBlank(inputProjectID)
        || StringUtils.isAllBlank(pubsubInputSubscription)
        || StringUtils.isAllBlank(pubSubBigTableOutputInstanceId)
        || StringUtils.isAllBlank(pubSubBigTableOutputProjectId)
        || StringUtils.isAllBlank(pubSubBigTableOutputTable)) {
      LOGGER.error(
          "{},{},{},{},{} are required parameter. ",
          PUBSUB_INPUT_PROJECT_ID_PROP,
          PUBSUB_INPUT_SUBSCRIPTION_PROP,
          PUBSUB_BIGTABLE_OUTPUT_INSTANCE_ID_PROP,
          PUBSUB_BIGTABLE_OUTPUT_PROJECT_ID_PROP,
          PUBSUB_BIGTABLE_OUTPUT_TABLE_PROP);
      throw new IllegalArgumentException(
          "Required parameters for PubSubToBigTable not passed. "
              + "Set mandatory parameter for PubSubToBigTable template "
              + "in resources/conf/template.properties file.");
    }

    LOGGER.info(
        "Starting PubSub to BigTable spark job with following parameters:"
            + "1. {}:{}"
            + "2. {}:{}"
            + "3. {}:{}"
            + "4. {},{}"
            + "5. {},{}"
            + "6. {},{}"
            + "7. {},{}"
            + "8. {},{}",
        PUBSUB_INPUT_PROJECT_ID_PROP,
        inputProjectID,
        PUBSUB_INPUT_SUBSCRIPTION_PROP,
        pubsubInputSubscription,
        PUBSUB_TIMEOUT_MS_PROP,
        timeoutMs,
        PUBSUB_STREAMING_DURATION_SECONDS_PROP,
        streamingDuration,
        PUBSUB_TOTAL_RECEIVERS_PROP,
        totalReceivers,
        PUBSUB_BIGTABLE_OUTPUT_INSTANCE_ID_PROP,
        pubSubBigTableOutputInstanceId,
        PUBSUB_BIGTABLE_OUTPUT_PROJECT_ID_PROP,
        pubSubBigTableOutputProjectId,
        PUBSUB_BIGTABLE_OUTPUT_TABLE_PROP,
        pubSubBigTableOutputTable);
  }