input_file_name:获取输入文件名
速查结论
input_file_name() 是 Spark SQL 中用于返回当前正在读取的输入文件名的辅助函数。
语法
input_file_name()
参数说明
| 参数 | 说明 |
|---|---|
| 无 | 该函数不接受任何参数 |
功能说明
input_file_name() 返回当前正在读取的文件的名称。如果文件信息不可用(例如数据来自非文件源),则返回空字符串。该函数在需要追踪数据来源、按文件进行数据审计或调试时非常有用。
示例
> SELECT input_file_name();
常见报错与避坑指南
- 非文件源返回空字符串:当数据来源于流式数据、JDBC、内存表等非文件源时,函数返回空字符串而非文件名。
- 分区数据:对于分区表,每行返回的是物理存储文件的路径,可用于识别数据所在的具体分区文件。
Since: 1.5.0
📱关注公众号
「数据仓库技术」文章同步更新,不错过每一篇干货

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