TargetMapper behavior has changed

[aletr]

TargetMapper behavior has changed. In the version without a DataFrame, com.nhl.link.move.runtime.task.createorupdate.TargetMapper#map throws an exception with the message like "Invalid key: " if duplicates were in the data source.

But in the version with a DataFrame, we can load duplicates in targed without any error messages.

In addition, even if we delete duplicates from the data source, duplicates will not be deleted from the target.

link-move/link-move/src/main/java/com/nhl/link/move/runtime/task/createorupdate/TargetMapper.java

Lines 22 to 34 in 124ebe0

	public DataFrame map(
	ObjectContext context,
	DataFrame sources,
	DataFrame targets) {
	Hasher lkm = r -> r.get(CreateOrUpdateSegment.KEY_COLUMN);
	Hasher rkm = r -> mapper.keyForTarget((DataObject) r.get(CreateOrUpdateSegment.TARGET_COLUMN));
	return sources
	.leftJoin().on(lkm, rkm).with(targets)
	.addColumn(CreateOrUpdateSegment.TARGET_CREATED_COLUMN, r -> isCreated(r.get(CreateOrUpdateSegment.TARGET_COLUMN)))
	.convertColumn(CreateOrUpdateSegment.TARGET_COLUMN, r -> createIfMissing(r, context));
	}