Skip to content

Commit d4e9f85

Browse files
committed
Code review.
1 parent a836a37 commit d4e9f85

File tree

2 files changed

+5
-5
lines changed

2 files changed

+5
-5
lines changed

core/src/main/scala/org/apache/spark/SparkContext.scala

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1758,7 +1758,7 @@ object SparkContext extends Logging {
17581758

17591759
@deprecated("Replaced by implicit functions in WritableConverter. This is kept here only for " +
17601760
"backward compatibility.", "1.2.0")
1761-
def writableWritableConverter[T <: Writable]() =
1761+
def writableWritableConverter[T <: Writable](): WritableConverter[T] =
17621762
WritableConverter.writableWritableConverter()
17631763

17641764
/**
@@ -2017,15 +2017,15 @@ object WritableConverter {
20172017
simpleWritableConverter[Boolean, BooleanWritable](_.get)
20182018

20192019
implicit def bytesWritableConverter(): WritableConverter[Array[Byte]] = {
2020-
simpleWritableConverter[Array[Byte], BytesWritable](bw =>
2020+
simpleWritableConverter[Array[Byte], BytesWritable] { bw =>
20212021
// getBytes method returns array which is longer then data to be returned
20222022
Arrays.copyOfRange(bw.getBytes, 0, bw.getLength)
2023-
)
2023+
}
20242024
}
20252025

20262026
implicit def stringWritableConverter(): WritableConverter[String] =
20272027
simpleWritableConverter[String, Text](_.toString)
20282028

2029-
implicit def writableWritableConverter[T <: Writable]() =
2029+
implicit def writableWritableConverter[T <: Writable](): WritableConverter[T] =
20302030
new WritableConverter[T](_.runtimeClass.asInstanceOf[Class[T]], _.asInstanceOf[T])
20312031
}

core/src/main/scala/org/apache/spark/rdd/RDD.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -70,7 +70,7 @@ object RDD {
7070
}
7171

7272
implicit def rddToOrderedRDDFunctions[K : Ordering : ClassTag, V: ClassTag](rdd: RDD[(K, V)])
73-
: OrderedRDDFunctions[K, V] = {
73+
: OrderedRDDFunctions[K, V, (K, V)] = {
7474
new OrderedRDDFunctions[K, V, (K, V)](rdd)
7575
}
7676

0 commit comments

Comments
 (0)