Sütun sınıfı

DataFrame'deki bir sütun.

Spark Connect'i destekler

Sözdizimi

Bkz. Sütun örnekleri oluşturma.

Methods

Yöntem Açıklama
alias(*alias, **kwargs) Bu sütunu yeni bir ad veya adla diğer adla döndürür (patlama gibi birden fazla sütun döndüren ifadeler söz konusu olduğunda).
asc() Sütunun artan düzenini temel alan bir sıralama ifadesi döndürür.
asc_nulls_first() Sütunun artan düzenini temel alan bir sıralama ifadesi döndürür ve null olmayan değerlerden önce null değerler döndürülüyor.
asc_nulls_last() Sütunun artan düzenini temel alan bir sıralama ifadesi döndürür ve null olmayan değerlerden sonra null değerler görüntülenir.
astype(dataType) Diğer ad için cast().
between(lowerBound, upperBound) Geçerli sütunun değerlerinin belirtilen alt ve üst sınırlar (dahil) arasında olup olmadığını denetleyin.
bitwiseAND(other) Bu ifadenin bit düzeyinde VE değerini başka bir ifadeyle hesapla.
bitwiseOR(other) Bu ifadenin bit düzeyinde OR değerini başka bir ifadeyle hesapla.
bitwiseXOR(other) Bu ifadenin bit düzeyinde XOR değerini başka bir ifadeyle hesapla.
cast(dataType) Sütunu türüne dataTypeyazar.
contains(other) Diğer öğeyi içerir.
desc() Sütunun azalan düzenini temel alan bir sıralama ifadesi döndürür.
desc_nulls_first() Sütunun azalan düzenini temel alan bir sıralama ifadesi döndürür ve null değerler null olmayan değerlerden önce görünür.
desc_nulls_last() Sütunun azalan düzenini temel alan bir sıralama ifadesi döndürür ve null olmayan değerlerden sonra null değerler görüntülenir.
dropFields(*fieldNames) StructType içindeki alanları ada göre düşüren ifade.
endswith(other) Dize ile biter.
eqNullSafe(other) Null değerler için güvenli olan eşitlik testi.
getField(name) StructType içinde ada göre alan alan ifade.
getItem(key) Listeden sıralı konumdaki bir öğeyi alan veya bir öğeyi bir diktenin anahtarıyla alan ifade.
ilike(other) SQL ILIKE ifadesi (büyük/küçük harfe duyarsız LIKE).
isNaN() Geçerli ifade NaN ise true.
isNotNull() Geçerli ifade NULL DEĞİlse true.
isNull() Geçerli ifade null ise True.
isin(*cols) Bu ifadenin değeri bağımsız değişkenlerin değerlendirilen değerleri tarafından içerdiğinde true olarak değerlendirilen boole ifadesi.
like(other) SQL benzeri ifade.
name(*alias, **kwargs) Diğer ad için alias().
otherwise(value) Koşulların listesini değerlendirir ve birden çok olası sonuç ifadelerinden birini döndürür.
over(window) Bir pencere sütunu tanımlayın.
rlike(other) SQL RLIKE ifadesi (Regex ile LIKE).
startswith(other) Dize ile başlar.
substr(startPos, length) Sütunun alt dizesi olan bir Sütun döndürür.
try_cast(dataType) Bu, aynı işlemi gerçekleştiren, ancak çağırma yöntemi özel durum oluşturursa hata oluşturmak yerine NULL değer döndüren özel bir sürümüdür cast .
when(condition, value) Koşulların listesini değerlendirir ve birden çok olası sonuç ifadelerinden birini döndürür.
withField(fieldName, col) StructType'daki bir alanı ada göre ekleyen/değiştiren ifade.

Operatörler

Column sınıfı aritmetik, karşılaştırma ve mantıksal işlemler için standart Python işleçlerini destekler:

  • Aritmetik: +, -, *, /, %, , **
  • Karşılaştırma: ==, !=, <, <=, >, , >=
  • Mantıksal: & (AND), | (VEYA), ~ (DEĞİl)

Örnekler

Sütunların kullanımını gösteren daha basit örnekler için bkz. Sütun işlemleri.

Sütun örnekleri oluşturma

DataFrame'den sütun seçin:

df = spark.createDataFrame(
    [(2, "Alice"), (5, "Bob")], ["age", "name"])

# Access by attribute
df.name
# Column<'name'>

# Access by bracket notation
df["name"]
# Column<'name'>

İfadeden sütun oluşturma:

df.age + 1
# Column<...>

1 / df.age
# Column<...>

Temel sütun işlemleri

# Arithmetic operations
df.select(df.age + 10).show()

# Comparison operations
df.filter(df.age > 3).show()

# String operations
df.filter(df.name.startswith("A")).show()

# Null checking
df.filter(df.name.isNotNull()).show()

Koşullu mantık

from pyspark.sql import functions as F

df.select(
    F.when(df.age < 3, "child")
     .when(df.age < 13, "kid")
     .otherwise("adult")
     .alias("age_group")
).show()

Sıralama

df.orderBy(df.age.desc()).show()
df.orderBy(df.age.asc_nulls_last()).show()
  • Last updated on