[ https://issues.apache.org/jira/browse/SPARK-15183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Sachin Aggarwal closed SPARK-15183. ----------------------------------- Resolution: Duplicate > Adding outputMode to structure Streaming Experimental Api > --------------------------------------------------------- > > Key: SPARK-15183 > URL: https://issues.apache.org/jira/browse/SPARK-15183 > Project: Spark > Issue Type: Improvement > Components: SQL, Streaming > Reporter: Sachin Aggarwal > Priority: Trivial > > while experimenting with structure streaming. I found that mode() is used for > non-continuous queries while outputMode() is used for continuous queries. > ouputMode is not defined, so I have written the some raw implementation and > test cases just to make sure the streaming app works > Note:- > /** Start a query */ > private[sql] def startQuery( > name: String, > checkpointLocation: String, > df: DataFrame, > sink: Sink, > trigger: Trigger = ProcessingTime(0), > triggerClock: Clock = new SystemClock(), > outputMode: OutputMode = Append): ContinuousQuery = { > As per me outputMode should be defined before triggerClock, the constructor > with outputMode defined will be used more often then triggerClock. > I have added triggerClock() method also -- This message was sent by Atlassian JIRA (v6.3.4#6332) --------------------------------------------------------------------- To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org For additional commands, e-mail: issues-h...@spark.apache.org