You can use string, and serialize all keys to a string.
Hemanga Borah <borah.hema...@gmail.com> 于2022年7月11日周一 09:49写道： > > 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 >>>>
