in flink-table/flink-table-api-scala/src/main/scala/org/apache/flink/table/api/runtime/types/TupleSerializers.scala [1020:1391]
def register(newK: Kryo): Unit = {
newK.register(classOf[Tuple1[Any]], new Tuple1Serializer[Any])
newK.register(classOf[Tuple2[Any, Any]], new Tuple2Serializer[Any, Any])
newK.register(classOf[Tuple3[Any, Any, Any]], new Tuple3Serializer[Any, Any, Any])
newK.register(classOf[Tuple4[Any, Any, Any, Any]], new Tuple4Serializer[Any, Any, Any, Any])
newK.register(
classOf[Tuple5[Any, Any, Any, Any, Any]],
new Tuple5Serializer[Any, Any, Any, Any, Any])
newK.register(
classOf[Tuple6[Any, Any, Any, Any, Any, Any]],
new Tuple6Serializer[Any, Any, Any, Any, Any, Any]
)
newK.register(
classOf[Tuple7[Any, Any, Any, Any, Any, Any, Any]],
new Tuple7Serializer[Any, Any, Any, Any, Any, Any, Any]
)
newK.register(
classOf[Tuple8[Any, Any, Any, Any, Any, Any, Any, Any]],
new Tuple8Serializer[Any, Any, Any, Any, Any, Any, Any, Any]
)
newK.register(
classOf[Tuple9[Any, Any, Any, Any, Any, Any, Any, Any, Any]],
new Tuple9Serializer[Any, Any, Any, Any, Any, Any, Any, Any, Any]
)
newK.register(
classOf[Tuple10[Any, Any, Any, Any, Any, Any, Any, Any, Any, Any]],
new Tuple10Serializer[Any, Any, Any, Any, Any, Any, Any, Any, Any, Any]
)
newK.register(
classOf[Tuple11[Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any]],
new Tuple11Serializer[Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any]
)
newK.register(
classOf[Tuple12[Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any]],
new Tuple12Serializer[Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any]
)
newK.register(
classOf[Tuple13[Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any]],
new Tuple13Serializer[Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any]
)
newK.register(
classOf[Tuple14[Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any]],
new Tuple14Serializer[Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any]
)
newK.register(
classOf[Tuple15[Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any]],
new Tuple15Serializer[
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any]
)
newK.register(
classOf[
Tuple16[Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any, Any]],
new Tuple16Serializer[
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any]
)
newK.register(
classOf[
Tuple17[
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any]],
new Tuple17Serializer[
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any
]
)
newK.register(
classOf[
Tuple18[
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any]
],
new Tuple18Serializer[
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any
]
)
newK.register(
classOf[
Tuple19[
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any
]],
new Tuple19Serializer[
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any
]
)
newK.register(
classOf[
Tuple20[
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any
]],
new Tuple20Serializer[
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any
]
)
newK.register(
classOf[
Tuple21[
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any
]],
new Tuple21Serializer[
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any
]
)
newK.register(
classOf[
Tuple22[
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any
]],
new Tuple22Serializer[
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any,
Any
]
)
newK.register(Class.forName("scala.Tuple1$mcJ$sp"), new Tuple1LongSerializer)
newK.register(Class.forName("scala.Tuple1$mcI$sp"), new Tuple1IntSerializer)
newK.register(Class.forName("scala.Tuple1$mcD$sp"), new Tuple1DoubleSerializer)
newK.register(Class.forName("scala.Tuple2$mcJJ$sp"), new Tuple2LongLongSerializer)
newK.register(Class.forName("scala.Tuple2$mcJI$sp"), new Tuple2LongIntSerializer)
newK.register(Class.forName("scala.Tuple2$mcJD$sp"), new Tuple2LongDoubleSerializer)
newK.register(Class.forName("scala.Tuple2$mcIJ$sp"), new Tuple2IntLongSerializer)
newK.register(Class.forName("scala.Tuple2$mcII$sp"), new Tuple2IntIntSerializer)
newK.register(Class.forName("scala.Tuple2$mcID$sp"), new Tuple2IntDoubleSerializer)
newK.register(Class.forName("scala.Tuple2$mcDJ$sp"), new Tuple2DoubleLongSerializer)
newK.register(Class.forName("scala.Tuple2$mcDI$sp"), new Tuple2DoubleIntSerializer)
newK.register(Class.forName("scala.Tuple2$mcDD$sp"), new Tuple2DoubleDoubleSerializer)
}