Some debug messages for cassandra

jayunit100 · jayunit100 · commit 61fd8c96b1c2 · 2015-01-24T21:25:20.000-05:00
diff --git a/src/main/scala/sparkapps/ctakes/CTakesTwitterStreamingApp.scala b/src/main/scala/sparkapps/ctakes/CTakesTwitterStreamingApp.scala
@@ -188,8 +188,11 @@ object Driver {
               Thread.sleep(1)
               transactions.foreach({
                 xN =>
+                  System.out.println("Running Cassandra Insert..." + xN)
+                  System.out.println("Note that this can fail if cassandra isnt working...")
                   val xNtxt=xN.toString+" "+xN.getText;
-                  session.executeAsync(s"INSERT INTO streaming_test.key_value (key, value) VALUES ('$xNtxt' , $x)")}
+                  session.executeAsync(s"INSERT INTO streaming_test.key_value (key, value) VALUES ('$xNtxt' , $x)")
+              }
               )
               true;
             }

Original file line number	Diff line number	Diff line change
`@@ -188,8 +188,11 @@ object Driver {`
`188`	`188`	`Thread.sleep(1)`
`189`	`189`	`transactions.foreach({`
`190`	`190`	`xN =>`
	`191`	`+ System.out.println("Running Cassandra Insert..." + xN)`
	`192`	`+ System.out.println("Note that this can fail if cassandra isnt working...")`
`191`	`193`	`val xNtxt=xN.toString+" "+xN.getText;`
`192`		`- session.executeAsync(s"INSERT INTO streaming_test.key_value (key, value) VALUES ('$xNtxt' , $x)")}`
	`194`	`+ session.executeAsync(s"INSERT INTO streaming_test.key_value (key, value) VALUES ('$xNtxt' , $x)")`
	`195`	`+ }`
`193`	`196`	`)`
`194`	`197`	`true;`
`195`	`198`	`}`