IPバージョン
対象: Databricks Runtime 18.2以降
備考
ベータ版
この機能はベータ版です。ワークスペース管理者は、 プレビュー ページからこの機能へのアクセスを制御できます。Databricksのプレビューを管理するを参照してください。
IPv4アドレスまたはIPv6アドレス、あるいはCIDRブロックからIPバージョン(4または6)を返します。
対応する SQL 関数については、 ip_version関数を参照してください。
構文
Python
from pyspark.databricks.sql import functions as dbf
dbf.ip_version(col=<col>)
パラメーター
パラメーター | Type | 説明 |
|---|---|---|
|
| 有効な IPv4 アドレスまたは IPv6 アドレス、あるいは CIDR ブロックを表す文字列またはバイナリ値。 |
例
例1 :IPv4アドレスからバージョンを取得する。
Python
from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame([('192.168.1.5',)], ['ip'])
df.select(dbf.ip_version('ip').alias('result')).collect()
Output
[Row(result=4)]
例2 :IPv6アドレスからバージョンを取得する。
Python
from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame([('2001:db8::1',)], ['ip'])
df.select(dbf.ip_version('ip').alias('result')).collect()
Output
[Row(result=6)]
例3 :CIDRブロックからバージョンを取得する。
Python
from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame([('192.168.1.0/24',)], ['cidr'])
df.select(dbf.ip_version('cidr').alias('result')).collect()
Output
[Row(result=4)]
例4 : None入力はNoneを返します。
Python
from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame([(None,)], 'ip: string')
df.select(dbf.ip_version('ip').alias('result')).collect()
Output
[Row(result=None)]