to

Her satırın belirtilen şemayla eşleşecek şekilde uzlaştırıldığı yeni bir DataFrame döndürür.

Sözdizimi

to(schema: StructType)

Parametreler

Parametre Türü Açıklama
schema YapıTürü Belirtilen şema.

İadeler

DataFrame: Uzlaştırılmış DataFrame.

Notlar

  • Sütunları ve/veya iç alanları belirtilen şemayla eşleşecek şekilde ada göre yeniden sırala.
  • Belirtilen şemada gerekli olmayan sütunları ve/veya iç alanları Project. Eksik sütunlar ve/veya iç alanlar (belirtilen şemada bulunur ancak DataFrame girişinde yoktur) hatalara yol açar.
  • Sütunlar ve/veya iç alanları belirtilen şemadaki veri türleriyle eşleşecek şekilde yayınlar; örneğin, türler uyumluysa( örneğin, sayısaldan sayısala (taşma durumunda hata), ancak int'e dize atamaz.
  • Belirtilen şemadaki meta verileri taşırken, sütunlar ve/veya iç alanlar belirtilen şema tarafından üzerine yazılmamışsa kendi meta verilerini tutar.
  • Null atanabilirlik uyumlu değilse başarısız olur. Örneğin, sütun ve/veya iç alan null atanabilir ancak belirtilen şema null atanamaz olmasını gerektirir.

Spark Connect'i destekler.

Örnekler

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|
# +---+---+