ApacheのFLINK：我々は、動的ファイルから例えばをスキーマを読み取るために推論スキーマを使用することができますスパークスパーク

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 formatごとにクラスファイルを追加する必要があります.csvの列がない場合は、クラスファイルも更新しなければならず、そのためにコードを再度コンパイルする必要があります.Plz correct私が間違っているなら私。 – Ammar

答えて