Not
Bu sayfaya erişim yetkilendirme gerektiriyor. Oturum açmayı veya dizinleri değiştirmeyi deneyebilirsiniz.
Bu sayfaya erişim yetkilendirme gerektiriyor. Dizinleri değiştirmeyi deneyebilirsiniz.
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|
# +---+---+