aboutsummaryrefslogtreecommitdiff
path: root/external/flume/src
diff options
context:
space:
mode:
authorDavies Liu <davies@databricks.com>2015-02-09 11:42:52 -0800
committerReynold Xin <rxin@databricks.com>2015-02-09 11:42:52 -0800
commitafb131637d96e1e5e07eb8abf24e32e7f3b2304d (patch)
treee99ca6a3cb84cc402c2f8bdd1b560d51f84dc19d /external/flume/src
parentde7806048ac49a8bfdf44d8f87bc11cea1dfb242 (diff)
downloadspark-afb131637d96e1e5e07eb8abf24e32e7f3b2304d.tar.gz
spark-afb131637d96e1e5e07eb8abf24e32e7f3b2304d.tar.bz2
spark-afb131637d96e1e5e07eb8abf24e32e7f3b2304d.zip
[SPARK-5678] Convert DataFrame to pandas.DataFrame and Series
``` pyspark.sql.DataFrame.to_pandas = to_pandas(self) unbound pyspark.sql.DataFrame method Collect all the rows and return a `pandas.DataFrame`. >>> df.to_pandas() # doctest: +SKIP age name 0 2 Alice 1 5 Bob pyspark.sql.Column.to_pandas = to_pandas(self) unbound pyspark.sql.Column method Return a pandas.Series from the column >>> df.age.to_pandas() # doctest: +SKIP 0 2 1 5 dtype: int64 ``` Not tests by jenkins (they depends on pandas) Author: Davies Liu <davies@databricks.com> Closes #4476 from davies/to_pandas and squashes the following commits: 6276fb6 [Davies Liu] Convert DataFrame to pandas.DataFrame and Series
Diffstat (limited to 'external/flume/src')
0 files changed, 0 insertions, 0 deletions