Como configurar conectores de tabela wide ao usar Flink SQL para enviar tarefas de computação - : Central de Documentação do Alibaba Cloud

Ao usar o mecanismo de streaming do Lindorm para processar tarefas de computação, você pode utilizar tabelas wide como tabelas de dimensão ou de resultado. Este tópico descreve como configurar conectores de tabela wide ao usar Flink SQL para enviar tarefas de computação.

Informações básicas

Para enviar uma tarefa de computação no mecanismo de streaming do Lindorm com Flink SQL, execute a instrução CREATE TABLE e configure os parâmetros relacionados ao conector.

Uso de tabelas wide no mecanismo de streaming do Lindorm

CREATE TABLE lindorm_table(
  c1 VARCHAR,
  c2 DOUBLE,
  c3 BIGINT,
  PRIMARY KEY (c1, c2) NOT ENFORCED -- The primary key specified in the statement must be the same as the primary key of the result table created in LindormTable.
)WITH(
      'connector'='lindorm',
      'seedServer'='ld-bp17pwu1541ia****-proxy-lindorm.lindorm.rds.aliyuncs.com:30020',
      'userName'='yourUser',
      'password'='yourPassword',
      'tableName'='yourTablename',
      'namespace'='yourNamespace'
    ); -- Configure connector-related parameters in the WITH clause.

Nota

Para obter mais informações sobre a instrução CREATE TABLE, consulte CREATE TABLE.

Parâmetros relacionados ao conector

Parâmetros comuns

Parâmetro	Valor padrão	Obrigatório	Descrição
seedServer	Nenhum	Sim	Endpoint usado para conectar-se ao LindormTable pela API Java do HBase. Para mais informações, consulte Visualizar os endpoints do LindormTable.
namespace	Nenhum	Sim	Namespace ao qual a tabela wide pertence.
userName	Nenhum	Sim	Nome de usuário usado para conectar-se ao LindormTable.
password	Nenhum	Sim	Senha usada para conectar-se ao LindormTable.
tableName	Nenhum	Sim	Nome da tabela wide.
bufferSize	5000	Não	Número de lotes usados na gravação de dados.
flushIntervalMs	2000	Não	Intervalo entre execuções da operação `flush` durante a gravação de dados na tabela wide. Unidade: milissegundos. Se o volume de dados gravados na tabela wide for baixo, a operação `flush` ocorrerá conforme o intervalo especificado. Nota O volume de dados que aciona a operação flush no intervalo especificado varia conforme o cenário de negócios.
columnFamily	f	Não	Nome da família de colunas. Nota Ao usar uma tabela wide no mecanismo de streaming do Lindorm, a obrigatoriedade do parâmetro columnFamily depende do método de criação da tabela. Se a tabela wide foi criada com a API Java do ApsaraDB for HBase, este parâmetro é obrigatório. Se a tabela wide foi criada com Lindorm SQL, este parâmetro é opcional.

Parâmetros espaço-temporais

Parâmetro	Valor padrão	Obrigatório	Descrição
cacheTTLMs	-1	Não	Tempo de vida (TTL) do cache de dados. O valor padrão é -1, o que indica que nenhum cache de dados é gerado. Unidade: milissegundos. Após a expiração do cache de dados, o índice espaço-temporal é reconstruído na próxima consulta.
geomHint	Nenhum	Não	Consulta Lookup Join especificada. O valor deste parâmetro está no formato `<columnName>:<queryFunction>`. Exemplo: `fence:st_contains`. Quando a consulta Lookup Join é executada, a equação espaço-temporal na condição Join é substituída pela consulta espaço-temporal especificada. Por exemplo, a equação `fence=ST_MakePoint(x,y))` é substituída pela consulta `ST_Contains(fence, ST_MakePoint(x,y))` especificada. queryFunction oferece suporte às seguintes funções: ST_Contains ST_Within ST_DWithin ST_DWithinSphere ST_Intersects ST_Overlaps ST_Equals
geomIndex	Nenhum	Não	Coluna na qual o índice espaço-temporal é criado. As consultas Lookup Join para a tabela são aceleradas pelo índice em memória. Índices podem ser criados apenas para uma única coluna em uma tabela. As seguintes funções podem ser aceleradas por índices em memória: ST_Contains ST_Within ST_DWithin ST_DWithinSphere ST_Intersects ST_Overlaps ST_Equals Importante O parâmetro geomIndex deve ser especificado junto com os parâmetros geomHint e cacheTTLMs. O valor do parâmetro cacheTTLMs deve ser maior que 0.