Catégories :

Fonctions de table

ICEBERG_TABLE_FILES

Renvoie des informations sur les fichiers de données enregistrés dans une table Apache Iceberg™ gérée en externe à un moment donné.

Voir aussi :

Tables Apache Iceberg™, Métadonnées et conservation des tables Apache Iceberg™, ALTER ICEBERG TABLE … REFRESH

Syntaxe

ICEBERG_TABLE_FILES(
  TABLE_NAME => '<table_name>'
  [, AT => '<timestamp_ltz>']
)
Copy

Arguments

Nécessaire

TABLE_NAME => 'table_name'

Le nom de la table Iceberg gérée en externe pour laquelle vous souhaitez récupérer les informations du fichier de données.

Facultatif

AT => 'timestamp_ltz'

Spécifie une date et une heure exactes à utiliser pour récupérer les informations sur le fichier. La valeur doit être explicitement convertie en type de données TIMESTAMP_LTZ. Pour plus d’informations, voir Types de données de date et heure.

Si elle n’est pas spécifiée, la fonction renvoie des informations sur les fichiers de table pour l’instantané actuel.

Sortie

La fonction renvoie les colonnes suivantes :

Nom de la colonne

Type de données

Description

REGISTERED_ON

TIMESTAMP_LTZ

Horodatage de l’enregistrement du fichier Parquet.

FILE_NAME

TEXT

Chemin complet vers le fichier enregistré.

FILE_SIZE

NUMBER

Taille du fichier (en octets).

ROW_COUNT

NUMBER

Nombre de lignes dans le fichier.

ROW_COUNT_GROUP

NUMBER

Nombre de groupes de lignes dans le fichier.

MD5

N/A

This field returns a placeholder value and should not be used. This field might be deprecated in a future release.

ETAG

N/A

This field returns a placeholder value and should not be used. This field might be deprecated in a future release.

LAST_MODIFIED_ON

N/A

This field returns a placeholder value and should not be used. This field might be deprecated in a future release.

Note

The ETAG, MD5, and LAST_MODIFIED_ON fields return a placeholder value and should not be used. These fields might be deprecated in a future release.

Exemples

Récupérer des informations sur les fichiers de données Parquet pour l”instantané actuel enregistré dans une table Iceberg gérée en externe nommée my_iceberg_table :

SELECT *
  FROM TABLE(
    INFORMATION_SCHEMA.ICEBERG_TABLE_FILES(
      TABLE_NAME => 'my_iceberg_table'
    )
  );
Copy

Sortie :

+-------------------------------------------------------+--------------------------------+------------+--------------------------------+------------+------------------+-----------------------------------+-----------------------------------+
| FILE_NAME                                             | REGISTERED_ON                  | FILE_SIZE  | LAST_MODIFIED_ON               | ROW_COUNT  | ROW_GROUP_COUNT  | ETAG                              | MD5                               |
| data/87/snow_D9zlAoeipII_AODxT1uXDxg_0_1_003.parquet  | 1969-12-31 16:00:00.000 -0800  | 27136      | 1969-12-31 16:00:00.000 -0800  | 30000      | 1                | NULL                              | NULL                              |
| data/08/snow_D9zlAoeipII_AODxT1uXDxg_0_1_006.parquet  | 1969-12-31 16:00:00.000 -0800  | 45568      | 1969-12-31 16:00:00.000 -0800  | 45000      | 1                | NULL                              | NULL                              |
| data/94/snow_D9zlAoeipII_AODxT1uXDxg_0_1_008.parquet  | 1969-12-31 16:00:00.000 -0800  | 45056      | 1969-12-31 16:00:00.000 -0800  | 45000      | 1                | NULL                              | NULL                              |
| data/24/snow_D9zlAoeipII_AODxT1uXDxg_0_1_004.parquet  | 1969-12-31 16:00:00.000 -0800  | 27136      | 1969-12-31 16:00:00.000 -0800  | 30000      | 1                | NULL                              | NULL                              |
+-------------------------------------------------------+--------------------------------+------------+--------------------------------+------------+------------------+-----------------------------------+-----------------------------------+

Récupérer des informations sur les fichiers de données Parquet pour une table nommée my_iceberg_table à une heure et un jour donnés :

SELECT file_name, file_size, row_count, row_group_count, etag, md5
  FROM TABLE(
    INFORMATION_SCHEMA.ICEBERG_TABLE_FILES(
      TABLE_NAME => 'my_iceberg_table',
      AT => CAST('2024-12-09 11:02:00' AS TIMESTAMP_LTZ)
    )
  );
Copy

Sortie :

+------------------------------------------------------+-----------+-----------+-----------------+----------------------------------+----------------------------------+
| FILE_NAME                                            | FILE_SIZE | ROW_COUNT | ROW_GROUP_COUNT | ETAG                             | MD5                              |
|------------------------------------------------------+-----------+-----------+-----------------+----------------------------------+----------------------------------|
| data/87/snow_D9zlAoeipII_AODxT1uXDxg_0_1_003.parquet | 27136     | 30000     | 1               | NULL                             | NULL                             |
| data/08/snow_D9zlAoeipII_AODxT1uXDxg_0_1_006.parquet | 45568     | 45000     | 1               | NULL                             | NULL                             |
| data/94/snow_D9zlAoeipII_AODxT1uXDxg_0_1_008.parquet | 45056     | 45000     | 1               | NULL                             | NULL                             |
| data/24/snow_D9zlAoeipII_AODxT1uXDxg_0_1_004.parquet | 27136     | 30000     | 1               | NULL                             | NULL                             |
+------------------------------------------------------+-----------+-----------+-----------------+----------------------------------+----------------------------------+
4 Row(s) produced. Time Elapsed: 1.502s