wie man die Liste in Items in Python funken umwandelt

Question

Mein folgender Code erzeugte gerade eine RDD, die Listen enthält, und transformiert dann die Liste in Items via flatMap. Aber ich denke die folgende Art von dumm, muss ich die Funktion listToItem schreiben, und muss ich die Funktion printStr schreiben. Irgendeine Optimierung auf dem folgenden Code bitte.

def listToItem(inputList): 
    return inputList 
def printStr(tm): 
    print tm 

if __name__ == "__main__": 
    sc = SparkContext(appName="Test Spark") 
    rdd1 = sc.parallelize([[1,2,3],['a','b','c']]) 
    res = rdd1.flatMap(listToItem).foreach(printStr) 
    sc.stop() 

Answer 1

Für die ersten nur verwenden Identität (Kredit Is there a builtin identity function in python?):

>>> _ = lambda *args: args 
>>> rdd1.flatMap(_) 

Für die zweite Import-Druckfunktion:

>>> from __future__ import print_function 

und

>>> rdd1.flatMap(_).foreach(print) 

aber erinnere dich, dass es ist nutzlos (https://stackoverflow.com/a/25296061/6022341)