fixed up some wording

BryanCutler · BryanCutler · commit a5a1fbe7121c · 2018-06-12T13:22:30.000-07:00
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/api/python/PythonSQLUtils.scala b/sql/core/src/main/scala/org/apache/spark/sql/api/python/PythonSQLUtils.scala
@@ -37,16 +37,16 @@ private[sql] object PythonSQLUtils {
    * Python callable function to convert an RDD of serialized ArrowRecordBatches into
    * a [[DataFrame]].
    *
-   * @param arrowStreamRDD A JavaRDD of Arrow record batches as byte arrays.
+   * @param arrowBatchRDD A JavaRDD of serialized ArrowRecordBatches.
    * @param schemaString JSON Formatted Spark schema for Arrow batches.
    * @param sqlContext The active [[SQLContext]].
    * @return The converted [[DataFrame]].
    */
   def arrowStreamToDataFrame(
-      arrowStreamRDD: JavaRDD[Array[Byte]],
+      arrowBatchRDD: JavaRDD[Array[Byte]],
       schemaString: String,
       sqlContext: SQLContext): DataFrame = {
-    ArrowConverters.toDataFrame(arrowStreamRDD, schemaString, sqlContext)
+    ArrowConverters.toDataFrame(arrowBatchRDD, schemaString, sqlContext)
   }
 
   /**
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/arrow/ArrowConverters.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/arrow/ArrowConverters.scala
@@ -196,20 +196,20 @@ private[sql] object ArrowConverters {
    * Create a DataFrame from a JavaRDD of serialized ArrowRecordBatches.
    */
   private[sql] def toDataFrame(
-      arrowStreamRDD: JavaRDD[Array[Byte]],
+      arrowBatchRDD: JavaRDD[Array[Byte]],
       schemaString: String,
       sqlContext: SQLContext): DataFrame = {
     val schema = DataType.fromJson(schemaString).asInstanceOf[StructType]
     val timeZoneId = sqlContext.sessionState.conf.sessionLocalTimeZone
-    val rdd = arrowStreamRDD.rdd.mapPartitions { iter =>
+    val rdd = arrowBatchRDD.rdd.mapPartitions { iter =>
       val context = TaskContext.get()
       ArrowConverters.fromBatchIterator(iter, schema, timeZoneId, context)
     }
     sqlContext.internalCreateDataFrame(rdd, schema)
   }
 
   /**
-   * Read a file as an Arrow stream and create an RDD of serialized ArrowRecordBatches.
+   * Read a file as an Arrow stream and return an RDD of serialized ArrowRecordBatches.
    */
   private[sql] def readArrowStreamFromFile(sqlContext: SQLContext, filename: String):
   JavaRDD[Array[Byte]] = {
