FormatCase 類

FormatCase轉換將列中的每個字符串更改為指定的大小寫類型。

範例

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

sc = SparkContext()
spark = SparkSession(sc)

datasource1 = spark.read.json("s3://${BUCKET}/json/zips/raw/data")

try:
    df_output = data_cleaning.FormatCase.apply(
        data_frame=datasource1,
        spark_context=sc,
        source_column="city",
        case_type="LOWER"
    )    
except:
    print("Unexpected Error happened ")
    raise
    

輸出

FormatCase轉換會根據 'CASE_TYPE = "小寫"' 參數，將 `city` 資料欄中的值轉換為小寫。由此產生的 `df_output` DataFrame 將包含來自原始「資料庫 1」的所有資料欄，但是 DataFrame以小寫形式顯示的「城市」欄值。

方法

• __call__

• apply

• name

• describeArgs

• describeReturn

• describeTransform

• describeErrors

• describe

__call__（閃光上下文，數據框架，源列，案例類型）

FormatCase轉換將列中的每個字符串更改為指定的大小寫類型。

• source_column – 現有資料欄的名稱。

• case_type— 支援的案例類型為CAPITALLOWER、UPPER、、SENTENCE。

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。