rozdělit

Rozdělí str podle shod s daným vzorem.

Odpovídající funkci SQL Databricks vizte funkcesplit.

Syntaxe

from pyspark.sql import functions as dbf

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

Parametry

Parameter	Typ	Description
str	pyspark.sql.Column nebo str	řetězcový výraz, který se má rozdělit
pattern	pyspark.sql.Column nebo literal string	řetězec představující regulární výraz. Řetězec regulárního výrazu by měl být regulárním výrazem Java. přijímána jako reprezentaci regulárního výrazu pro zpětnou kompatibilitu. Kromě int limit teď přijímá název sloupce a sloupce.
limit	pyspark.sql.Column nebo str nebo int	celé číslo, které určuje počet použití pattern . _ limit > 0: Délka výsledného pole nebude větší než limita výsledná položka pole bude obsahovat všechny vstupy za posledním shodným vzorem. _ limit <= 0: pattern použije se co nejvíce a výsledná matice může mít libovolnou velikost.

Návraty

pyspark.sql.Column: pole oddělených řetězců.

Examples

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()