如何使用Scala序列化Spark Streaming中的org.joda.time.DateTime？

import org.joda.time.DateTime
import java.io.Serializable

class SerializableWrapper(val dateTime: DateTime) extends Serializable {
  def getDateTime: DateTime = dateTime
}

import org.apache.spark.streaming._
import org.joda.time.DateTime

val ssc = new StreamingContext(sparkConf, Seconds(1))

val dateTime = new DateTime()  // 创建org.joda.time.DateTime对象
val serializableWrapper = new SerializableWrapper(dateTime)  // 将DateTime对象包装在SerializableWrapper中

val stream = ssc.receiverStream(new CustomReceiver(serializableWrapper))  // 使用SerializableWrapper对象

// 其他Spark Streaming的操作...

ssc.start()
ssc.awaitTermination()