Skip to content

Commit de22f70

Browse files
author
jbencook
committed
[SPARK-4860][pyspark][sql] using sample() method from JavaSchemaRDD
1 parent b916442 commit de22f70

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

python/pyspark/sql.py

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -2095,9 +2095,8 @@ def sample(self, withReplacement, fraction, seed=None):
20952095
"""
20962096
assert fraction >= 0.0, "Negative fraction value: %s" % fraction
20972097
seed = seed if seed is not None else random.randint(0, sys.maxint)
2098-
rdd = self._jschema_rdd.baseSchemaRDD().sample(
2099-
withReplacement, fraction, long(seed))
2100-
return SchemaRDD(rdd.toJavaSchemaRDD(), self.sql_ctx)
2098+
rdd = self._jschema_rdd.sample(withReplacement, fraction, long(seed))
2099+
return SchemaRDD(rdd, self.sql_ctx)
21012100

21022101
def takeSample(self, withReplacement, num, seed=None):
21032102
"""Return a fixed-size sampled subset of this SchemaRDD.

0 commit comments

Comments
 (0)