IntToIp kelas

IntToIpTransformasi mengubah nilai integer kolom sumber atau nilai lainnya ke nilai IPv4 yang sesuai di kolom target, dan mengembalikan hasilnya di kolom baru.

Contoh

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
    

Output

Outputnya adalah:

```
+---------------+---------------+
|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.applyTransformasi mengambil `source_column` sebagai `"source_column_int"` dan `target_column` sebagai `"target_column"` dan mengubah nilai integer di kolom `source_column_int` ke representasi alamat IPv4 yang sesuai dan menyimpan hasilnya di kolom `target_column`.

Untuk nilai integer yang valid dalam kisaran alamat IPv4 (0 hingga 4294967295), transformasi berhasil mengubahnya menjadi representasi alamat IPv4 mereka (misalnya, 192.0.0.1, 0.0.0.0, 10.0.0.10, 255.255.255.255).

Untuk nilai integer di luar rentang yang valid (misalnya, 4294967296, -1), nilai `target_column` diatur ke `null`. Untuk nilai `null` di kolom `source_column_int`, nilai `target_column` juga diatur ke `null`.

Metode

• __call__

• apply

• name

• describeArgs

• describeReturn

• describeTransform

• describeErrors

• describe

__call__ (spark_context, data_frame, target_column, source_column=None, value=None)

IntToIpTransformasi mengubah nilai integer kolom sumber atau nilai lainnya ke nilai IPv4 yang sesuai di kolom target, dan mengembalikan hasilnya di kolom baru.

• sourceColumn— Nama kolom yang ada.

• value— String karakter untuk dievaluasi.

• targetColumn— Nama kolom baru yang akan dibuat.

apply(cls, *args, **kwargs)

Warisan dari GlueTransform apply.

name(cls)

Warisan dari GlueTransform nama.

describeArgs(cls)

Warisan dari GlueTransform describeArgs.

describeReturn(cls)

Warisan dari GlueTransform describeReturn.

describeTransform(cls)

Warisan dari GlueTransform describeTransform.

describeErrors(cls)

Warisan dari GlueTransform describeErrors.

describe(cls)

Warisan dari GlueTransform describe.