Apache Spark에서 IF Then ELSE 문을 복제하는 방법은 무엇입니까?

IF Then ELSE와 동일한 Spark

Spark에서는 when() 함수를 사용하여 열에 조건식을 적용할 수 있습니다. 이 함수를 사용하면 다양한 조건에 대해 true 및 false 값을 지정할 수 있습니다.

코드 오류 및 해결 방법

when()을 잘못 사용하여 코드에서 오류가 발생합니다. 기능. when()의 올바른 구문은 다음과 같습니다.

when(condition, value).when(...)

or

when(condition, value).otherwise(...)

코드에서 when() 함수에 세 개의 인수를 제공했는데 이는 올바르지 않습니다. 이 문제를 해결하려면 다음과 같이 코드를 다시 작성해야 합니다.

iris_spark_df = iris_spark.withColumn(
    "Class", 
    F.when(iris_spark.iris_class == 'Iris-setosa', 0)
    .when(iris_spark.iris_class == 'Iris-versicolor', 1)
    .otherwise(2)
)

동등한 SQL 표현식

Spark when() 함수는 다음의 CASE 문과 동일합니다. SQL:

CASE
    WHEN (iris_class = 'Iris-setosa') THEN 0
    WHEN (iris_class = 'Iris-versicolor') THEN 1
    ELSE 2
END

위 내용은 Apache Spark에서 IF Then ELSE 문을 복제하는 방법은 무엇입니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!