Re: does updateStateByKey accept a state that is a tuple?

2014-10-31 Thread spr
).max) } var DhcpSvrCum = newState.updateStateByKey[(Int, Time, Time)](updateDhcpState) -- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/does-updateStateByKey-accept-a-state-that-is-a-tuple-tp17756p17828.html Sent from the Apache Spark User List

does updateStateByKey accept a state that is a tuple?

2014-10-30 Thread spr
-tuple) value? How could this work with a tuple value? Thanks in advance. -- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/does-updateStateByKey-accept-a-state-that-is-a-tuple-tp17756.html Sent from the Apache Spark User List mailing list archive at Nabble.com

Re: does updateStateByKey accept a state that is a tuple?

2014-10-30 Thread spr
, Time, Time)]]) = Option[Tuple1[(Int, Time, Time)]] { ... } And I'm wondering whether those Tuple1()s are superfluous. Film at 11. -- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/does-updateStateByKey-accept-a-state-that-is-a-tuple-tp17756p17769