Skip to content

Commit 8a4a3d4

Browse files
committed
[SPARK-7929] Remove Bagel examples & whitespace fix for examples.
1 parent 0077af2 commit 8a4a3d4

File tree

15 files changed

+31
-485
lines changed

15 files changed

+31
-485
lines changed

examples/src/main/scala/org/apache/spark/examples/CassandraCQLTest.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -104,8 +104,8 @@ object CassandraCQLTest {
104104

105105
val casRdd = sc.newAPIHadoopRDD(job.getConfiguration(),
106106
classOf[CqlPagingInputFormat],
107-
classOf[java.util.Map[String,ByteBuffer]],
108-
classOf[java.util.Map[String,ByteBuffer]])
107+
classOf[java.util.Map[String, ByteBuffer]],
108+
classOf[java.util.Map[String, ByteBuffer]])
109109

110110
println("Count: " + casRdd.count)
111111
val productSaleRDD = casRdd.map {
@@ -118,7 +118,7 @@ object CassandraCQLTest {
118118
case (productId, saleCount) => println(productId + ":" + saleCount)
119119
}
120120

121-
val casoutputCF = aggregatedRDD.map {
121+
val casoutputCF = aggregatedRDD.map {
122122
case (productId, saleCount) => {
123123
val outColFamKey = Map("prod_id" -> ByteBufferUtil.bytes(productId))
124124
val outKey: java.util.Map[String, ByteBuffer] = outColFamKey

examples/src/main/scala/org/apache/spark/examples/LocalLR.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@ object LocalLR {
3939

4040
def generateData: Array[DataPoint] = {
4141
def generatePoint(i: Int): DataPoint = {
42-
val y = if(i % 2 == 0) -1 else 1
42+
val y = if (i % 2 == 0) -1 else 1
4343
val x = DenseVector.fill(D){rand.nextGaussian + y * R}
4444
DataPoint(x, y)
4545
}

examples/src/main/scala/org/apache/spark/examples/SparkALS.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -117,7 +117,7 @@ object SparkALS {
117117
var us = Array.fill(U)(randomVector(F))
118118

119119
// Iteratively update movies then users
120-
val Rc = sc.broadcast(R)
120+
val Rc = sc.broadcast(R)
121121
var msb = sc.broadcast(ms)
122122
var usb = sc.broadcast(us)
123123
for (iter <- 1 to ITERATIONS) {

examples/src/main/scala/org/apache/spark/examples/SparkLR.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -44,7 +44,7 @@ object SparkLR {
4444

4545
def generateData: Array[DataPoint] = {
4646
def generatePoint(i: Int): DataPoint = {
47-
val y = if(i % 2 == 0) -1 else 1
47+
val y = if (i % 2 == 0) -1 else 1
4848
val x = DenseVector.fill(D){rand.nextGaussian + y * R}
4949
DataPoint(x, y)
5050
}

examples/src/main/scala/org/apache/spark/examples/bagel/PageRankUtils.scala

Lines changed: 0 additions & 112 deletions
This file was deleted.

examples/src/main/scala/org/apache/spark/examples/bagel/WikipediaPageRank.scala

Lines changed: 0 additions & 106 deletions
This file was deleted.

0 commit comments

Comments
 (0)