update comment

marmbrus · marmbrus · commit 71cc71785e4a · 2015-08-06T15:26:11.000-07:00
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/WriterContainer.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/WriterContainer.scala
@@ -361,8 +361,7 @@ private[sql] class DynamicPartitionWriterContainer(
         throw new SparkException("Task failed while writing rows.", cause)
     }
 
-    // The `row` argument is supposed to only contain partition column values which have been casted
-    // to strings.
+    /** Open and returns a new OutputWriter given a partition key. */
     def newOutputWriter(key: InternalRow): OutputWriter = {
       val partitionPath = getPartitionString(key).getString(0)
       val path = new Path(getWorkPath, partitionPath)

Original file line number	Diff line number	Diff line change
`@@ -361,8 +361,7 @@ private[sql] class DynamicPartitionWriterContainer(`
`361`	`361`	`throw new SparkException("Task failed while writing rows.", cause)`
`362`	`362`	`}`
`363`	`363`
`364`		- // The `row` argument is supposed to only contain partition column values which have been casted
`365`		`- // to strings.`
	`364`	`+ /** Open and returns a new OutputWriter given a partition key. */`
`366`	`365`	`def newOutputWriter(key: InternalRow): OutputWriter = {`
`367`	`366`	`val partitionPath = getPartitionString(key).getString(0)`
`368`	`367`	`val path = new Path(getWorkPath, partitionPath)`