fmadeiro
Contributor II
  1. Query Using Unity Catalog:

    • SQL:
      sql
      Copiar código
      SELECT * FROM catalog_name.schema_name.table_name;
    • PySpark:
      python
      Copiar código
      df = spark.sql("SELECT * FROM catalog_name.schema_name.table_name") df.display()
  2. Direct Access by Path: If not using Unity Catalog:

    python
    Copiar código
    iceberg_table_path = "abfss://<container>@<storage_account>.dfs.core.windows.net/<path_to_table>" df = spark.read.format("iceberg").load(iceberg_table_path) df.display()
  3. Optimize Performance:

    • Query by partitions:
      sql
      Copiar código
      SELECT * FROM catalog_name.schema_name.table_name WHERE partition_column = 'value';
    • Cache data:
      python
      Copiar código
      df.cache()
  4. Optional Features:

    • Time Travel:
      sql
      Copiar código
      SELECT * FROM catalog_name.schema_name.table_name VERSION AS OF 123456;

View solution in original post