This question already has answers here: (null) entry in command string exception in saveAsTextFile() on Pyspark ...

To understand this problem, imagine that a group of people, at time t1, are in a certain location L. You are interested in knowing where all those people were at time t0. 我在这里有一个示例代码来引导练习： row = Row("user_id", "start", "location_id") df = spark.sparkContex...

我有一个用例，可以向timestamp列中添加一些值并从中得出日期。我正在尝试使用from_unix和unix_timestamp函数。但是它以不同的格式显示了不同的值。 select from_unixtime('1577582583', 'YYYY-MM-dd'), from_unixtime('1577582583', 'yyyy-MM-dd'); from_unixtime(CAST(1577582583 AS BIGINT), YYYY-MM-dd) from_unixtime(CAST(...