Skip to content
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -106,7 +106,7 @@ private[python] class WritableToJavaConverter(
}

/**
* A converter that converts common types to [[org.apache.hadoop.io.Writable]]. Note that array
* A converter that converts common types to [[org.apache.hadoop.io.Writable]]. @note Array
* types are not supported since the user needs to subclass [[org.apache.hadoop.io.ArrayWritable]]
* to set the type properly. See [[org.apache.spark.api.python.DoubleArrayWritable]] and
* [[org.apache.spark.api.python.DoubleArrayToWritableConverter]] for an example. They are used in
Expand All @@ -115,7 +115,7 @@ private[python] class WritableToJavaConverter(
private[python] class JavaToWritableConverter extends Converter[Any, Writable] {

/**
* Converts common data types to [[org.apache.hadoop.io.Writable]]. Note that array types are not
* Converts common data types to [[org.apache.hadoop.io.Writable]]. @note Array types are not
* supported out-of-the-box.
*/
private def convertToWritable(obj: Any): Writable = {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -760,7 +760,7 @@ private[spark] object PythonRDD extends Logging {

/**
* Output a Python RDD of key-value pairs as a Hadoop SequenceFile using the Writable types
* we convert from the RDD's key and value types. Note that keys and values can't be
* we convert from the RDD's key and value types. @note Keys and values can't be
* [[org.apache.hadoop.io.Writable]] types already, since Writables are not Java
* `Serializable` and we can't peek at them. The `path` can be on any Hadoop file system.
*/
Expand Down