3.3 从 pandas.DataFrame 创建

  1. 使用方式:

    1. df = pd.DataFrame({'a':[1,3,5],'b':[2,4,6]})
    2. spark_session.createDataFrame(df).collect()

    结果为:

    1. [Row(a=1, b=2), Row(a=3, b=4), Row(a=5, b=6)]