Add the option to process multiple input schemas as part of a streaming job