fixed comments

Author: hlin09

pkg/R/RDD.R

@@ -1275,14 +1275,14 @@ setMethod("aggregateRDD",
             Reduce(combOp, partitionList, zeroValue)
           })
 
-#' Pipes elements to a forked externel process.
+#' Pipes elements to a forked external process.
 #'
 #' The same as 'pipe()' in Spark.
 #'
-#' @param rdd The RDD whose elements are piped to the forked externel process.
-#' @param command The command to fork an externel process.
-#' @param env A named list to set environment variables of the externel process.
-#' @return A new RDD created by piping all elements to a forked externel process.
+#' @param rdd The RDD whose elements are piped to the forked external process.
+#' @param command The command to fork an external process.
+#' @param env A named list to set environment variables of the external process.
+#' @return A new RDD created by piping all elements to a forked external process.
 #' @rdname pipeRDD
 #' @export
 #' @examples

pkg/inst/tests/test_rdd.R

@@ -341,6 +341,11 @@ test_that("pipeRDD() on RDDs", {
   expected <- as.list(as.character(1:10))
   expect_equal(actual, expected)
 
+  trailed.rdd <- parallelize(sc, c("1", "", "2\n", "3\n\r\n"))
+  actual <- collect(pipeRDD(trailed.rdd, "sort"))
+  expected <- list("", "1", "2", "3")
+  expect_equal(actual, expected)
+  
   rev.nums <- 9:0
   rev.rdd <- parallelize(sc, rev.nums, 2L)
   actual <- collect(pipeRDD(rev.rdd, "sort"))

pkg/man/pipeRDD.Rd

@@ -4,21 +4,21 @@
 \name{pipeRDD}
 \alias{pipeRDD}
 \alias{pipeRDD,RDD,character-method}
-\title{Pipes elements to a forked externel process.}
+\title{Pipes elements to a forked external process.}
 \usage{
 pipeRDD(rdd, command, env = list())
 
 \S4method{pipeRDD}{RDD,character}(rdd, command, env = list())
 }
 \arguments{
-\item{rdd}{The RDD whose elements are piped to the forked externel process.}
+\item{rdd}{The RDD whose elements are piped to the forked external process.}
 
-\item{command}{The command to fork an externel process.}
+\item{command}{The command to fork an external process.}
 
-\item{env}{A named list to set environment variables of the externel process.}
+\item{env}{A named list to set environment variables of the external process.}
 }
 \value{
-A new RDD created by piping all elements to a forked externel process.
+A new RDD created by piping all elements to a forked external process.
 }
 \description{
 The same as 'pipe()' in Spark.