aboutsummaryrefslogtreecommitdiff
path: root/examples
diff options
context:
space:
mode:
Diffstat (limited to 'examples')
-rw-r--r--examples/src/main/scala/org/apache/spark/examples/CassandraCQLTest.scala3
-rw-r--r--examples/src/main/scala/org/apache/spark/examples/CassandraTest.scala2
2 files changed, 5 insertions, 0 deletions
diff --git a/examples/src/main/scala/org/apache/spark/examples/CassandraCQLTest.scala b/examples/src/main/scala/org/apache/spark/examples/CassandraCQLTest.scala
index fa07c1e501..d1b9b8d398 100644
--- a/examples/src/main/scala/org/apache/spark/examples/CassandraCQLTest.scala
+++ b/examples/src/main/scala/org/apache/spark/examples/CassandraCQLTest.scala
@@ -16,6 +16,7 @@
*/
// scalastyle:off println
+ // scalastyle:off jobcontext
package org.apache.spark.examples
import java.nio.ByteBuffer
@@ -81,6 +82,7 @@ object CassandraCQLTest {
val job = new Job()
job.setInputFormatClass(classOf[CqlPagingInputFormat])
+ val configuration = job.getConfiguration
ConfigHelper.setInputInitialAddress(job.getConfiguration(), cHost)
ConfigHelper.setInputRpcPort(job.getConfiguration(), cPort)
ConfigHelper.setInputColumnFamily(job.getConfiguration(), KeySpace, InputColumnFamily)
@@ -135,3 +137,4 @@ object CassandraCQLTest {
}
}
// scalastyle:on println
+// scalastyle:on jobcontext
diff --git a/examples/src/main/scala/org/apache/spark/examples/CassandraTest.scala b/examples/src/main/scala/org/apache/spark/examples/CassandraTest.scala
index 2e56d24c60..1e679bfb55 100644
--- a/examples/src/main/scala/org/apache/spark/examples/CassandraTest.scala
+++ b/examples/src/main/scala/org/apache/spark/examples/CassandraTest.scala
@@ -16,6 +16,7 @@
*/
// scalastyle:off println
+// scalastyle:off jobcontext
package org.apache.spark.examples
import java.nio.ByteBuffer
@@ -130,6 +131,7 @@ object CassandraTest {
}
}
// scalastyle:on println
+// scalastyle:on jobcontext
/*
create keyspace casDemo;