Skip to content

Commit ae8c02d

Browse files
committed
Fixed some Scala style errors.
1 parent 216ab0c commit ae8c02d

File tree

3 files changed

+4
-3
lines changed

3 files changed

+4
-3
lines changed

mllib/src/main/scala/org/apache/spark/mllib/fpm/LocalPrefixSpan.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -65,7 +65,7 @@ private[fpm] object LocalPrefixSpan extends Logging with Serializable {
6565
if (element.length > 1 && flag == 1) {
6666
element.take(element.length - 1) ++ originalSequence
6767
} else if (element.length == 1 && flag == 1) {
68-
val firstPosition = originalSequence.indexOf(-1)
68+
val firstPosition = originalSequence.indexOf( -1 )
6969
if (firstPosition != -1) {
7070
originalSequence.drop(firstPosition + 1)
7171
} else {

mllib/src/main/scala/org/apache/spark/mllib/fpm/PrefixSpan.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -103,7 +103,7 @@ class PrefixSpan private (
103103

104104
private def sortSequences(sequences: RDD[Array[Int]]): RDD[Array[Int]] = {
105105
sequences.map { sequence =>
106-
val sortedArray: ArrayBuffer[Int] = ArrayBuffer()
106+
val sortedArray: ArrayBuffer[Int] = ArrayBuffer()
107107
var currentIndex = -1
108108
var nextIndex = 0
109109
while (nextIndex != -1) {

mllib/src/test/scala/org/apache/spark/mllib/fpm/PrefixSpanSuite.scala

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -175,7 +175,8 @@ class PrefixSpanSuite extends SparkFunSuite with MLlibTestSparkContext {
175175
"f,c,b:2")
176176
val intExpectedValue = expectedValue4
177177
.map(_.split(":"))
178-
.map(x => (x.apply(0).split(",").flatMap(-1 +: _.toArray.map(coder)).drop(1), x.apply(1).toLong))
178+
.map { x =>
179+
(x.apply(0).split(",").flatMap(-1 +: _.toArray.map(coder)).drop(1), x.apply(1).toLong) }
179180
assert(compareResult(intExpectedValue, result4.collect()))
180181
}
181182
}

0 commit comments

Comments
 (0)