Classe IsEven

La transformation IsEven renvoie une valeur booléenne dans une nouvelle colonne qui indique si la colonne ou la valeur source est paire. Si la colonne ou la valeur source est décimale, le résultat est false.

exemple

from pyspark.context import SparkContext
from pyspark.sql import SparkSession
from awsgluedi.transforms import *

sc = SparkContext()
spark = SparkSession(sc)

input_df = spark.createDataFrame(
    [(5,), (0,), (-1,), (2,), (None,)],
    ["source_column"],
)

try:
    df_output = math_functions.IsEven.apply(
        data_frame=input_df,
        spark_context=sc,
        source_column="source_column",
        target_column="target_column",
        value=None,
        true_string="Even",
        false_string="Not even",
    )
    df_output.show()
except:
    print("Unexpected Error happened ")
    raise
    

Sortie

Le résultat sera :

```
+------------+------------+
|source_column|target_column|
+------------+------------+
| 5| Not even|
| 0| Even|
| -1| Not even|
| 2| Even|
| null| null|
+------------+------------+
```

La transformation IsEven prend la valeur `source_column` "source_column" et la valeur `target_column` "target_column". Elle vérifie si la valeur de `"source_column"` est paire ou non. Si la valeur est paire, elle définit la valeur `"target_column"` sur `true_string` "Even". Si la valeur est impaire, elle définit la valeur `"target_column"` sur `false_string` "Not even". Si la valeur `"source_column"` est `null`, la valeur `"target_column"` est définie sur `null`.

La transformation identifie correctement les nombres pairs (0 et 2) et définit la valeur `"target_column"` sur "Even". Pour les nombres impairs (5 et -1), elle définit la valeur `"target_column"` sur "Not even". Pour la valeur `null` dans `"source_column"`, la valeur `"target_column"` est définie sur `null`.

Méthodes

__call__(spark_context, data_frame, target_column, source_column=None, true_string=DEFAULT_TRUE_STRING, false_string=DEFAULT_FALSE_STRING, value=None)

La transformation IsEven renvoie une valeur booléenne dans une nouvelle colonne qui indique si la colonne ou la valeur source est paire. Si la colonne ou la valeur source est décimale, le résultat est false.

apply(cls, *args, **kwargs)

Hérité de GlueTransform s'appliquent.

name(cls)

Hérité de GlueTransform name.

describeArgs(cls)

Hérité de GlueTransform describeArgs.

describeReturn(cls)

Hérité de GlueTransform describeReturn.

describeTransform(cls)

Hérité de GlueTransform describeTransform.

describeErrors(cls)

Hérité de GlueTransform describeErrors.

describe(cls)

Hérité de GlueTransform describe.