【发布时间】:2021-08-23 20:47:49
【问题描述】:
我创建了一个数据框 d2 并想应用一个函数来查看它是否为空。我收到错误:'list' 对象没有属性 'isEmpty'
import pyspark
from pyspark.sql import SparkSession
from pyspark.sql.types import DecimalType, FloatType, StructType,StructField, StringType, IntegerType
from pyspark.sql.types import ArrayType, DoubleType, BooleanType
from pyspark.sql.functions import col,array_contains, monotonically_increasing_id, when
from pyspark.sql.window import Window as W
from pyspark.sql import functions as F
from pyspark.sql.types import StructType,StructField
from pyspark.sql.types import StringType, IntegerType, ArrayType
from pyspark.sql.functions import round, lit
sc = SparkSession.builder.appName('SparkByExamples.com').getOrCreate()
columns2 = ["Java","Python"]
data2 = [("Java", "20000"), ("Hello", "100000"), ("Scala", "3000")]
df2 = sc.createDataFrame(data2).toDF(*columns2)
print(df2.head(1).isEmpty)
在最后一行我得到一个错误。有人可以帮我吗?
【问题讨论】:
-
用您自己的话来说,您认为
df2.head(1)是什么意思?当df2为空时,你认为它会做什么?当df2不为空时,你认为它会做什么?现在,退后一步,想想。df2是您要检查它是否为空的东西,对吗? 那个的东西是否提供isEmpty?那有什么作用?能直接解决你的问题吗?那么,你应该写什么代码呢? -
你能发布回溯吗?
-
这是标记为 pandas 但似乎没有涉及 pandas。
-
或许是。不确定
sc.createDataFrame(data2).toDF(*columns2)做了什么。你能print(type(df2))让我们看看它是什么吗?
标签: python pandas pyspark apache-spark-sql