Thanks Timo,
custom function worked for me with no further exceptions,
Thanks.
-----------------------------------------------
*Amol Suryawanshi*
Java Developer
am...@iprogrammer.com
*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 <sac...@iprogrammer.com>
------------------------------------------------
On Fri, Jul 27, 2018 at 6:10 PM, Timo Walther <twal...@apache.org> 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");
>>
>
>
>
