Toggle navigation
Home
org.apache.flink.api.common.typeutils.TypeSerializerSchemaCompatibility to org.apache.flink.api.common.typeutils.TypeSerializer
No. of Instances - 1
No. of Commits - 1
No. of Projects - {'flink'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Cascading Type Change (Different)
TypeSafeDiagnosingMatcher<TypeSerializerSchemaCompatibility<TestEnum>>
to
TypeSafeMatcher<EnumSerializer<TestEnum>>
Update Anonymous class
{ @Override protected boolean matchesSafely( TypeSerializerSchemaCompatibility<TestEnum> item, Description mismatchDescription){ if (!item.isCompatibleWithReconfiguredSerializer()) { mismatchDescription.appendText("compatibility mismatch ").appendValue(item); return false; } EnumSerializer<TestEnum> reconfiguredSerialized=(EnumSerializer<TestEnum>)item.getReconfiguredSerializer(); if (!Arrays.equals(reconfiguredSerialized.getValues(),expectedEnumValues)) { mismatchDescription.appendText("reconfigured values are ").appendValueList("{",", ","}",reconfiguredSerialized.getValues()); return false; } return true; } @Override public void describeTo( Description description){ description.appendText("EnumSerializer with values ").appendValueList("{",", ","}",expectedEnumValues); } }
to
{ @Override protected boolean matchesSafely( EnumSerializer<TestEnum> reconfiguredSerialized){ return Arrays.equals(reconfiguredSerialized.getValues(),expectedEnumValues); } @Override public void describeTo( Description description){ description.appendText("EnumSerializer with values ").appendValueList("{",", ","}",expectedEnumValues); } }
Rename Variable
hasExpectedEnumSerializer
to
enumSerializerWith