[streaming] removed input format wrappers from JobGraphBuilder