@@ -716,28 +716,11 @@ private[spel] class Typer(
716
716
if tc.runtimeObjType.canBeLooselyAssignedTo(Typed [java.util.Collection [_]]) ||
717
717
tc.runtimeObjType.klass.isArray =>
718
718
valid(tc.runtimeObjType.params.headOption.getOrElse(Unknown ))
719
- // it would have been caught by the next case, but since IndexedRecord does not have type parameters we
719
+ // it would have been caught by the next case, but since IndexedRecord and Row does not have type parameters we
720
720
// extract iterative type in different way
721
721
case tc : TypedObjectTypingResult
722
- if AssignabilityUtil .isAssignableToLoadableClass(
723
- tc.runtimeObjType.klass,
724
- " org.apache.avro.generic.IndexedRecord"
725
- ) =>
726
- valid(
727
- Typed .record(
728
- Map (
729
- " key" -> Typed .genericTypeClass(classOf [String ], List ()),
730
- " value" -> superTypeOfTypes(tc.fields.values)
731
- )
732
- )
733
- )
734
- // it would have been caught by the next case, but since flink row does not have type parameters we
735
- // extract iterative type in different way
736
- case tc : TypedObjectTypingResult
737
- if AssignabilityUtil .isAssignableToLoadableClass(
738
- tc.runtimeObjType.klass,
739
- " org.apache.flink.types.Row"
740
- ) =>
722
+ if List (" org.apache.avro.generic.IndexedRecord" , " org.apache.flink.types.Row" )
723
+ .exists(className => AssignabilityUtil .isAssignableToLoadableClass(tc.runtimeObjType.klass, className)) =>
741
724
valid(
742
725
Typed .record(
743
726
Map (
0 commit comments