我正在測試由我在我的代碼中定義的簡單字符串分析器函數，但其中一個工作器節點在執行時總是失敗。這裏是我一直在測試假人代碼： /* JUST A SIMPLE PARSER TO CLEAN PARENTHESIS */
def parseString(field: String): String = {
val Pattern = "(.*.)".r
field match
我有一個RDD的分區包含元素（熊貓數據框，因爲它發生），可以很容易地變成行列表。把它看成是看起來像這樣 rows_list = []
for word in 'quick brown fox'.split():
rows = []
for i,c in enumerate(word):
x = ord(c) + i
row = pyspark.sql.
我正在嘗試按特定順序將多個RDD的字符串合併到RDD行中。我試圖創建一個Map[String, RDD[Seq[String]]]（其中Seq只包含一個元素），然後將它們合併到一個RDD[Row[String]]，但它似乎不起作用（內容RDD[Seq[String]]丟失）。有人有什麼想法嗎？ val t1: StructType
val mapFields: Map[String, RDD[S