in scripts/tuple_serializers.scala [99:127]
def spTup1(scalaVersion: String)(typeNm: String): String =
scalaVersion match {
case "2.10" =>
"""
class Tuple1TYPESerializer extends KSerializer[Tuple1$mcSHORT$sp] with Serializable {
setImmutable(true)
def read(kser : Kryo, in : Input, cls : Class[Tuple1$mcSHORT$sp]) : Tuple1$mcSHORT$sp = {
new Tuple1$mcSHORT$sp(in.readTYPE)
}
def write(kser : Kryo, out : Output, tup : Tuple1$mcSHORT$sp): Unit = {
out.writeTYPE(tup._1$mcSHORT$sp)
}
}
""".replace("TYPE", typeNm).replace("SHORT", typeMap(typeNm))
case _ =>
"""
class Tuple1TYPESerializer extends KSerializer[Tuple1[TYPE]] with Serializable {
setImmutable(true)
def read(kser : Kryo, in : Input, cls : Class[Tuple1[TYPE]]) : Tuple1[TYPE] = {
new Tuple1[TYPE](in.readTYPE)
}
def write(kser : Kryo, out : Output, tup : Tuple1[TYPE]): Unit = {
out.writeTYPE(tup._1)
}
}
""".replace("TYPE", typeNm)
}