In [13]: source = sink.get_result() In [14]: source Out[14]: In [15]: source.size Out[15]: 1074750744