Hi, While working with structured streaming (aka SparkSQL Streams :)) I thought about adding
implicit def toProcessingTime(duration: Duration) = ProcessingTime(duration) What do you think? I think it'd improve the API: .trigger(ProcessingTime(10 seconds)) vs .trigger(10 seconds) (since it's not a release feature I didn't mean to file an issue in JIRA - please guide if needed). Pozdrawiam, Jacek Laskowski ---- https://medium.com/@jaceklaskowski/ Mastering Apache Spark http://bit.ly/mastering-apache-spark Follow me at https://twitter.com/jaceklaskowski --------------------------------------------------------------------- To unsubscribe, e-mail: dev-unsubscr...@spark.apache.org For additional commands, e-mail: dev-h...@spark.apache.org
