osdir.com


[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Re: Access generic pojo fields


Thanks Timo,

custom function worked for me with no further exceptions,

Thanks.



-----------------------------------------------
*Amol Suryawanshi*
Java Developer
amols@xxxxxxxxxxxxxxx


*iProgrammer Solutions Pvt. Ltd.*



*Office 103, 104, 1st Floor Pride Portal,Shivaji Housing Society,
Bahiratwadi,Near Hotel JW Marriott, Off Senapati Bapat Road, Pune - 411016,
MH, INDIA.**Phone: +91 9689077510 | Skype: amols_iprogrammer*
www.iprogrammer.com <sachin@xxxxxxxxxxxxxxx>
------------------------------------------------

On Fri, Jul 27, 2018 at 6:10 PM, Timo Walther <twalthr@xxxxxxxxxx> wrote:

> I tried to reproduce your error but everything worked fine. Which Flink
> version are you using?
>
> Inner joins are a Flink 1.5 feature.
>
>
> Am 27.07.18 um 13:28 schrieb Amol S - iProgrammer:
>
> Table master = table1.filter("ns === 'Master'").select("o as master,
>> 'accessBasicDBObject(applicationId,o)' as primaryKey");
>> Table child1 = table1.filter("ns === 'Child1'").select("o  as child1,
>> 'accessBasicDBObject(applicationId,o)' as foreignKey");
>> Table child2 = table1.filter("ns === 'Child2'").select("o  as child2,
>> 'accessBasicDBObject(applicationId,o)' as foreignKey2");
>>
>> Table result = master.join(child1).where("pri
>> maryKey==foreignKey").join(child2).where("primaryKey==foreignKey2");
>>
>
>
>