0

我试着写这个

package org.apache.spark.h2o.utils

import water.fvec.{NewChunk, Frame, Chunk}
import water._

class Miss extends MRTask{
  override def map(c: Chunk, nc: NewChunk): Unit = {
    for (row <- 0 until c.len()) {
      if(  ){  
       nc.addNum(1)
      }
      else
       nc.addNum(0)
    }
  }
}

我可以输入什么if (...)来检查该行中是否有null值?

4

1 回答 1

1

H2O 提供Chunk专注于高效数据处理的 API,内部仅使用原始 Java 类型。因此,没有null检查,但您可以在给定行询问缺失值:

if (c.isNA(row)) { ... } else { ... }

或更短的版本为您的示例:

nc.addNum(c.isNA(row) ? 1 : 0)
于 2015-10-30T01:56:28.803 回答