Nota
L'accesso a questa pagina richiede l'autorizzazione. È possibile provare ad accedere o modificare le directory.
L'accesso a questa pagina richiede l'autorizzazione. È possibile provare a modificare le directory.
Restituisce l'elemento di una matrice in corrispondenza dell'indice (in base 0) specificato. Se l'indice punta all'esterno dei limiti della matrice, questa funzione restituisce NULL. La posizione non è basata su 1, ma su 0.
Sintassi
from pyspark.sql import functions as sf
sf.get(col, index)
Parametri
| Parametro | TIPO | Description |
|---|---|---|
col |
pyspark.sql.Column o str |
Nome della colonna contenente la matrice. |
index |
pyspark.sql.Column, stringa o intero |
Indice da verificare nella matrice. |
Restituzioni
pyspark.sql.Column: valore in corrispondenza della posizione specificata.
Esempi
Esempio 1: Recupero di un elemento in una posizione fissa
from pyspark.sql import functions as sf
df = spark.createDataFrame([(["a", "b", "c"],)], ['data'])
df.select(sf.get(df.data, 1)).show()
+------------+
|get(data, 1)|
+------------+
| b|
+------------+
Esempio 2: Recupero di un elemento in una posizione esterna ai limiti della matrice
from pyspark.sql import functions as sf
df = spark.createDataFrame([(["a", "b", "c"],)], ['data'])
df.select(sf.get(df.data, 3)).show()
+------------+
|get(data, 3)|
+------------+
| NULL|
+------------+
Esempio 3: Recupero di un elemento in una posizione specificata da un'altra colonna
from pyspark.sql import functions as sf
df = spark.createDataFrame([(["a", "b", "c"], 2)], ['data', 'index'])
df.select(sf.get(df.data, df.index)).show()
+----------------+
|get(data, index)|
+----------------+
| c|
+----------------+
Esempio 4: Recupero di un elemento in una posizione calcolata da un'altra colonna
from pyspark.sql import functions as sf
df = spark.createDataFrame([(["a", "b", "c"], 2)], ['data', 'index'])
df.select(sf.get(df.data, df.index - 1)).show()
+----------------------+
|get(data, (index - 1))|
+----------------------+
| b|
+----------------------+
Esempio 5: Recupero di un elemento in una posizione negativa
from pyspark.sql import functions as sf
df = spark.createDataFrame([(["a", "b", "c"], )], ['data'])
df.select(sf.get(df.data, -1)).show()
+-------------+
|get(data, -1)|
+-------------+
| NULL|
+-------------+