使用DataFrame Scala创建文件名为时间戳的CSV文件可以按照以下步骤进行:
import org.apache.spark.sql.{DataFrame, SaveMode, SparkSession}
import java.text.SimpleDateFormat
import java.util.Date
val spark = SparkSession.builder()
.appName("Create CSV File with Timestamp")
.getOrCreate()
val data = Seq(("John", 25), ("Alice", 30), ("Bob", 35))
val columns = Seq("Name", "Age")
val df = spark.createDataFrame(data).toDF(columns: _*)
val timestamp = new SimpleDateFormat("yyyyMMddHHmmss").format(new Date())
val filePath = s"/path/to/csv/file/$timestamp.csv"
df.write.mode(SaveMode.Overwrite)
.option("header", "true")
.csv(filePath)
在上述代码中,我们使用了SparkSession创建了一个DataFrame,并将其保存为CSV文件。时间戳通过SimpleDateFormat生成,并用于作为文件名的一部分。保存CSV文件时,我们指定了文件路径和文件名,并设置了保存模式为覆盖已存在的文件。同时,我们还设置了CSV文件的头部信息。
这是一个使用DataFrame Scala创建文件名为时间戳的CSV文件的示例。请注意,这只是一个基本的示例,实际应用中可能需要根据具体需求进行适当的修改和扩展。
腾讯云相关产品和产品介绍链接地址:
领取专属 10元无门槛券
手把手带您无忧上云