아파치 FLINK하십시오 CSV의 스키마가 불꽃처럼 파일 추론 우리가 추론 스키마를 사용할 수 있습니다 스파크에서

df = sqlContext.read.format('com.databricks.spark.csv').options(delimiter='|',header='true', inferschema='true').load('cars.csv')

이 FLINK에 동일한 할 수있는 방법이 있나요 파일 예컨대 :에서 스키마를 읽어?

2017-12-28 Ammar

Flink에는 CSV 파일의 자동 스키마 추론 기능이 기본적으로 내장되어 있지 않습니다.

CSV 파일의 첫 번째 행을 분석하고 해당하는 CsvTableSource를 생성하여 이러한 기능을 구현할 수 있습니다.

2017-12-28 14:05:31

외부 카탈로그를 사용하는 방법이 있습니까 – Ammar

예, 그렇지만 스키마 유추를 직접 구현해야합니다. CSV 파일의 스키마를 추론하는 사용자 정의 TableSource를 구현할 수도 있습니다. –

내 현재의 연구에 따라 CSV 형식 당 클래스 파일을 추가해야합니다 .CSS의 열이 없으면 클래스 파일도 업데이트해야하며 코드를 다시 컴파일해야합니다. 올바른 .Plz 올바른 값 내가 틀렸다면 나. – Ammar

답변