ip_cidr

Область применения: Databricks Runtime 18.2 и выше

Important

Эта функция доступна в бета-версии. Администраторы рабочей области могут управлять доступом к этой функции на странице "Предварительные версии ". См. статью "Управление предварительными версиями Azure Databricks".

Возвращает каноническое представление блока CIDR IPv4 или IPv6.

Соответствующая функция SQL см. в разделеip_cidr "Функция".

Syntax

from pyspark.databricks.sql import functions as dbf

dbf.ip_cidr(col=<col>)

Parameters

Parameter	Тип	Description
col	pyspark.sql.Column или str	Строковое или двоичное значение, представляющее допустимый блок CIDR IPv4 или IPv6.

Примеры

Пример 1. Канонизация блока CIDR IPv4.

from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame([('192.168.1.5/24',)], ['cidr'])
df.select(dbf.ip_cidr('cidr').alias('result')).collect()

[Row(result='192.168.1.0/24')]

Пример 2. Канонизация блока CIDR IPv6.

from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame([('2001:db8::1/64',)], ['cidr'])
df.select(dbf.ip_cidr('cidr').alias('result')).collect()

[Row(result='2001:db8::/64')]

Пример 3. Канонизация блока CIDR в двоичном формате. Входные данные — это двоичное представление 192.168.1.5/24.

from pyspark.databricks.sql import functions as dbf
from pyspark.sql.functions import hex
df = spark.createDataFrame([(bytearray([0xC0, 0xA8, 0x01, 0x05, 0x18]),)], ['cidr'])
df.select(hex(dbf.ip_cidr('cidr')).alias('result')).collect()

[Row(result='C0A8010018')]

Пример 4. None Возвращает Noneвходные данные.

from pyspark.databricks.sql import functions as dbf
df = spark.createDataFrame([(None,)], 'cidr: string')
df.select(dbf.ip_cidr('cidr').alias('result')).collect()

[Row(result=None)]