Kazalo:

Kako iz seznama naredim PySpark DataFrame?
Kako iz seznama naredim PySpark DataFrame?

Video: Kako iz seznama naredim PySpark DataFrame?

Video: Kako iz seznama naredim PySpark DataFrame?
Video: Data Science with Python! Analyzing File Types from Avro to Stata 2024, April
Anonim

Sledim tem korakom za ustvarjanje DataFrame s seznama vodnikov:

  1. Ustvari a seznam naborkov. Vsak tule vsebuje ime osebe s starostjo.
  2. Ustvari RDD iz seznam zgoraj.
  3. Pretvorba vsak niz v vrstico.
  4. Ustvari a DataFrame z uporabo createDataFrame na RDD s pomočjo sqlContext.

Ob upoštevanju tega, kako pretvorite DataFrame v seznam v Pythonu?

  1. 1. korak: pretvorite podatkovni okvir v ugnezdeno matriko Numpy z uporabo DataFrame.to_numpy(), tj.
  2. 2. korak: pretvorite matriko 2D Numpy v seznam seznamov.
  3. 1. korak: Transponirajte podatkovni okvir, da pretvorite vrstice v stolpce in stolpce v vrstice.
  4. 2. korak: pretvorite podatkovni okvir v ugnezdeno matriko Numpy z uporabo DataFrame.to_numpy()

Poleg tega, kaj je spark DataFrame? A Spark DataFrame je porazdeljena zbirka podatkov, organizirana v poimenovane stolpce, ki zagotavlja operacije za filtriranje, združevanje ali izračunavanje agregatov in se lahko uporablja z Iskra SQL. Podatkovni okvirji je mogoče sestaviti iz strukturiranih podatkovnih datotek, obstoječih RDD-jev, tabel v Hiveju ali zunanjih baz podatkov.

Vedite tudi, kaj je PySpark SQL?

Spark SQL je Iskra modul za strukturirano obdelavo podatkov. Zagotavlja programsko abstrakcijo, imenovano DataFrames, in lahko deluje tudi kot porazdeljena SQL motor za poizvedbe. Omogoča, da se nespremenjene poizvedbe Hadoop Hive izvajajo do 100x hitreje na obstoječih razmestitvah in podatkih.

Ali so spark DataFrames nespremenljivi?

V Iskra ne moreš - Podatkovni okvirji so nespremenljiv . Moral bi uporabiti.

Priporočena: