Apache Zeppelin Notebook 中的 Spray-JSON

Question

我正在使用Zeppelin notebooks 为Spark Streaming 应用程序编写原型。它通过事件总线接收小的JSON 消息，我需要以（最好）分布式方式解析这些消息。我选择spray-json 来反序列化各个消息，但我似乎无法让它工作。我认为这是因为Zeppelin notebooks 是通过某种 REPL 接口解释的。

我直接从docs复制了这个样本：

case class Color(name: String, red: Int, green: Int, blue: Int)
object Color

object MyJsonProtocol extends DefaultJsonProtocol {
  implicit val colorFormat = jsonFormat4(Color.apply)
}

但它给了我以下输出：

defined class Color
defined object Color
warning: previously defined class Color is not a companion to object Color.
Companions must be defined together; you may wish to use :paste mode for this.
<console>:75: error: value apply is not a member of object Color
 Note: implicit value colorFormat is not applicable here because it comes after the application point and it lacks an explicit result type
         implicit val colorFormat = jsonFormat4(Color.apply)

还有其他方法可以让我反序列化Zeppelin notebook 中的消息吗？我不受spray-json 的约束，但它看起来确实是一个不错的库。

Answer 1

感谢@philantrovert 的评论，我能够让它工作。诀窍是将类和对象声明放在同一行，如下所示：

case class Color(name: String, red: Int, green: Int, blue: Int); object Color;