We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 5170da2 commit 6fbc769Copy full SHA for 6fbc769
sql/core/src/main/scala/org/apache/spark/sql/SchemaRDD.scala
@@ -441,9 +441,10 @@ class SchemaRDD(
441
* Serializes the Array[Row] returned by SchemaRDD's takeSample(), using the same
442
* format as javaToPython and collectToPython. It is used by pyspark.
443
*/
444
- private[sql] def takeSampleToPython(withReplacement: Boolean,
445
- num: Int,
446
- seed: Long): JList[Array[Byte]] = {
+ private[sql] def takeSampleToPython(
+ withReplacement: Boolean,
+ num: Int,
447
+ seed: Long): JList[Array[Byte]] = {
448
val fieldTypes = schema.fields.map(_.dataType)
449
val pickle = new Pickler
450
new java.util.ArrayList(this.takeSample(withReplacement, num, seed).map { row =>
0 commit comments