本文為英文版的機器翻譯版本,如內容有任何歧義或不一致之處,概以英文版為準。
IntToIp 類
轉IntToIp
換指令會將來源資料行或其他值的整數值轉換為目標資料行中對應的 IPv4 值,並在新資料行中傳回結果。
範例
from pyspark.context import SparkContext from pyspark.sql import SparkSession from awsgluedi.transforms import * sc = SparkContext() spark = SparkSession(sc) input_df = spark.createDataFrame( [ (3221225473,), (0,), (1,), (100,), (168430090,), (4294967295,), (4294967294,), (4294967296,), (-1,), (None,), ], ["source_column_int"], ) try: df_output = web_functions.IntToIp.apply( data_frame=input_df, spark_context=sc, source_column="source_column_int", target_column="target_column", value=None ) df_output.show() except: print("Unexpected Error happened ") raise
輸出
輸出將是:
``` +---------------+---------------+ |source_column_int|target_column| +---------------+---------------+ | 3221225473| 192.0.0.1 | | 0| 0.0.0.0 | | 1| 0.0.0.1 | | 100| 0.0.0.100| | 168430090 | 10.0.0.10 | | 4294967295| 255.255.255.255| | 4294967294| 255.255.255.254| | 4294967296| null | | -1| null | | null| null | +---------------+---------------+ ```
此IntToIp.apply
轉換會將「來源欄」作為「來源欄」,「目標欄」為「目標欄」,並將「來源欄」欄中的整數值轉換為對應的 IPv4 位址表示法,並將結果儲存在「目標資料欄」欄中。
對於 IPv4 位址範圍內的有效整數值 (0 至 4294967295),轉換會成功地將它們轉換成它們的 IPv4 位址表示 (例如,192.0.0.1、0.0.0、10.0.10、255.255.255.255)。
對於超出有效範圍的整數值 (例如 4294967296、-1),「目標欄」值會設定為「空值」。對於「源列」列中的「空」值,「目標列」值也設置為空值。
方法
__call__(閃光上下文,數據框架,目標列,源列 = 無,值 = 無)
轉IntToIp
換指令會將來源資料行或其他值的整數值轉換為目標資料行中對應的 IPv4 值,並在新資料行中傳回結果。
-
sourceColumn
– 現有資料欄的名稱。 -
value
— 要評估的字元字串。 -
targetColumn
— 要建立的新欄名稱。
apply(cls, *args, **kwargs)
繼承自 GlueTransform
apply。
name(cls)
繼承自 GlueTransform
name。
describeArgs(cls)
繼承自 GlueTransform
describeArgs。
describeReturn(cls)
繼承自 GlueTransform
describeReturn。
describeTransform(cls)
繼承自 GlueTransform
describeTransform。
describeErrors(cls)
繼承自 GlueTransform
describeErrors。
describe(cls)
繼承自 GlueTransform
describe。