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.
Sınırlayıcıyı kullanarak giriş dizisi sütununun öğelerini birleştirerek bir dize sütunu döndürür. Dizideki null değerler, null_replacement bağımsız değişkeni aracılığıyla belirtilen bir dizeyle değiştirilebilir. null_replacement ayarlanmadıysa, null değerler yoksayılır.
Sözdizimi
from pyspark.sql import functions as sf
sf.array_join(col, delimiter, null_replacement=None)
Parametreler
| Parametre | Türü | Description |
|---|---|---|
col |
pyspark.sql.Column veya str |
Birleştirilecek dizileri içeren giriş sütunu. |
delimiter |
str | Dizi öğeleri birleştirildiğinde sınırlayıcı olarak kullanılacak dize. |
null_replacement |
str, isteğe bağlı | Dizi içindeki null değerleri değiştirmek için dize. Ayarlanmazsa, null değerler yoksayılır. |
İade
pyspark.sql.Column: Her değerin giriş sütunundan karşılık gelen diziyi birleştirmenin sonucu olduğu dize türünde yeni bir sütun.
Örnekler
Örnek 1: array_join işlevinin temel kullanımı.
from pyspark.sql import functions as sf
df = spark.createDataFrame([(["a", "b", "c"],), (["a", "b"],)], ['data'])
df.select(sf.array_join(df.data, ",")).show()
+-------------------+
|array_join(data, ,)|
+-------------------+
| a,b,c|
| a,b|
+-------------------+
Örnek 2: array_join işlevinin null_replacement bağımsız değişkeniyle kullanımı.
from pyspark.sql import functions as sf
df = spark.createDataFrame([(["a", None, "c"],)], ['data'])
df.select(sf.array_join(df.data, ",", "NULL")).show()
+-------------------------+
|array_join(data, ,, NULL)|
+-------------------------+
| a,NULL,c|
+-------------------------+
Örnek 3: array_join işlevinin null_replacement bağımsız değişkeni olmadan kullanımı.
from pyspark.sql import functions as sf
df = spark.createDataFrame([(["a", None, "c"],)], ['data'])
df.select(sf.array_join(df.data, ",")).show()
+-------------------+
|array_join(data, ,)|
+-------------------+
| a,c|
+-------------------+
Örnek 4: null olan bir dizi ile array_join işlevinin kullanımı.
from pyspark.sql import functions as sf
from pyspark.sql.types import StructType, StructField, ArrayType, StringType
schema = StructType([StructField("data", ArrayType(StringType()), True)])
df = spark.createDataFrame([(None,)], schema)
df.select(sf.array_join(df.data, ",")).show()
+-------------------+
|array_join(data, ,)|
+-------------------+
| NULL|
+-------------------+
Örnek 5: Yalnızca null değerler içeren bir diziyle array_join işlevinin kullanımı.
from pyspark.sql import functions as sf
from pyspark.sql.types import StructType, StructField, ArrayType, StringType
schema = StructType([StructField("data", ArrayType(StringType()), True)])
df = spark.createDataFrame([([None, None],)], schema)
df.select(sf.array_join(df.data, ",", "NULL")).show()
+-------------------------+
|array_join(data, ,, NULL)|
+-------------------------+
| NULL,NULL|
+-------------------------+