[大数据]Spark clip函数

package com.hadwinling.woa

import breeze.linalg.clip
import org.apache.log4j.{Level, Logger}
import org.apache.spark.{SparkConf, SparkContext}

/**
 * @Classname ClipDemo 
 * @Description TODO
 * @Date 2021/8/13 12:09
 * @Created by ${hadwinling}
 */
object ClipDemo {
  def main(args: Array[String]): Unit = {
    Logger.getLogger("org").setLevel(Level.ERROR)
    val conf = new SparkConf().setAppName("SparkWOA").setMaster("local[*]")
    val sc: SparkContext = new SparkContext(conf)

    /**
     * clip() : 就数组控制在lb和ub之间，如果小于lb则使用lb ，如果大于ub则使用ub
     */

    val ints = Array(1, 2, 3, 4)
    val ints1 = clip(ints, -10, 10)
    ints1.foreach(println)

    println("=======================")

    val int2 = Array(1, 2, 3, 40)
    val ints2 = clip(int2, -10, 10)
    ints2.foreach(println)

    sc.stop()
  }

}

结果：