我有以下sql命令我做與真空幹燥的運行。
% sql真空< table_name >保留500小時排練;
想檢查是否有一種方法可以做到這一點在python api ?
我試著下麵。但不確定是否有一個參數,我們可以通過排練嗎?
從三角洲。表導入DeltaTable路徑=“路徑/ / delta_table”dt = DeltaTable(火花,路徑)vacuum_out = dt.vacuum (retentionHours = 500)
保留小時我們排練一個參數嗎?
如果這是不可能通過python api,有pyspark sql相當於這個嗎?
謝謝你!