我们正在使用scala代码运行spark（1.5.2）中的作业，它连接到cassandra。新的spark-cassandra-connector（1.5）依赖于cassandra-driver-core-2.2.0-RC 3。
2.2.0-RC 3中删除了DataType序列化/反序列化方法。
序列化/反序列化的另一种方法是什么？
13: error: value serialize is not a member of com.datastax.driver.core.DataType.CollectionType
[ERROR] implicit def ListString2ByteBuffer(list : List[String]): ByteBuffer =
DataType.list(DataType.text()).serialize(list.asJava, ProtocolVersion.NEWEST_SUPPORTED);
1条答案
按热度按时间5t7ly7z51#
请参阅：Upgrade guide
DataType不再引用TypeCodec，因此处理数据类型得序列化与反序列化得方法已被删除...现在必须直接在TypeCodec上调用这些方法.
要获得TypeCodec，您可以使用以下代码：