[streaming] Source parallelism API update

The new preferred way is calling setParallelism() after adding the SourceFounction. This solution works any other operator.