def validateStreamingProperties()

in connector/src/main/scala/com/microsoft/kusto/spark/datasink/SparkIngestionProperties.scala [46:59]

14 lines of code
9 McCabe index (conditional complexity)


  def validateStreamingProperties(): Unit = {
    if ((this.ingestByTags != null && !this.ingestByTags.isEmpty)
      || (this.dropByTags != null && !this.dropByTags.isEmpty)
      || (this.additionalTags != null && !this.additionalTags.isEmpty)
      || Objects.nonNull(creationTime)) {
      throw new InvalidParameterException(
        "Ingest by tags / Drop by tags / Additional tags / Creation Time are not supported for streaming ingestion " +
          "through SparkIngestionProperties")
    }
    if (StringUtils.isNotEmpty(this.csvMapping)) {
      throw new InvalidParameterException(
        "CSVMapping cannot be used with Spark streaming ingestion")
    }
  }