Sign upLogin

hongbo-miao/hongbomiao.com

View on GitHub
Star
data-processing/hm-spark/applications/ingest-from-s3-to-kafka/src/main/scala/com/hongbomiao/IngestFromS3ToKafka.scala

Summary

Maintainability
A
1 hr
Test Coverage

Function main has 29 lines of code (exceeds 25 allowed). Consider refactoring.
Open

  def main(args: Array[String]): Unit = {
    val spark: SparkSession = SparkSession
      .builder()
      .config("spark.sql.extensions", "io.delta.sql.DeltaSparkSessionExtension")
      .config(
Severity: Minor
Found in data-processing/hm-spark/applications/ingest-from-s3-to-kafka/src/main/scala/com/hongbomiao/IngestFromS3ToKafka.scala - About 1 hr to fix

    There are no issues that match your filters.

    Category
    Status