def spTup2()

in scripts/tuple_serializers.scala [129:163]

• 35 lines of code
• 3 McCabe index (conditional complexity)

def spTup2(scalaVersion: String)(typeNm1: String, typeNm2: String): String =
  scalaVersion match {
    case "2.10" =>
      """
      class Tuple2TYPE1TYPE2Serializer extends KSerializer[Tuple2$mcSHORT1SHORT2$sp] with Serializable {
        setImmutable(true)
        def read(kser : Kryo, in : Input, cls : Class[Tuple2$mcSHORT1SHORT2$sp]) : Tuple2$mcSHORT1SHORT2$sp = {
          new Tuple2$mcSHORT1SHORT2$sp(in.readTYPE1, in.readTYPE2)
        }
        def write(kser : Kryo, out : Output, tup : Tuple2$mcSHORT1SHORT2$sp): Unit = {
          out.writeTYPE1(tup._1$mcSHORT1$sp)
          out.writeTYPE2(tup._2$mcSHORT2$sp)
        }
      }
      """
        .replace("TYPE1", typeNm1)
        .replace("SHORT1", typeMap(typeNm1))
        .replace("TYPE2", typeNm2)
        .replace("SHORT2", typeMap(typeNm2))
    case _ =>
      """
      class Tuple2TYPE1TYPE2Serializer extends KSerializer[Tuple2[TYPE1, TYPE2]] with Serializable {
        setImmutable(true)
        def read(kser : Kryo, in : Input, cls : Class[Tuple2[TYPE1, TYPE2]]) : Tuple2[TYPE1, TYPE2] = {
          new Tuple2[TYPE1, TYPE2](in.readTYPE1, in.readTYPE2)
        }
        def write(kser : Kryo, out : Output, tup : Tuple2[TYPE1, TYPE2]): Unit = {
          out.writeTYPE1(tup._1)
          out.writeTYPE2(tup._2)
        }
      }
      """
        .replace("TYPE1", typeNm1)
        .replace("TYPE2", typeNm2)
  }