Here is the documentation of the Tuple class: https://nightlies.apache.org/flink/flink-docs-master/api/java/org/apache/flink/api/java/tuple/Tuple.html
If you need a concrete class, you can go from Tuple0 to Tuple25. On Sun, Jul 10, 2022 at 5:43 PM Thomas Wang <w...@datability.io> wrote: > 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 >>> >>>
