override def update()

in src/main/scala/org/apache/spark/sql/datasketches/kll/aggregate/KllDoublesSketchAggMerge.scala [128:141]

• 14 lines of code
• 5 McCabe index (conditional complexity)

  override def update(union: KllDoublesSketch, input: InternalRow): KllDoublesSketch = {
    val value = sketchExpr.eval(input)
    if (value != null && value != None) {
      sketchExpr.dataType match {
        case KllDoublesSketchType =>
            union.merge(KllDoublesSketch.wrap(Memory.wrap(value.asInstanceOf[Array[Byte]])))
            union
        case _ => throw new IllegalArgumentException(
          s"Unsupported input type ${sketchExpr.dataType.catalogString}")
      }
    } else {
      union
    }
  }