Thank you both for the information. Meanwhile I realized I had a mistmatch between the setters/getters names and fields, after correcting this, it worked. It seems that it works also without implementing the Key interface. My new question is, should it still implement the key interface? Is it expected to go wrong somewhere else without having it?
@Marton – the answer was that I need 2 of these fields to be used to do the keyBy (long, string) Dr. Radu Tudoran Research Engineer IT R&D Division [cid:image007.jpg@01CD52EB.AD060EE0] HUAWEI TECHNOLOGIES Duesseldorf GmbH European Research Center Riesstrasse 25, 80992 München E-mail: radu.tudo...@huawei.com Mobile: +49 15209084330 Telephone: +49 891588344173 HUAWEI TECHNOLOGIES Duesseldorf GmbH Hansaallee 205, 40549 Düsseldorf, Germany, www.huawei.com<http://www.huawei.com/> Registered Office: Düsseldorf, Register Court Düsseldorf, HRB 56063, Managing Director: Jingwen TAO, Wanzhou MENG, Lifang CHEN Sitz der Gesellschaft: Düsseldorf, Amtsgericht Düsseldorf, HRB 56063, Geschäftsführer: Jingwen TAO, Wanzhou MENG, Lifang CHEN This e-mail and its attachments contain confidential information from HUAWEI, which is intended only for the person or entity whose address is listed above. Any use of the information contained herein in any way (including, but not limited to, total or partial disclosure, reproduction, or dissemination) by persons other than the intended recipient(s) is prohibited. If you receive this e-mail in error, please notify the sender by phone or email immediately and delete it! From: Márton Balassi [mailto:balassi.mar...@gmail.com] Sent: Monday, November 30, 2015 5:42 PM To: user@flink.apache.org Subject: Re: key Hey Radu, To add to Till's comment: do you need the whole Event type to be the key are would you like to group the records based on the value of one of your attributes (the 2 longs, int or string as mentioned)? If the latter is true Flink comes with utilities to use standard types as keys. In the former case Till's comment holds. Best, Marton On Mon, Nov 30, 2015 at 5:38 PM, Till Rohrmann <trohrm...@apache.org<mailto:trohrm...@apache.org>> wrote: Hi Radu, if you want to use custom types as keys, then these custom types have to implement the Key interface. Cheers, Till On Mon, Nov 30, 2015 at 5:28 PM, Radu Tudoran <radu.tudo...@huawei.com<mailto:radu.tudo...@huawei.com>> wrote: Hi, I want to apply a “keyBy operator on a stream”. The string is of type MyEvent. This is a simple type that contains 2 longs and and int or string However, when applying this I get Exception in thread "main" org.apache.flink.api.common.InvalidProgramException: This type (GenericType<Event>) cannot be used as key. Can you give me a hint about a solution to this? Thanks Dr. Radu Tudoran Research Engineer IT R&D Division [cid:image007.jpg@01CD52EB.AD060EE0] HUAWEI TECHNOLOGIES Duesseldorf GmbH European Research Center Riesstrasse 25, 80992 München E-mail: radu.tudo...@huawei.com<mailto:radu.tudo...@huawei.com> Mobile: +49 15209084330<tel:%2B49%2015209084330> Telephone: +49 891588344173<tel:%2B49%20891588344173> HUAWEI TECHNOLOGIES Duesseldorf GmbH Hansaallee 205, 40549 Düsseldorf, Germany, www.huawei.com<http://www.huawei.com/> Registered Office: Düsseldorf, Register Court Düsseldorf, HRB 56063, Managing Director: Jingwen TAO, Wanzhou MENG, Lifang CHEN Sitz der Gesellschaft: Düsseldorf, Amtsgericht Düsseldorf, HRB 56063, Geschäftsführer: Jingwen TAO, Wanzhou MENG, Lifang CHEN This e-mail and its attachments contain confidential information from HUAWEI, which is intended only for the person or entity whose address is listed above. Any use of the information contained herein in any way (including, but not limited to, total or partial disclosure, reproduction, or dissemination) by persons other than the intended recipient(s) is prohibited. If you receive this e-mail in error, please notify the sender by phone or email immediately and delete it!
