I believe what you are looking for is to set the queryName property
sourceData.writeStream() .queryName(queryName) ... .start() .awaitTermination();
Give that a try.