langchain/utilities/spark_sql.py/SparkSQL/run
class SparkSQL:    def run(self, command: str, fetch: str = "all") -> str:
        df = self._spark.sql(command)
        if fetch == "one":
            df = df.limit(1)
        return str(self._get_dataframe_results(df))