böl

Verilen desenin eşleşmeleri etrafında str böler.

İlgili Databricks SQL fonksiyonu için bakınız split fonksiyonu.

Sözdizimi

from pyspark.sql import functions as dbf

dbf.split(str=<str>, pattern=<pattern>, limit=<limit>)

Parametreler

Parametre Türü Description
str pyspark.sql.Column veya str bölünecek dize ifadesi
pattern pyspark.sql.Column veya literal string normal ifadeyi temsil eden bir dize. Regex dizesi bir Java normal ifadesi olmalıdır. geriye dönük uyumluluk için normal ifade gösterimi olarak kabul edilir. Int'e ek olarak artık limit sütun ve sütun adını da kabul ediyor.
limit pyspark.sql.Column veya str veya int uygulama sayısını pattern denetleyen bir tamsayı. _ limit > 0: Sonuçta elde edilen dizinin uzunluğu değerinden limituzun olmayacaktır ve sonuçta elde edilen dizinin son girdisi, eşleşen son desenin ötesindeki tüm girişleri içerir. _ limit <= 0: pattern mümkün olduğunca çok kez uygulanır ve sonuçta elde edilen dizi herhangi bir boyutta olabilir.

İade

pyspark.sql.Column: ayrılmış dize dizisi.

Örnekler

from pyspark.sql import functions as dbf
df = spark.createDataFrame([('oneAtwoBthreeC',)], ['s',])
df.select('*', dbf.split(df.s, '[ABC]')).show()
df.select('*', dbf.split(df.s, '[ABC]', 2)).show()
df.select('*', dbf.split('s', '[ABC]', -2)).show()
df = spark.createDataFrame([
('oneAtwoBthreeC', '[ABC]', 2),
('1A2B3C', '[1-9]+', 1),
('aa2bb3cc4', '[1-9]+', -1)], ['s', 'p', 'l'])
df.select('*', dbf.split(df.s, df.p)).show()
df.select(dbf.split('s', df.p, 'l')).show()
  • Last updated on