Extended UniformPactRecordGenerator to produce keys and values starting at an offset
Extended DataSinkTask to support union input and added corresponding test case and integration test.