使用withcolumn的方法的scala单元测试

ig9co6j1  于 2021-05-19  发布在  Spark
关注(0)|答案(0)|浏览(257)

我想为下面这样的方法编写一个scala单元测试。如果有什么建议,请告诉我。

private def appendDF(inDF: DataFrame, mdObj : Metadata): DataFrame =  {
    val columns = mdObj.getAffinityCols

    if (columns.isEmpty || columns.length < 10) {
      inDF
    } 
    else {
      var outDF = inDF
        .withColumn(Constants.columnName, lower(regexp_replace(col(dataSource),"""[\p{Space}\p{Punct}&&[^.]]""","")))
      outDF
    }
  }

谢谢,
兰迪

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题