아파치 스파크 데이터프레임 API 편집하기 (부분)

==예제 코드 (Scala)==
다음은 스칼라(Scala)를 사용하여 아파치 스파크 데이터프레임을 생성하고 조작하는 예제이다.<syntaxhighlight lang="scala">
import org.apache.spark.sql.SparkSession

object DataFrameExample {
  def main(args: Array[String]): Unit = {
    // SparkSession 생성 (로컬 모드 실행)
    val spark = SparkSession.builder
      .appName("DataFrameExample")
      .master("local[*]")
      .getOrCreate()

    // CSV 파일에서 데이터프레임 생성 (header 옵션과 inferSchema 옵션 사용)
    val df = spark.read
      .option("header", "true")
      .option("inferSchema", "true")
      .csv("data.csv")

    // 데이터프레임 스키마 출력
    df.printSchema()

    // 데이터프레임의 일부 행 조회
    df.show(5)

    // SQL 쿼리 실행을 위해 임시 뷰 생성
    df.createOrReplaceTempView("data_table")
    val result = spark.sql("SELECT column1, COUNT(*) AS count FROM data_table GROUP BY column1")
    result.show()

    // SparkSession 종료
    spark.stop()
  }
}
</syntaxhighlight>