FSCK REPAIR TABLE

Dotyczy: Databricks SQL Databricks Runtime

Usuwa wpisy plików z dziennika transakcji Tabeli Delta, które nie mogą już być znalezione w bazowym systemie plików. Może się to zdarzyć, gdy te pliki zostały ręcznie usunięte.

Składnia

FSCK REPAIR TABLE table_name [DRY RUN]

Parametry

• table_name

  Identyfikuje istniejącą tabelę delty. Nazwa nie może zawierać specyfikacji czasowej ani specyfikacji opcji.

• PRÓBA NA SUCHO

  Przedstawia informacje o wpisach pliku, które zostaną usunięte z dziennika transakcji tabeli delty przez FSCK REPAIR TABLE, ponieważ nie można ich znaleźć w bazowym systemie plików. Może się to zdarzyć, gdy te pliki zostały ręcznie usunięte. Wpisy pliku to albo ścieżka do pliku danych, albo kombinacja ścieżki do pliku danych i ścieżki do pliku z wektorem usuwania. Wpisy pliku są uwzględniane w danych wyjściowych, gdy brakuje pliku danych, gdy brakuje pliku wektora usuwania lub gdy brakuje obu tych plików.

  Domyślnie DRY RUN zwraca tylko pierwsze 1000 plików. Możesz zwiększyć ten próg, ustawiając zmienną spark.databricks.delta.fsck.maxNumEntriesInResult SparkSession na wyższą wartość przed uruchomieniem polecenia w notesie.

Zwraca

Dla DRY RUN raportu w formie:

• dataFilePath STRING NOT NULL
• dataFileMissing BOOLEAN NOT NULL
• deletionVectorPath STRING
• deletionVectorFileMissing BOOLEAN NOT NULL

Przykłady

— Assume file1.parquet is missing and no DV is expected.
> FSCK REPAIR TABLE t DRY RUN;
  dataFilePath dataFileMissing deletionVectorPath deletionVectorFileMissing
 ------------- --------------- ------------------ -------------------------
 file1.parquet            true               null                     false

— Assume dv1.bin is missing.
> FSCK REPAIR TABLE t DRY RUN;
  dataFilePath dataFileMissing deletionVectorPath deletionVectorFileMissing
 ------------- --------------- ------------------ -------------------------
 file1.parquet           false            dv1.bin                      true

Powiązane

• REPAIR TABLE