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.
Şunun için geçerlidir:
Databricks Runtime 18.2 ve üzerini denetleyin
Important
Bu özellik Beta sürümündedir.
IP adresinin veya CIDR bloğunun kurallı ikili gösterimini döndürür. Giriş geçersizse hata oluşturmak yerine döndürür None .
İlgili SQL işlevi için bkz try_ip_as_binary . işlev.
Syntax
from pyspark.databricks.sql import functions as dbf
dbf.try_ip_as_binary(col=<col>)
Parameters
| Parametre | Türü | Description |
|---|---|---|
col |
pyspark.sql.Column veya str |
Geçerli bir IPv4 veya IPv6 adresini veya CIDR bloğunu temsil eden STRING veya BINARY değeri. |
Examples
Örnek 1: IPv4 adresini ikiliye dönüştürme.
from pyspark.databricks.sql import functions as dbf
from pyspark.sql.functions import hex
df = spark.createDataFrame([('192.168.1.1',)], ['ip'])
df.select(hex(dbf.try_ip_as_binary('ip')).alias('result')).collect()
[Row(result='C0A80101')]
Örnek 2: IPv6 adresini ikiliye dönüştürme.
from pyspark.databricks.sql import functions as dbf
from pyspark.sql.functions import hex
df = spark.createDataFrame([('2001:db8::1',)], ['ip'])
df.select(hex(dbf.try_ip_as_binary('ip')).alias('result')).collect()
[Row(result='20010DB8000000000000000000000001')]
Örnek 3: CIDR bloğunu ikiliye dönüştürme.
from pyspark.databricks.sql import functions as dbf
from pyspark.sql.functions import hex
df = spark.createDataFrame([('192.168.1.5/24',)], ['cidr'])
df.select(hex(dbf.try_ip_as_binary('cidr')).alias('result')).collect()
[Row(result='C0A8010018')]
Örnek 4: Geçersiz giriş döndürür None.
from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame([('invalid.ip',)], ['ip'])
df.select(dbf.try_ip_as_binary('ip').alias('result')).collect()
[Row(result=None)]
Örnek 5: None giriş döndürür None.
from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame([(None,)], 'ip: string')
df.select(dbf.try_ip_as_binary('ip').alias('result')).collect()
[Row(result=None)]