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.
Si applica a:
Databricks Runtime 18.2 e versioni successive
Importante
Questa funzionalità è in versione beta. Gli amministratori dell'area di lavoro possono controllare l'accesso a questa funzionalità dalla pagina Anteprime . Vedere Gestire le anteprime di Azure Databricks.
Restituisce True se un indirizzo IP o un blocco CIDR è contenuto all'interno di un altro blocco CIDR, False in caso contrario.
Per la funzione SQL corrispondente, vedere ip_cidr_contains funzione.
Syntax
from pyspark.databricks.sql import functions as dbf
dbf.ip_cidr_contains(col1=<col1>, col2=<col2>)
Parameters
| Parametro | Tipo | Description |
|---|---|---|
col1 |
pyspark.sql.Column oppure str |
Valore STRING o BINARY che rappresenta un blocco CIDR IPv4 o IPv6 valido. |
col2 |
pyspark.sql.Column oppure str |
Valore STRING o BINARY che rappresenta un indirizzo IPv4 o IPv6 valido o un blocco CIDR. |
Examples
Esempio 1: verificare se un indirizzo IP è contenuto in un blocco CIDR.
from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame([('192.168.1.0/24', '192.168.1.100')], ['cidr', 'ip'])
df.select(dbf.ip_cidr_contains('cidr', 'ip').alias('result')).collect()
[Row(result=True)]
Esempio 2: verificare se un blocco CIDR più piccolo è contenuto in un blocco CIDR più grande.
from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame([('192.168.0.0/16', '192.168.1.0/24')], ['cidr', 'needle'])
df.select(dbf.ip_cidr_contains('cidr', 'needle').alias('result')).collect()
[Row(result=True)]
Esempio 3: l'input None restituisce None.
from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame([(None, '192.168.1.1')], 'cidr: string, ip: string')
df.select(dbf.ip_cidr_contains('cidr', 'ip').alias('result')).collect()
[Row(result=None)]