@@ -63,25 +63,6 @@ def __init__(self):
6363 import pyarrow
6464 import pyarrow .parquet
6565 except ImportError :
66- < << << << HEAD
67- raise ImportError ("pyarrow is required for parquet support\n \n "
68- "you can install via conda\n "
69- "conda install pyarrow -c conda-forge\n "
70- "\n or via pip\n "
71- "pip install -U pyarrow\n " )
72-
73- if LooseVersion (pyarrow .__version__ ) < LooseVersion ('0.4.1' ):
74- raise ImportError ("pyarrow >= 0.4.1 is required for parquet"
75- "support\n \n "
76- "you can install via conda\n "
77- "conda install pyarrow -c conda-forge\n "
78- "\n or via pip\n "
79- "pip install -U pyarrow\n " )
80-
81- self ._pyarrow_lt_050 = LooseVersion (pyarrow .__version__ ) < '0.5.0'
82- self ._pyarrow_lt_060 = LooseVersion (pyarrow .__version__ ) < '0.6.0'
83- self ._pyarrow_lt_070 = LooseVersion (pyarrow .__version__ ) < '0.7.0'
84- == == == =
8566 raise ImportError (
8667 "pyarrow is required for parquet support\n \n "
8768 "you can install via conda\n "
@@ -91,13 +72,12 @@ def __init__(self):
9172 )
9273 if LooseVersion (pyarrow .__version__ ) < '0.7.0' :
9374 raise ImportError (
94- "pyarrow >= 0.4.1 is required for parquet support\n \n "
75+ "pyarrow >= 0.7.0 is required for parquet support\n \n "
9576 "you can install via conda\n "
9677 "conda install pyarrow -c conda-forge\n "
9778 "\n or via pip\n "
9879 "pip install -U pyarrow\n "
9980 )
100- >> >> >> > Updated pyarrow dep to 0.7 .0
10181 self .api = pyarrow
10282
10383 def write (self , df , path , compression = 'snappy' ,
@@ -123,22 +103,6 @@ def __init__(self):
123103 try :
124104 import fastparquet
125105 except ImportError :
126- < << << << HEAD
127- raise ImportError ("fastparquet is required for parquet support\n \n "
128- "you can install via conda\n "
129- "conda install fastparquet -c conda-forge\n "
130- "\n or via pip\n "
131- "pip install -U fastparquet" )
132-
133- if LooseVersion (fastparquet .__version__ ) < LooseVersion ('0.1.0' ):
134- raise ImportError ("fastparquet >= 0.1.0 is required for parquet "
135- "support\n \n "
136- "you can install via conda\n "
137- "conda install fastparquet -c conda-forge\n "
138- "\n or via pip\n "
139- "pip install -U fastparquet" )
140-
141- == == == =
142106 raise ImportError (
143107 "fastparquet is required for parquet support\n \n "
144108 "you can install via conda\n "
@@ -153,8 +117,8 @@ def __init__(self):
153117 "you can install via conda\n "
154118 "conda install fastparquet -c conda-forge\n "
155119 "\n or via pip\n "
156- "pip install -U fastparquet" )
157- > >> >> >> Updated pyarrow dep to 0.7 . 0
120+ "pip install -U fastparquet"
121+ )
158122 self .api = fastparquet
159123
160124 def write (self , df , path , compression = 'snappy' , ** kwargs ):
0 commit comments