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	Ce champ renvoie une valeur d’espace réservé et ne doit pas être utilisé. Ce champ pourrait être obsolète dans une future version.
ETAG	N/A	Ce champ renvoie une valeur d’espace réservé et ne doit pas être utilisé. Ce champ pourrait être obsolète dans une future version.
LAST_MODIFIED_ON	N/A	Ce champ renvoie une valeur d’espace réservé et ne doit pas être utilisé. Ce champ pourrait être obsolète dans une future version.

Note

Les champs ETAG, MD5, et LAST_MODIFIED_ON renvoient une valeur d’espace réservé et ne doivent pas être utilisés. Ces champs pourraient être obsolètes dans une future version.

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