我使用dataSet API,我有两种案例类。case class Geo(country:Int, province:Int, city:Int, county:Int)
eventType/值对,它的值是一个case类。val groupedSortedData = dataKeyValue groupBy 0 at o
我正在尝试使用Scala的case类构建一个数据集(我希望在元组上使用case类,因为我希望按名称连接字段)。$.ensureSerializable(ClosureCleaner.scala:179) at org.apache.flink.api.scala.ClosureCleaner$.clean(ClosureCleaner.scala:171) at org.apache.flink.api.sc
问题是在进行案例类提取时,映射函数中存在问题。case类不可序列化。我已经隐式地定义了DefaultFormats格式。import org.json4s._import scala.util.Try
case class CC(key:String$.ensureSerializable(ClosureCleaner.scala:172) at org.apache.flink.api.<
我使用Scala和Flink 1.0快照在leftOuterJoin上执行DataSet,并得到以下异常: at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$handleMessage$1$$anonfun$applyOrElse$5.apply
我正在Scala中构建一个Apache应用程序,它从Kafka总线读取流数据,然后对其执行汇总操作。Kafka的数据是Avro格式的,需要一个特殊的反序列化类。我找到了这个scala类AvroDeserializationScehema ():import org.apache.avro.io.BinaryDecoder/** Case class to hold the Device data. */
case</e