跳到主要内容

input_file_name:获取输入文件名

速查结论

input_file_name() 是 Spark SQL 中用于返回当前正在读取的输入文件名的辅助函数。

语法

input_file_name()

参数说明

参数说明
该函数不接受任何参数

功能说明

input_file_name() 返回当前正在读取的文件的名称。如果文件信息不可用(例如数据来自非文件源),则返回空字符串。该函数在需要追踪数据来源、按文件进行数据审计或调试时非常有用。

示例

> SELECT input_file_name();

常见报错与避坑指南

  • 非文件源返回空字符串:当数据来源于流式数据、JDBC、内存表等非文件源时,函数返回空字符串而非文件名。
  • 分区数据:对于分区表,每行返回的是物理存储文件的路径,可用于识别数据所在的具体分区文件。

Since: 1.5.0

📱关注公众号

「数据仓库技术」文章同步更新,不错过每一篇干货

微信公众号二维码
💬加群交流

备注「数据仓库技术」加入社群,每日一道大厂SQL真题

交流微信二维码

你可能还想看