我預定義模式δ生活表自動裝載。這包括評論一些屬性。當執行一個標準readStream,我的言論出現,但在三角洲住表我沒有評論。有什麼我需要做的評論出現嗎?
模式定義:
模式= StructType ([StructField (uuid, StringType(),真的,{“評論”:“獨特的客戶id”}), StructField(“全球定位係統”,StringType(),真的)))
三角洲:直播表
@dlt。表(name = " test_bronze "評論=“測試帳戶數據增量地攝取S3原始著陸區”,table_properties ={“質量”:“青銅”})# # @dlt流數據。表def test_bronze():返回(火花。readStream .format .option (“cloudFiles (“cloudFiles”)。形式at", "csv) .option("header", "True") .schema(schema) .load(data_source) )
但沒有注釋數據: