One more question, if i have a function which takes RDD as a parameter, how do we mock an RDD ??
On Thu, Oct 29, 2015 at 5:20 PM, Priya Ch <learnings.chitt...@gmail.com> wrote: > How do we do it for Cassandra..can we use the same Mocking ? > EmbeddedCassandra Server is available with CassandraUnit. Can this be used > in Spark Code as well ? I mean with Scala code ? > > On Thu, Oct 29, 2015 at 5:03 PM, Василец Дмитрий <pronix.serv...@gmail.com > > wrote: > >> there is example how i mock mysql >> import org.scalamock.scalatest.MockFactory >> val connectionMock = mock[java.sql.Connection] >> val statementMock = mock[PreparedStatement] >> (conMock.prepareStatement(_: >> String)).expects(sql.toString).returning(statementMock) >> (statementMock.executeUpdate _).expects() >> >> >> On Thu, Oct 29, 2015 at 12:27 PM, Priya Ch <learnings.chitt...@gmail.com> >> wrote: >> >>> Hi All, >>> >>> For my Spark Streaming code, which writes the results to Cassandra >>> DB, I need to write Unit test cases. what are the available test frameworks >>> to mock the connection to Cassandra DB ? >>> >> >> >
