fixed schema check to print out if not equal

This commit is contained in:
Bryan Cutler committed 2016-12-06 14:29:10 -08:00
1 parent 72ea875255
commit f5751e0d78
1 file changed
+5 -3
+5 -3
View File
@@ -545,9 +545,11 @@ cdef class Table:
schema = batches[0].schema
# check schemas are equal
if any((not schema.equals(other.schema) for other in batches[1:])):
raise ArrowException("Error converting list of RecordBatches to "
"DataFrame, not all schemas are equal")
for other in batches[1:]:
if not schema.equals(other.schema):
raise ArrowException("Error converting list of RecordBatches "
"to DataFrame, not all schemas are equal: {%s} != {%s}"
% (str(schema), str(other.schema)))
cdef int K = batches[0].num_columns