Classe IntToIp

La trasformazione IntToIp converte il valore intero della colonna di origine o un altro valore nel valore IPv4 corrispondente nella colonna di destinazione e restituisce il risultato in una nuova colonna.

Esempio

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

L'output sarà:

```
+---------------+---------------+
|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 |
+---------------+---------------+
```

La trasformazione IntToIp.apply assegna `source_column` come `“source_column_int”` e `target_column` come `“target_column”` e converte i valori interi presenti nella colonna `source_column_int` nella rappresentazione corrispondente in indirizzo IPv4 e archivia il risultato nella colonna `target_column`.

Per i valori interi validi all'interno dell'intervallo di indirizzi IPv4 (da 0 a 4294967295), la trasformazione li converte correttamente nella rappresentazione corrispondente in indirizzo IPv4 (ad esempio, 192.0.0.1, 0.0.0.0, 10.0.0.10, 255.255.255.255).

Per i valori interi esterni all'intervallo valido (ad esempio, 4294967296, -1), il valore `target_column` è impostato su `null`. Per i valori `null` presenti nella colonna `source_column_int`, anche il valore `target_column` è impostato su `null`.

Metodi

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

La trasformazione IntToIp converte il valore intero della colonna di origine o un altro valore nel valore IPv4 corrispondente nella colonna di destinazione e restituisce il risultato in una nuova colonna.

apply(cls, *args, **kwargs)

Ereditato da GlueTransform apply.

name(cls)

Ereditato da GlueTransform nome.

describeArgs(cls)

Ereditato da GlueTransform describeArgs.

describeReturn(cls)

Ereditato da GlueTransform describeReturn.

describeTransform(cls)

Ereditato da GlueTransform describeTransform.

describeErrors(cls)

Ereditato da GlueTransform describeErrors.

describe(cls)

Ereditato da GlueTransform describe.