apache-zeppelin - 使用时找不到齐柏林飞艇导入的类

Question

在 zeppelin 上使用 spark 时出现奇怪的错误。使用时找不到导入的类。代码示例是:

%spark
import java.io.Serializable
import java.text.{ParseException, SimpleDateFormat}
import java.util.{Calendar, SimpleTimeZone}

class Pos(val pos: String) extends Serializable {

if (pos.length != 12) {
  throw new IllegalArgumentException(s"[${pos}] seems not a valid pos 
 string")
}

private val cstFormat = new SimpleDateFormat("yyyyMMddHHmm")
private val utcFormat = new SimpleDateFormat("yyyyMMddHHmm")
}

我收到以下错误:

import java.io.Serializable
import java.text.{ParseException, SimpleDateFormat}
import java.util.{Calendar, SimpleTimeZone}
<console>:17: error: not found: type SimpleDateFormat
     private val cstFormat = new SimpleDateFormat("yyyyMMddHHmm")
                                 ^
<console>:18: error: not found: type SimpleDateFormat
     private val utcFormat = new SimpleDateFormat("yyyyMMddHHmm")
                                 ^
<console>:25: error: not found: type ParseException
       case e: ParseException => throw newIllegalArgumentException(s"
               ^

有什么方法可以解决这个错误吗？zeppelin版本是0.7.3，spark版本是2.1提前致谢!

Answer 1

看来你必须在类定义中编写导入:

%spark
class Pos(val pos: String) extends Serializable {

    import java.io.Serializable
    import java.text.{ParseException, SimpleDateFormat}
    import java.util.{Calendar, SimpleTimeZone}

    if (pos.length != 12) {
      throw new IllegalArgumentException(s"[${pos}] seems not a valid pos string")
    }

    private val cstFormat = new SimpleDateFormat("yyyyMMddHHmm")
    private val utcFormat = new SimpleDateFormat("yyyyMMddHHmm")
}

如果您需要导入类构造函数的参数，您可以在一个对象中创建您的类，然后在以下段落中调用 YourObject.YourClass(args)。参见 this question再举个例子。