Create a DistributedDataFrame from an sql command. :param command: the sql command to run
(self, command)
| 31 | return self._jdm.sql(command) |
| 32 | |
| 33 | def sql2ddf(self, command): |
| 34 | """ |
| 35 | Create a DistributedDataFrame from an sql command. |
| 36 | :param command: the sql command to run |
| 37 | """ |
| 38 | return DistributedDataFrame(self._jdm.sql2ddf(command)) |
| 39 | |
| 40 | def shutdown(self): |
| 41 | """ |