felhasználóként a(z)

Egy új DataFrame-et ad vissza, amelyben minden sor egyeztetve van a megadott sémával.

Szemantika

to(schema: StructType)

Paraméterek

Paraméter	Típus	Leírás
schema	StructType	Megadott séma.

Visszatérítések

DataFrame: Egyeztetett adatkeret.

Jegyzetek

• Az oszlopok és/vagy belső mezők átrendezése név szerint a megadott sémának megfelelően.
• Project a megadott séma által nem szükséges oszlopokat és/vagy belső mezőket. A hiányzó oszlopok és/vagy belső mezők (amelyek a megadott sémában találhatók, de a DataFrame nem) hibákhoz vezetnek.
• Az oszlopokat és/vagy a belső mezőket a megadott séma adattípusainak megfelelően alakíthatja ki, ha a típusok kompatibilisek, például numerikustól numerikusig (túlcsordulások esetén hiba), de sztringet nem kell inthez adni.
• Vigye át a metaadatokat a megadott sémából, míg az oszlopok és/vagy belső mezők továbbra is megtartják a saját metaadataikat, ha a megadott séma nem írja felül őket.
• Sikertelen, ha a nullhiba nem kompatibilis. Az oszlop és/vagy belső mező például null értékű, de a megadott séma megköveteli, hogy ne legyenek null értékűek.

Támogatja a Spark Connectet.

Examples

from pyspark.sql.types import StructField, StringType
df = spark.createDataFrame([("a", 1)], ["i", "j"])
df.schema
# StructType([StructField('i', StringType(), True), StructField('j', LongType(), True)])

schema = StructType([StructField("j", StringType()), StructField("i", StringType())])
df2 = df.to(schema)
df2.schema
# StructType([StructField('j', StringType(), True), StructField('i', StringType(), True)])
df2.show()
# +---+---+
# |  j|  i|
# +---+---+
# |  1|  a|
# +---+---+