return newSerializer.getClass() == serializerClass ? TypeSerializerSchemaCompatibility.compatibleAsIs() : TypeSerializerSchemaCompatibility.incompatible(); | return newSerializer.getClass() == serializerSupplier.get().getClass() ? TypeSerializerSchemaCompatibility.compatibleAsIs() : TypeSerializerSchemaCompatibility.incompatible(); | serializerClass | serializerClass.get().getClass() | flink | edf6d59d315fc0f88d35d6686b39891864537620 | org.apache.flink.api.common.typeutils.SimpleTypeSerializerSnapshot | | _1 | serializerClass |
---|
_2 | serializerSupplier |
---|
| | | | Uses | True |