source(output(
		id as integer,
		name as string,
		city as string
	),
	allowSchemaDrift: true,
	validateSchema: false,
	ignoreNoFilesFound: false) ~> source1
source(output(
		id as integer,
		job as string,
		salary as integer
	),
	allowSchemaDrift: true,
	validateSchema: false,
	ignoreNoFilesFound: false) ~> source2
source1, source2, source2 compose(mapColumn(
		id = source1@id,
		name,
		city
	),mapColumn(
		id = source2@id,
		job,
		salary
	),
	composition: 'sample_flowlet3') ~> Flowlet1@(output1)
Flowlet1@output1 sink(allowSchemaDrift: true,
	validateSchema: false,
	skipDuplicateMapInputs: true,
	skipDuplicateMapOutputs: true,
	store: 'cache',
	format: 'inline',
	output: false,
	saveOrder: 1) ~> sink1