sourceStream=spark.readStream.format("csv") 
.option("header",True) 
.schema(schema) 
.option("mode","dropMalformed") 
.option("maxFilesPerTrigger",1) 
.option("ignoreLeadingWhiteSpace",True) 
.load("dbfs:/FileStore/tables/stream")