feat: Update Sourcer interface for propagating totalPartitions (#343) #170

Job	Run time
Build, Tag, and Push Image (examples/map/flatmap)	1m 55s
Build, Tag, and Push Image (examples/mapstream/flatmap_stream)	1m 56s
Build, Tag, and Push Image (examples/map/forward_message)	1m 58s
Build, Tag, and Push Image (examples/sideinput/simple_sideinput/udf)	2m 6s
Build, Tag, and Push Image (examples/map/multiproc_map)	1m 53s
Build, Tag, and Push Image (examples/map/even_odd)	1m 51s
Build, Tag, and Push Image (examples/sink/async_log)	2m 8s
Build, Tag, and Push Image (examples/reduce/counter)	2m 7s
Build, Tag, and Push Image (examples/sideinput/simple_sideinput)	1m 55s
Build, Tag, and Push Image (examples/reducestream/sum)	1m 57s
Build, Tag, and Push Image (examples/sink/log)	2m 9s
Build, Tag, and Push Image (examples/reducestream/counter)	2m 5s
Build, Tag, and Push Image (examples/batchmap/flatmap)	2m 6s
Build, Tag, and Push Image (examples/accumulator/streamsorter)	2m 1s
Build, Tag, and Push Image (examples/sourcetransform/event_time_filter)	2m 6s
Build, Tag, and Push Image (examples/source/simple_source)	2m 5s
	32m 18s

Provide feedback