input(output(
		id as integer,
		name as string,
		city as string
	),
	order: 0) ~> input1
input(output(
		id as integer,
		job as string,
		salary as integer
	),
	order: 1) ~> input2
input1, input2 join(input1@id == input2@id,
	joinType:'inner',
	broadcast: 'auto')~> Join1
Join1 select(mapColumn(
		id = input1@id,
		name,
		city,
		job,
		salary
	),
	skipDuplicateMapInputs: true,
	skipDuplicateMapOutputs: true) ~> Select1
Select1 output() ~> output1