Flink SQL读取带表头的CSV文件时如何跳过首行表头?
解决方案
Flink CSV 格式提供了原生的跳过表头配置,无需修改原始文件,仅需在表定义的 WITH 参数中新增 'csv.ignore-first-line' = 'true' 即可自动跳过第一行表头。
修正后的表定义如下:
CREATE TABLE trades ( AccountNo varchar(10), Symbol varchar(10), Quantity integer, BuySell varchar(4), Price decimal ) WITH ( 'connector' = 'filesystem', 'path' = '/mnt/d/Work/Github/Flink-Samples/data/trade-data.csv', 'format' = 'csv', 'csv.ignore-first-line' = 'true' );
如果存在多行表头,可以使用 'csv.skip-header-line-count' = '<N>' 参数,将 <N> 替换为实际需要跳过的表头行数即可。
内容的提问来源于stack exchange,提问作者Siddharth B
相关产品推荐
相关产品推荐

