Realtime Compute for Apache Flink:Gerenciar catálogos do Paimon

Os catálogos do Paimon conectam o Flink aos metadados do data lake armazenados no OSS ou no DLF. Saiba como criar e gerenciar catálogos, bancos de dados e tabelas.

-- Replace my-catalog with the name of your Paimon catalog.
-- Replace my_db with the name of the database that you want to use.
-- Replace my_tbl with the name of the Paimon catalog table that you created.
DROP TABLE `my-catalog`.`my_db`.`my_tbl`;

-- Replace my-catalog with the name of your Paimon catalog.
-- Replace my_db with the name of the database that you want to use.
-- Replace my_tbl with the name of the Paimon catalog table that you created.
DROP TABLE `my-catalog`.`my_db`.`my_tbl`;

-- Replace my-catalog with the name of your Paimon catalog.
-- Replace my_db with the name of the database that you want to use.
-- Replace my_tbl with the name of the Paimon catalog table that you created.
DROP TABLE `my-catalog`.`my_db`.`my_tbl`;

-- Replace my-catalog with the name of your Paimon catalog.
-- Replace my_db with the name of the database that you want to use.
-- Replace my_tbl with the name of the Paimon catalog table that you created.
DROP TABLE `my-catalog`.`my_db`.`my_tbl`;

Parâmetros de configuração:

• Geral

  Item de configuração	Descrição	Obrigatório	Observações
  my-catalog	O nome do catálogo Paimon.	Sim	Insira um nome personalizado.
  type	O tipo do catálogo.	Sim	O valor é fixo como paimon.
  metastore	O tipo de metastore.	Sim	Valores válidos: filesystem: Use este valor para configurar um catálogo Paimon Filesystem. dlf: Use este valor para configurar um catálogo Paimon DLF. maxcompute: Use este valor para configurar um catálogo Paimon MaxCompute. sync: Use este valor para configurar um catálogo Paimon Sync.

• Específico do Sync

  Item de configuração	Descrição	Obrigatório	Observações
  source	O source para sincronização de metadados.	Sim	Defina este parâmetro como dlf.
  target	O destino para sincronização de metadados.	Sim	Defina este parâmetro como maxcompute.

• OSS

  Item de configuração	Descrição	Obrigatório	Observações
  warehouse	O diretório do data warehouse no OSS.	Sim	O formato é oss://<bucket>/<object>, em que: bucket: o nome do seu bucket do OSS. object: o caminho onde seus dados estão armazenados. Visualize os nomes do seu bucket e do seu objeto no console do OSS.
  fs.oss.endpoint	O endpoint do service do OSS.	Sim	Se o Flink e o DLF estiverem na mesma região, use o endpoint de VPC. Caso contrário, use o endpoint de rede pública. Este parâmetro é obrigatório se o bucket do OSS especificado para warehouse não estiver na mesma região do workspace do Flink, ou se você usar um bucket do OSS que pertença a outra conta do Alibaba Cloud. Regiões e Endpoints e Criar um AccessKey.
  fs.oss.accessKeyId	O AccessKeyID da conta do Alibaba Cloud ou do usuário do RAM que tem permissões de leitura e gravação no OSS.	Sim
  fs.oss.accessKeySecret	O AccessKeySecret da conta do Alibaba Cloud ou do usuário do RAM que tem permissões de leitura e gravação no OSS.	Sim

• DLF

  Item de configuração	Descrição	Obrigatório	Observações
  dlf.catalog.id	O ID do catálogo de dados do DLF.	Sim	Visualize o ID do catálogo de dados no console do Data Lake Formation.
  dlf.catalog.accessKeyId	O AccessKeyID necessário para acessar o service do DLF.	Sim	Para mais informações, consulte Criar um AccessKey.
  dlf.catalog.accessKeySecret	O AccessKeySecret necessário para acessar o service do DLF.	Sim	Para mais informações, consulte Criar um AccessKey.
  dlf.catalog.endpoint	O endpoint do service do DLF.	Sim	Regiões e endpoints. Nota Se o Flink e o DLF estiverem na mesma região, use o endpoint de VPC. Caso contrário, use o endpoint de rede pública.
  dlf.catalog.region	A região onde o DLF está localizado.	Sim	Regiões e endpoints. Nota Certifique-se de que a região seja a mesma especificada para dlf.catalog.endpoint.

• maxcompute

  Item de configuração	Descrição	Obrigatório	Observações
  maxcompute.endpoint	O endpoint do service do MaxCompute.	Sim	Endpoint.
  maxcompute.project	O nome do projeto do MaxCompute a ser operado.	Sim	Atualmente, não há suporte para projetos do MaxCompute com Operações de Schema ativadas.
  maxcompute.accessid	O AccessKey da conta do Alibaba Cloud que tem permissões no MaxCompute.	Sim	Criar um AccessKey.
  maxcompute.accesskey	O AccessKeySecret da conta do Alibaba Cloud que tem permissões no MaxCompute.	Sim	Criar um AccessKey.
  maxcompute.oss.endpoint	O endpoint para acessar o service do OSS a partir do MaxCompute.	Não	Se você não especificar este parâmetro, o valor do parâmetro fs.oss.endpoint será usado por padrão. Região e Endpoint. Nota Como o bucket do OSS e o projeto do MaxCompute estão na mesma região, especifique um endpoint interno.
  maxcompute.life-cycle	O ciclo de vida da tabela externa do MaxCompute.	Não	A unidade é dias.