它可以解決,例如,通過指定的模式與ID字符串。
如果你不想指定模式,更好的將自動裝卸機,您可以指定提示:
火花。readStream .format .option (“cloudFiles (“cloudFiles”)。格式”、“csv”) .option (“cloudFiles。schemaLocation”, checkpoint_path) .option (“cloudFiles。schemaHints”、“ID字符串”).option (“inferSchema”,真的).option (“mergeSchema”,真的).load(文件夾)