I have developed a job thats supposed to track changes by comparing two sources and create an output insert. My tMap has a variable expression defined as below. My records are in millions of rows and performance it not very good. Any ideas please. - thank you in advance.
source1.customerid.equals(source2.customerid) && source1.hashing.equals(source2.hashing)? "no change":"changed"
It seems you don't have a join between input rows (not sure because you have reduce everything). You should (must) have a left outer join then, depending on result you'll decide which output flow to address.
It seems you don't have a join between input rows (not sure because you have reduce everything). You should (must) have a left outer join then, depending on result you'll decide which output flow to address.
