more debugging.

uwescience · Apr 5, 2016 · e9c4522 · e9c4522
1 parent 2b1ca99
commit e9c4522
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/raco/backends/spark/catalog.py b/raco/backends/spark/catalog.py
@@ -19,7 +19,9 @@ def get_scheme(self, rel_key):
 
         try:
             if str(rel_key).startswith('hdfs://'):
-                df_scheme = self.connection.get_df(str(rel_key)).dtypes
+                df = self.connection.get_df(str(rel_key))
+                print df
+                df_scheme = df.dtypes
             else:
                 df_scheme = self.connection.get_df(rel_key.relation).dtypes
             print scheme.Scheme([(i, self.types_dict[j]) for (i, j) in df_scheme])