Categorias:: Funções de tabela

ICEBERG_TABLE_FILES¶

Retorna informações sobre os arquivos de dados registrados em uma tabela Apache Iceberg™ gerenciada externamente em um ponto específico no tempo.

Consulte também:: Tabelas Apache Iceberg™, Metadados e retenção para tabelas Apache Iceberg™, ALTER ICEBERG TABLE … REFRESH

Sintaxe¶

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

Argumentos¶

Obrigatório

TABLE_NAME => 'table_name': O nome da tabela Iceberg gerenciada externamente para a qual você deseja recuperar as informações do arquivo de dados.

Opcional

AT => 'timestamp_ltz'

Especifica uma data e hora exatas a serem usadas para recuperar as informações do arquivo. O valor deve ser explicitamente convertido em um tipo de dados TIMESTAMP_LTZ. Para obter mais informações, consulte Tipos de dados de data e hora.

Se não for especificada, a função retornará informações sobre os arquivos de tabela do instantâneo atual.

Saída¶

A função retorna as seguintes colunas:


Nome da coluna	Tipo de dados	Descrição
REGISTERED_ON	TIMESTAMP_LTZ	O carimbo de data/hora de quando o arquivo Parquet foi registrado.
FILE_NAME	TEXT	O caminho completo para o arquivo registrado.
FILE_SIZE	NUMBER	O tamanho do arquivo (em bytes).
ROW_COUNT	NUMBER	O número de linhas no arquivo.
ROW_COUNT_GROUP	NUMBER	O número de grupos de linhas no arquivo.
MD5	N/A	Este campo retorna um valor de espaço reservado e não deve ser usado. Ele talvez se torne obsoleto em uma versão futura.
ETAG	N/A	Este campo retorna um valor de espaço reservado e não deve ser usado. Ele talvez se torne obsoleto em uma versão futura.
LAST_MODIFIED_ON	N/A	Este campo retorna um valor de espaço reservado e não deve ser usado. Ele talvez se torne obsoleto em uma versão futura.

Nota

Os campos ETAG, MD5 e LAST_MODIFIED_ON retornam um valor de espaço reservado e não devem ser usados. Eles talvez se tornem obsoletos em uma versão futura.

Exemplos¶

Recupere informações sobre os arquivos de dados Parquet para o instantâneo atual registrado em uma tabela Iceberg gerenciada externamente chamada my_iceberg_table:

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

Saída:

+-------------------------------------------------------+--------------------------------+------------+--------------------------------+------------+------------------+-----------------------------------+-----------------------------------+
| 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                              |
+-------------------------------------------------------+--------------------------------+------------+--------------------------------+------------+------------------+-----------------------------------+-----------------------------------+

Recupere as informações sobre os arquivos de dados Parquet de uma tabela nomeada my_iceberg_table em um dia e hora especificados:

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)
    )
  );

Saída:

+------------------------------------------------------+-----------+-----------+-----------------+----------------------------------+----------------------------------+
| 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