I didn't copy the exact error message, but basically the idea of the error message is that I cannot use the abstract class Tuple and instead, I should use Tuple1, Tuple2 and etc.
Thomas On Sun, Jul 10, 2022 at 12:47 PM Hemanga Borah <borah.hema...@gmail.com> wrote: > What error do you see? > > On Sun, Jul 10, 2022 at 6:30 AM Thomas Wang <w...@datability.io> wrote: > >> Hi, >> >> I have a use case where I need to call DataStream.keyBy() with keys >> loaded from a configuration. The number of keys and their data types are >> variables and is determined by the configuration. Once the configuration is >> loaded, they won't change. I'm trying to use the following key selector, >> but it looks like I cannot use Tuple as the key type here. Is there any way >> I can work around this as the rest of the logic of my application is the >> same. Thank you! >> >> public class SimpleRecordKeySelector<T extends BaseRecord> implements >> KeySelector<T, Tuple> >> >> Thomas >> >>
