Skip to content

Commit f3776d6

Browse files
feat(#286): fix missing implementation of resolveSchemaCompatibility
1 parent a3a6b70 commit f3776d6

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

modules/flink-common-api/src/main/scala/org/apache/flinkx/api/serializer/orderingSerializers.scala

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -254,6 +254,10 @@ class ReverseOrderingSerializerSnapshot[A](private var child: TypeSerializer[Ord
254254
override def readSnapshot(readVersion: Int, in: DataInputView, userCodeClassLoader: ClassLoader): Unit = {
255255
child = TypeSerializerSnapshot.readVersionedSnapshot[Ordering[A]](in, userCodeClassLoader).restoreSerializer()
256256
}
257+
override def resolveSchemaCompatibility(
258+
oldSerializerSnapshot: TypeSerializerSnapshot[Ordering[A]]
259+
): TypeSerializerSchemaCompatibility[Ordering[A]] =
260+
TypeSerializerSchemaCompatibility.compatibleAsIs()
257261
override def restoreSerializer(): TypeSerializer[Ordering[A]] = new ReverseOrderingSerializer[A](child)
258262
}
259263

@@ -288,5 +292,9 @@ class OptionOrderingSerializerSnapshot[A](private var child: TypeSerializer[Orde
288292
override def readSnapshot(readVersion: Int, in: DataInputView, userCodeClassLoader: ClassLoader): Unit = {
289293
child = TypeSerializerSnapshot.readVersionedSnapshot[Ordering[A]](in, userCodeClassLoader).restoreSerializer()
290294
}
295+
override def resolveSchemaCompatibility(
296+
oldSerializerSnapshot: TypeSerializerSnapshot[Ordering[Option[A]]]
297+
): TypeSerializerSchemaCompatibility[Ordering[Option[A]]] =
298+
TypeSerializerSchemaCompatibility.compatibleAsIs()
291299
override def restoreSerializer(): TypeSerializer[Ordering[Option[A]]] = new OptionOrderingSerializer[A](child)
292300
}

0 commit comments

Comments
 (0)