python3怎么获取spark.sql().collect()结果集的列名

你可以使用Spark DataFrame的schema属性来获取结果集的列名，示例代码如下：

result = spark.sql("SELECT * FROM table").collect()
columns = result.schema.names
print(columns)

这样就可以获取到结果集的列名了。

相关问题

python3判断spark.sql().collect()是否为空

在Python3中，可以使用len()函数来判断collect()返回的数据集是否为空。示例如下：

result = spark.sql("SELECT * FROM table_name").collect()
if len(result) == 0:
    print("数据集为空")
else:
    for row in result:
        print(row)

在这个示例中，使用Spark SQL查询数据表并将结果集收集到本地变量result中。如果结果集为空，则打印一条消息。否则，遍历结果集并打印每行记录。

获取spark.sql().collect()结果集的条数

可以使用以下代码获取Spark SQL结果集的条数：

result = spark.sql("SELECT * FROM my_table")
count = result.count()

在此示例中，我们首先执行Spark SQL查询并将结果存储在`result`变量中。然后，我们使用`count()`函数获取结果集中的记录数，并将其存储在`count`变量中。最后，我们可以使用`print()`函数打印结果集中的记录数：

print("Total records: ", count)