alter name

src/main/scala/com/winhc/bigdata/spark/jobs/CompanyInfoCalculator.scala

@@ -1,11 +1,11 @@
 package com.winhc.bigdata.spark.jobs
 
-import com.winhc.bigdata.spark.udf.CommpanyMapping
+import com.winhc.bigdata.spark.udf.CompanyMapping
 import com.winhc.bigdata.spark.utils.SparkUtils
 import org.apache.commons.logging.LogFactory
 import org.apache.spark.sql.SparkSession
 
-object CompanyInfoCalculator extends CommpanyMapping {
+object CompanyInfoCalculator extends CompanyMapping {
 
   private val LOG = LogFactory.getLog(this.getClass)
 

src/main/scala/com/winhc/bigdata/spark/udf/CommpanyMapping.scala

@@ -5,7 +5,7 @@ import org.apache.commons.lang3.StringUtils
 import org.apache.spark.broadcast.Broadcast
 import org.apache.spark.sql.SparkSession
 
-trait CommpanyMapping {
+trait CompanyMapping {
 
 
   def prepare(spark: SparkSession): Unit = {