Hi all,

I'm trying to create a MapState<Integer, Tuple3<Set<String>, Set<String>,
List<myClass>>> for KeyedBroadcastProcessFunction but I'm not sure how to
initialize its MapStateDescriptor.

I have written it in two ways as given below and my IDE isn't showing an
error either way (haven't tested on runtime yet).

I'd really appreciate if anyone can tell me which way is correct and if not
what's the best way to give Type Hints for  Tuple3<Set<String>,
Set<String>, List<myClass>>

myClass is POJO type.

Code Snippet 1:

        private final MapStateDescriptor<Integer, Tuple3<Set<String>,
Set<String>, List<myClass>>> outStateDesc =
                new MapStateDescriptor<>(
                        "neighbours",
                        BasicTypeInfo.INT_TYPE_INFO,
                        new TupleTypeInfo<>(TypeInformation.of(new
TypeHint<Set>() {}),
                                TypeInformation.of(new TypeHint<Set>() {}),
                                new ListTypeInfo<>(myClass.class)));



Code Snippet 2:
        private final MapStateDescriptor<Integer, Tuple3<Set<String>,
Set<String>, List<myClass>>> outStateDesc =
                new MapStateDescriptor<>(
                        "neighbours",
                        BasicTypeInfo.INT_TYPE_INFO,
                        TypeInformation.of(new TypeHint<Tuple3<Set<String>,
Set<String>, List<myClass>>>(){}));


Best Regards,
Komal

Reply via email to