def buildRow()

in spark/hbase-spark/src/main/scala/org/apache/hadoop/hbase/spark/DefaultSource.scala [305:330]

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

  def buildRow(fields: Seq[Field], result: Result): Row = {
    val r = result.getRow
    val keySeq = parseRowKey(r, catalog.getRowKey)
    val valueSeq = fields
      .filter(!_.isRowKey)
      .map {
        x =>
          val kv = result.getColumnLatestCell(Bytes.toBytes(x.cf), Bytes.toBytes(x.col))
          if (kv == null || kv.getValueLength == 0) {
            (x, null)
          } else {
            val v = CellUtil.cloneValue(kv)
            (
              x,
              x.dt match {
                // Here, to avoid arraycopy, return v directly instead of calling hbaseFieldToScalaType
                case BinaryType => v
                case _ => Utils.hbaseFieldToScalaType(x, v, 0, v.length)
              })
          }
      }
      .toMap
    val unionedRow = keySeq ++ valueSeq
    // Return the row ordered by the requested order
    Row.fromSeq(fields.map(unionedRow.get(_).getOrElse(null)))
  }