[DataFrame] Implementing write methods#1918
[DataFrame] Implementing write methods#1918devin-petersohn merged 5 commits intoray-project:masterfrom
Conversation
|
Test PASSed. |
|
Test PASSed. |
|
Test FAILed. |
|
Jenkins, retest this please. |
|
Test FAILed. |
|
Test FAILed. |
|
Test PASSed. |
|
Test FAILed. |
|
Test FAILed. |
devin-petersohn
left a comment
There was a problem hiding this comment.
Looks great, just a quick formatting change.
python/ray/dataframe/test/test_io.py
Outdated
| import pandas as pd | ||
| from ray.dataframe.utils import to_pandas | ||
| import ray.dataframe.io as io | ||
| import ray.dataframe as rpd |
There was a problem hiding this comment.
Please change to import ray.dataframe as pd.
python/ray/dataframe/test/test_io.py
Outdated
| @@ -6,7 +6,7 @@ | |||
| import numpy as np | |||
| import pandas as pd | |||
There was a problem hiding this comment.
Please change to import pandas.
There was a problem hiding this comment.
Formatting done.
|
Test PASSed. |
|
Test FAILed. |
|
Jenkins, retest this please. |
|
Test PASSed. |
|
Merged, thanks @kunalgosar! |
* master: updates (ray-project#1958) Pin Cython in autoscaler development example. (ray-project#1951) Incorporate C++ Buffer management and Seal global threadpool fix from arrow (ray-project#1950) [XRay] Add consistency check for protocol between node_manager and local_scheduler_client (ray-project#1944) Remove smart_open install. (ray-project#1943) [DataFrame] Fully implement append, concat and join (ray-project#1932) [DataFrame] Fix for __getitem__ string indexing (ray-project#1939) [DataFrame] Implementing write methods (ray-project#1918) [rllib] arr[end] was excluded when end is not None (ray-project#1931) [DataFrame] Implementing API correct groupby with aggregation methods (ray-project#1914) Handle interrupts correctly for ASIO synchronous reads and writes. (ray-project#1929) [DataFrame] Adding read methods and tests (ray-project#1712) Allow task_table_update to fail when tasks are finished. (ray-project#1927) [rllib] Contribute DDPG to RLlib (ray-project#1877) [xray] Workers blocked in a `ray.get` release their resources (ray-project#1920) Raylet task dispatch and throttling worker startup (ray-project#1912) [DataFrame] Eval fix (ray-project#1903)
* 'master' of https://github.com/ray-project/ray: [rllib] Fix broken link in docs (ray-project#1967) [DataFrame] Sample implement (ray-project#1954) [DataFrame] Implement Inter-DataFrame operations (ray-project#1937) remove UniqueIDHasher (ray-project#1957) [rllib] Add DDPG documentation, rename DDPG2 <=> DDPG (ray-project#1946) updates (ray-project#1958) Pin Cython in autoscaler development example. (ray-project#1951) Incorporate C++ Buffer management and Seal global threadpool fix from arrow (ray-project#1950) [XRay] Add consistency check for protocol between node_manager and local_scheduler_client (ray-project#1944) Remove smart_open install. (ray-project#1943) [DataFrame] Fully implement append, concat and join (ray-project#1932) [DataFrame] Fix for __getitem__ string indexing (ray-project#1939) [DataFrame] Implementing write methods (ray-project#1918) [rllib] arr[end] was excluded when end is not None (ray-project#1931) [DataFrame] Implementing API correct groupby with aggregation methods (ray-project#1914)
This PR is rebased on #1712
This PR implements the write IO functions by falling back on pandas. This is a temporary placeholder and throws a warning for performance degradation.
Opening in favor of #1713