Realtime Compute for Apache Flink:Configuração de parâmetros (VVR 11+)

Parâmetro

Descrição

Tipo

Obrigatório

Padrão

Observações

connector

Tipo da tabela.

String

Sim

—

O valor deve ser hologres.

dbname

Nome do banco de dados.

String

Sim

—

É possível conectar-se a um virtual warehouse específico adicionando um sufixo ao nome do banco de dados. Por exemplo, para conectar uma tabela de dimensão ao virtual warehouse read_warehouse, especifique 'dbname' = 'db_test@read_warehouse'.

tablename

Nome da tabela.

String

Sim

—

Se o schema não for public, utilize o formato schema.tableName.

username

• Nome de usuário de uma conta personalizada, no formato BASIC$<user_name>.

• AccessKey ID de uma conta Alibaba Cloud ou usuário RAM.

String

Sim

—

• O usuário especificado deve ter permissões para acessar o banco de dados Hologres correspondente. Para mais informações sobre permissões e gerenciamento de usuários no Hologres, consulte Development permission models e Manage users.

• Para obter informações sobre como adquirir um AccessKey ID e AccessKey secret, consulte How do I view the AccessKey ID and AccessKey secret?.

password

• Senha da conta personalizada.

• AccessKey secret de uma conta Alibaba Cloud ou usuário RAM.

String

Sim

—

endpoint

Endpoint do service Hologres.

String

Sim

—

Para mais informações, consulte Endpoints.

connection.pool.size

Tamanho do pool de conexões JDBC criado para uma única tabela Flink dentro de uma tarefa.

Integer

Não

5

Se o desempenho do job for insuficiente, considere aumentar o tamanho do pool de conexões. O tamanho do pool é proporcional ao throughput de dados. Este parâmetro afeta apenas tabelas de dimensão e tabelas sink.

connection.pool.name

Tabelas no mesmo TaskManager podem compartilhar um pool de conexões usando o mesmo nome.

String

Não

'default'

O valor padrão é 'default'. Se várias tabelas estiverem configuradas para usar o mesmo pool de conexões, o maior valor especificado para o parâmetro connection.pool.size entre elas será utilizado.

Por exemplo, se um job contiver cinco tabelas Hologres (tabelas de dimensão A e B, e tabelas sink C, D e E), você pode configure as tabelas A e B para usarem pool1, as tabelas C e D para usarem pool2, e a tabela E, que lida com alto tráfego, para usar pool3.

connection.fixed.enabled

Defina se o modo de conexão leve deve ser usado.

Boolean

Não

—

O Hologres possui um connection limit. A partir do Hologres V2.1, escritas em tempo real suportam conexões leves que não estão sujeitas a esse limite.

connection.max-idle-ms

Tempo limite de ociosidade para uma conexão JDBC, em milissegundos.

Long

Não

60000

Se uma conexão permanecer ociosa por mais tempo que este valor, ela será fechada. Uma nova conexão é criada automaticamente quando necessário.

connection.ssl.mode

Especifique se a criptografia Secure Sockets Layer (SSL) em trânsito deve ser ativada e qual modo utilizar.

String

Não

disable

• disable (padrão): Desativa a criptografia em trânsito.

• require: Ative SSL e criptografa apenas o link de dados.

• verify-ca: Ative SSL, criptografa o link de dados e usa um certificado CA para verifique a autenticidade do servidor Hologres.

• verify-full: Ative SSL, criptografa o link de dados, usa um certificado CA para verifique a autenticidade do servidor Hologres e valida se o Common Name (CN) ou nome DNS no certificado corresponde ao endpoint Hologres configurado.

connection.ssl.root-cert.location

Caminho para o certificado CA, necessário para modos de criptografia baseados em certificado.

String

Não

—

Se connection.ssl.mode estiver definido como verify-ca ou verify-full, você deve especifique o caminho para o certificado CA. É possível fazer upload do arquivo de certificado usando o recurso Manage artifacts no console Realtime Compute. Após o upload, o arquivo é armazenado no diretório /flink/usrlib. Por exemplo, se o arquivo de certificado CA se chamar certificate.crt, defina este parâmetro como '/flink/usrlib/certificate.crt'.

retry-count

Número de vezes para tentar novamente uma operação de escrita ou consulta em caso de falha de conexão.

Integer

Não

10

—

retry-sleep-step-ms

Tempo de espera incremental para cada nova tentativa, em milissegundos.

Long

Não

5000

Por exemplo, com o valor padrão de 5.000 (5 segundos), a primeira tentativa aguarda 5 segundos, a segunda 10 segundos, e assim por diante.

meta-cache-ttl-ms

Tempo de vida (TTL) para informações de TableSchema armazenadas em cache localmente, em milissegundos.

Long

Não

600000

Unidade: milissegundos.

serverless-computing.enabled

Defina se recursos serverless devem ser usados.

Boolean

Não

false

Se este parâmetro for definido como true, o conector utiliza recursos serverless do Hologres para operações de leitura e escrita, em vez dos recursos da sua instância Hologres. Este parâmetro é suportado apenas para leituras em lote e importações em lote. Ele não é válido para consumo de binary log, consultas pontuais de tabela de dimensão ou escritas em tempo real. Para mais informações, consulte Overview.

Parâmetro

Descrição

Tipo

Obrigatório

Padrão

Observações

source.binlog

Defina se dados binlog devem ser consumidos.

Boolean

Não

true

• true (padrão): Consome dados binlog.

• false: Não consome dados binlog. O job realiza uma leitura em lote e depois para.

source.binlog.read-mode

Especifique o modo de leitura.

ENUM

Não

AUTO

• AUTO (padrão): Selecione automaticamente o modo ideal com base na versão da instância.

• HOLOHUB: Usa o modo HoloHub para consumir dados binlog.

• JDBC: Usa o modo JDBC para consumir dados binlog.

source.binlog.change-log-mode

Especifique os tipos de ChangeLog suportados pela tabela de source CDC.

ENUM

Não

UPSERT

• ALL: Suporta todos os tipos de ChangeLog, incluindo INSERT, DELETE, UPDATE_BEFORE e UPDATE_AFTER.

• UPSERT (padrão): Suporta apenas ChangeLogs upsert, incluindo INSERT, DELETE e UPDATE_AFTER.

• ALL_AS_APPEND_ONLY: Trata todos os tipos de ChangeLog como INSERT.

source.binlog.startup-mode

Especifique o modo de consumo para dados binlog.

ENUM

Não

INITIAL

• INITIAL (padrão): Realiza uma leitura completa dos dados e, em seguida, inicia o consumo incremental a partir do binlog.

• EARLIEST_OFFSET: Inicia o consumo a partir do offset binlog mais antigo disponível.

• TIMESTAMP: Inicia o consumo a partir do binlog no startTime especificado.

• LATEST_OFFSET: Inicia o consumo a partir do offset binlog mais recente.

source.binlog.batch-size

Especifique o número de linhas a serem lidas por lote do binlog.

Integer

Não

512

Não aplicável.

source.binlog.request-timeout-ms

Especifique o timeout para leitura de dados binlog.

Long

Não

300000

Unidade: milissegundos.

source.binlog.project-columns.enabled

Defina se apenas os campos especificados na tabela do usuário devem ser lidos ao consumir dados binlog.

Boolean

Não

Nenhum

Os campos especificados são aqueles declarados na instrução CREATE TEMPORARY TABLE; campos não declarados não são lidos. Quando uma tabela possui muitos campos, mas você precisa consumir apenas um subconjunto, esta opção evita transferência e conversão desnecessárias de dados, melhorando o desempenho de leitura e economizando largura de banda.

source.binlog.compression.enabled

Defina se a compressão de dados em trânsito deve ser ativada durante a leitura de dados binlog.

Boolean

Não

Nenhum

Ao consumir o binlog, o servidor retorna um fluxo de bytes comprimido com o algoritmo LZ4. Isso melhora o desempenho de leitura e reduz o uso de largura de banda.

source.binlog.partition-binlog-mode

Especifique o modo de consumo de binlog para uma tabela particionada.

Enum

Não

DISABLE

• DISABLE (padrão): Use para tabelas de source não particionadas. O job lança uma exceção se a tabela Hologres especificada for particionada.

• DYNAMIC: Consome continuamente as partições mais recentes de uma tabela particionada. A tabela deve ter dynamic partitioning ativado. O modo DYNAMIC consome partições em ordem cronológica. Quando o consumo atinge a penúltima partição, ele começa a consumir a partição mais recente assim que uma nova unidade de tempo se inicia.

• STATIC: Consome um conjunto fixo de partições de uma tabela particionada. Múltiplas partições podem ser consumidas simultaneamente. Partições não podem ser adicionadas ou removidas durante o consumo. Por padrão, consome todas as partições da tabela pai.

source.binlog.partition-binlog-lateness-timeout-minutes

No modo DYNAMIC, especifique o timeout máximo de atraso ao consumir uma tabela particionada.

Integer

Não

60

• Unidade: minutos. No modo DYNAMIC, quando uma nova unidade de tempo se inicia, o conector começa a consumir a partição mais recente para o tempo atual. No entanto, ele não fecha imediatamente a partição anterior, continuando a monitorá-la para capturar dados que chegam com atraso.

Por exemplo, se o particionamento dinâmico for por DIA, para a partição 20240920, e o atraso máximo de dados for de 1 hora, o consumo desta partição será encerrado às 2024-09-21 01:00:00, e não às 2024-09-21 00:00:00.

• O valor de lateness-timeout não pode exceder a unidade de tempo da partição.

Se o particionamento for por dia, o valor máximo é 24 * 60 = 1440 minutos. No modo DYNAMIC, o conector geralmente consome apenas uma partição por vez, mas pode consumir duas partições simultaneamente durante o período de atraso.

source.binlog.partition-values-to-read

No modo STATIC, especifique as partições a serem consumidas. Use vírgulas (,) para separar os valores de partição.

String

Não

Nenhum

• Se você não configure este parâmetro, o modo STATIC consome todas as partições da tabela pai especificada. Se configurado, consome apenas as partições especificadas.

• Especifique apenas os valores de partição, não os nomes completos das partições. Separe múltiplos valores com vírgulas (,). Este parâmetro não suporta expressões regulares.

startTime

Especifique o horário inicial para o offset de consumo.

String

Não

Nenhum

Formato: yyyy-MM-dd hh:mm:ss. Se este parâmetro não for definido e o job não estiver retomando de um estado salvo, o consumo começa a partir do binlog mais antigo.

source.scan.fetch-size

Especifique o tamanho do lote para leituras em lote.

Integer

Não

512

Não aplicável.

source.scan.timeout-seconds

Especifique o timeout para leituras em lote.

Integer

Não

60

Unidade: segundos.

source.scan.filter-push-down.enabled

Defina se filtros devem ser enviados (push down) durante uma leitura em lote.

Boolean

Não

false

• false (padrão): Não envia filtros.

• true: Envia condições de filtro suportadas para o Hologres durante uma leitura em lote.

source.binlog.filter-push-down.enabled

Defina se filtros devem ser enviados (push down) durante o consumo de binlog.

Boolean

Não

false

• false (padrão): Não envia filtros.

• true: Envia condições de filtro suportadas para o Hologres durante o consumo de binlog.

scan.prefer.physical-column.over.metadata-column

Defina se a leitura de dados de uma coluna física deve ter prioridade quando ela compartilha o mesmo nome de uma coluna de metadados.

Boolean

Não

false

Este parâmetro é suportado apenas no VVR 11.5 e posteriores. Versões anteriores sempre priorizam a leitura de dados da coluna de metadados.

Parâmetro

Descrição

Tipo

Obrigatório

Padrão

Observações

sink.write-mode

Modo de escrita de dados.

ENUM

Não

INSERT

• INSERT: Padrão. Usa JDBC para escrever dados com instruções INSERT.

• COPY_STREAM: Usa o método de streaming COPY fixo, uma opção de alto desempenho para cenários que exigem alto throughput e baixa latência. Este modo não suporta exclusão de dados, escrita em uma tabela pai particionada ou uso do parâmetro sink.ignore-null-when-update.enabled.

• COPY_BULK_LOAD: Realiza escritas em massa usando o protocolo COPY. COPY_BULK_LOAD aplica-se atualmente apenas a tabelas sem chave primária (uma exceção é lançada se houver duplicidade de chave primária). Comparado ao COPY_STREAM, este modo utiliza menos recursos do Hologres para escritas.

• COPY_BULK_LOAD_ON_CONFLICT: Usa o protocolo COPY para escritas em lote e suporta escrita em tabelas com chave primária, além de lidar com conflitos de chave primária.

sink.on-conflict-action

Política para tratar conflitos de chave primária.

ENUM

Não

INSERT_OR_UPDATE

• INSERT_OR_IGNORE: Mantém o primeiro registro e ignora todos os registros subsequentes com a mesma chave primária.

• INSERT_OR_REPLACE: Substitui toda a linha existente pela nova linha.

• INSERT_OR_UPDATE: Padrão. Atualize um subconjunto de colunas em uma linha existente.

  Por exemplo, considere uma tabela com as colunas a, b, c e d, onde a é a chave primária. Se um registro recebido fornecer valores apenas para as colunas a e b, um conflito de chave primária fará com que o sistema atualize apenas a coluna b e deixe as colunas c e d inalteradas.

sink.create-missing-partition

Defina se uma partição deve ser criada automaticamente com base no valor de partição, caso não exista uma correspondente ao escrever em uma tabela particionada.

Boolean

Não

false

• Se você usar o tipo de dados DATE como chave de partição e ative dynamic partitioning, os nomes das partições criadas automaticamente seguem a convenção de nomenclatura de particionamento dinâmico.

• Use este parâmetro com cautela. Certifique-se de que os valores de partição não contenham dados incorretos (dirty data). Caso contrário, você poderá crie partições incorretas, o que pode levar a um failover.

• Se sink.write-mode não for INSERT, não é possível escrever em uma tabela pai particionada.

sink.delete-strategy

Política para lidar com mensagens de retração.

String

Não

CHANGELOG_STANDARD

• IGNORE_DELETE: Ignora mensagens UPDATE_BEFORE e DELETE. Esta opção é adequada para cenários que requerem apenas inserções ou atualizações, mas não exclusões.

• NON_PK_FIELD_TO_NULL: Ignora mensagens UPDATE_BEFORE e processa mensagens DELETE definindo campos que não são chave primária como NULL. Esta opção é adequada para cenários de atualização parcial onde você deseja realizar uma exclusão sem afetar outras colunas.

• DELETE_ROW_ON_PK: Ignora mensagens UPDATE_BEFORE e processa mensagens DELETE excluindo a linha inteira com base na chave primária. Esta opção é adequada para cenários de atualização parcial onde você deseja exclua a linha inteira.

• CHANGELOG_STANDARD: Segue o mecanismo padrão de changelog do Flink SQL. Não ignora operações de exclusão. Esta opção realiza atualizações excluindo primeiro o registro antigo e depois inserindo o novo, garantindo a precisão dos dados. Esta opção é adequada para cenários que não envolvem atualizações parciais.

sink.ignore-null-when-update.enabled

Quando sink.on-conflict-action é 'INSERT_OR_UPDATE', especifique se valores nulos nos dados recebidos devem ser ignorados durante uma atualização.

Boolean

Não

false

• false: Padrão. Escreve valores nulos na tabela sink Hologres.

• true: Ignora valores nulos nos dados de atualização recebidos.

sink.ignore-null-when-update-by-expr.enabled

Quando sink.on-conflict-action é 'INSERT_OR_UPDATE', especifique se um método baseado em expressão deve ser usado para ignorar valores nulos nos dados de atualização recebidos.

Boolean

Não

false

Este método oferece melhor desempenho do que sink.ignore-null-when-update.enabled.

• false: Padrão.

  • Se sink.ignore-null-when-update.enabled for true, valores nulos nas atualizações são ignorados.

  • Se sink.ignore-null-when-update.enabled for false, valores nulos são escritos na tabela sink Hologres.

• true: Ignora valores nulos nos dados de atualização recebidos, independentemente da configuração de sink.ignore-null-when-update.enabled.

sink.ignore-null-when-update.use-builtin.enabled

Defina se o método integrado do SDK Hologres deve ser usado quando sink.ignore-null-when-update.enabled ou sink.ignore-null-when-update-by-expr.enabled estiver ativado.

Boolean

Não

false

• false (padrão): Comporta-se da mesma forma que sink.ignore-null-when-update.enabled ou sink.ignore-null-when-update-by-expr.enabled.

• true: Quando sink.ignore-null-when-update-by-expr.enabled está ativado, o desempenho é superior ao de ative apenas sink.ignore-null-when-update-by-expr.enabled.

O desempenho é equivalente quando sink.ignore-null-when-update.enabled está ativado.

sink.default-for-not-null-column.enabled

Especifique se o conector fornece um valor padrão quando null é escrito em uma coluna NOT NULL que não possui um valor padrão definido.

Boolean

Não

true

• true: Padrão. Permite que o conector forneça e escreva um valor padrão com base nas seguintes regras:

  • Para o tipo de dados String, uma string vazia ("") é escrita.

  • Para o tipo de dados Number, 0 é escrito.

  • Para os tipos de dados Date, timestamp ou timestamptz, 1970-01-01 00:00:00 é escrito.

• false: Não fornece um valor padrão. Escrever um valor nulo em uma coluna NOT NULL lança uma exceção.

sink.remove-u0000-in-text.enabled

Especifique se o conector remove o caractere ilegal \u0000 de tipos string durante uma operação de escrita.

Boolean

Não

true

• false: O conector não modifique os dados. Se dados incorretos forem encontrados, uma operação de escrita pode lançar um erro semelhante ao seguinte: ERROR: invalid byte sequence for encoding "UTF8": 0x00

  Nesse caso, você deve processar os dados incorretos na tabela de source ou defina a lógica para lidar com eles em sua instrução SQL.

• true: Padrão. O conector remove o caractere \u0000 de tipos string para evitar erros de escrita.

sink.partial-insert.enabled

Defina se apenas os campos definidos na instrução INSERT devem ser inseridos ou atualizados.

Boolean

Não

false

• false: Padrão. Todos os campos definidos no DDL da tabela sink são atualizados. Campos não declarados na instrução INSERT são atualizados para null.

• true: Envia apenas os campos definidos na instrução INSERT para o conector, permitindo atualize ou insira apenas os campos declarados.

sink.deduplication.enabled

Especifique se a deduplicação deve ser realizada durante o agrupamento em lote.

Boolean

Não

true

• true: Padrão. Se um lote contiver vários registros com a mesma chave primária, o conector os deduplica e escreve apenas o último registro na tabela sink Hologres. Considere uma tabela com dois campos, onde o primeiro é a chave primária:

  • Se os registros INSERT (1,'a') e INSERT (1,'b') chegarem em sequência, apenas o último registro, (1,'b'), será escrito na tabela sink Hologres após a deduplicação.

  • Se a tabela sink Hologres já contiver o registro (1,'a'), e os registros DELETE (1,'a') e INSERT (1,'b') chegarem em sequência, apenas o último registro (1,'b') será escrito no Hologres. Isso resulta em uma atualização direta em vez de uma exclusão seguida de uma inserção.

• false: Desativa a deduplicação durante o agrupamento em lote. Se um novo registro tiver a mesma chave primária que um registro no lote atual, o lote é primeiro escrito no sink e, em seguida, o novo registro é processado.

sink.aggressive-flush.enabled

Defina se o modo de flush agressivo deve ser ativado.

Boolean

Não

false

Se definido como true, o conector força o envio (flush) de um lote quando a conexão está ociosa, mesmo que o lote não tenha atingido seu tamanho configurado. Isso reduz a latência de escrita de dados durante períodos de baixo tráfego.

sink.insert.check-and-put.column

Habilite atualizações condicionais e especifique a coluna a ser verificada.

String

Não

Nenhum

O valor deste parâmetro deve ser um nome de coluna existente na tabela Hologres.

sink.insert.check-and-put.operator

Operador de comparação para a operação de atualização condicional.

String

Não

GREATER

Compara a coluna de verificação do registro recebido com o valor existente na tabela. A atualização prossegue se a condição for atendida. Os operadores suportados são: GREATER, GREATER_OR_EQUAL, EQUAL, NOT_EQUAL, LESS, LESS_OR_EQUAL, IS_NULL e IS_NOT_NULL.

sink.insert.check-and-put.null-as

Durante uma atualização condicional, trata um valor nulo nos dados existentes como o valor especificado por este parâmetro.

String

Não

Nenhum

No PostgreSQL, qualquer comparação com NULL retorna FALSE. Portanto, quando o valor existente na tabela for NULL, você deve defina este parâmetro com um valor específico para usar na comparação. Isso equivale à função COALESCE em SQL.

sink.insert.batch-size

No modo INSERT, o número máximo de registros a serem incluídos em um lote antes da escrita.

Integer

Não

512

O conector aciona uma escrita quando qualquer um dos limiares sink.insert.batch-size, sink.insert.batch-byte-size ou sink.insert.flush-interval-ms é atingido.

sink.insert.batch-byte-size

No modo INSERT, o tamanho máximo em bytes de um lote antes da escrita.

Long

Não

2097152 (2 MB)

sink.insert.flush-interval-ms

No modo INSERT, o intervalo máximo em milissegundos a aguardar antes que um lote seja enviado (flush) para o Hologres.

Long

Não

10000

sink.copy.format

Formato de transmissão de dados usado no modo COPY.

String

Não

• O modo COPY_STREAM tem como padrão binary.

• O modo COPY_BULK_LOAD ou COPY_BULK_LOAD_ON_CONFLICT tem como padrão text.

Formatos suportados para o modo COPY_STREAM:

• binary

• text

• binaryrow (Requer mecanismo Hologres V4.1.0 ou posterior)

Formato suportado para o modo COPY_BULK_LOAD ou COPY_BULK_LOAD_ON_CONFLICT: apenas text

sink.insert.conflict-update-set

Expressão Hologres usada para atualize a linha quando ocorre um conflito de chave primária.

String

Não

Nenhum

Equivalente a insert into tbl values(xxx) on conflict(pk) do update set <conflict-update-set>. Você pode especifique uma expressão ou função Hologres.

Por exemplo, se este parâmetro for definido como col1=old.col1+excluded.col1,col2=excluded.col2, um conflito de chave primária fará com que o valor de col1 seja atualizado para a soma dos valores antigo e novo, e o valor de col2 seja atualizado para o novo valor.

• Se este parâmetro não for especificado, o conector atualize todos os campos recebidos para seus novos valores por padrão.

• Para expressões com estado onde o resultado depende do valor antigo (por exemplo, col=old.col+excluded.col), garanta que uma coluna possa servir como número de versão da linha e defina sink.insert.conflict-where como excluded.seq>old.seq. Isso garante a correção dos dados após um failover e recuperação.

sink.insert.conflict-where

Condição de filtro Hologres para acionar uma atualização durante um conflito de chave primária.

String

Não

Nenhum

Equivalente a insert into tbl values(xxx) on conflict(pk) do update set <conflict-update-set> where <conflict-where>. Você pode especifique uma expressão ou função Hologres.

Por exemplo, se este parâmetro for definido como excluded.col1>old.col1, uma atualização será acionada apenas quando o novo valor de col1 for maior que o valor existente.

Parâmetro

Descrição

Tipo

Obrigatório

Padrão

Observações

lookup.read.batch-size

Número máximo de registros a serem agrupados em lote para consultas pontuais em uma tabela de dimensão Hologres.

Integer

Não

256

Nenhum

lookup.read.timeout-ms

Timeout para consultas pontuais em uma tabela de dimensão.

Long

Não

0, o que significa sem timeout.

Nenhum

lookup.read.column-table.enabled

Defina se uma tabela orientada a colunas deve ser usada como tabela de dimensão.

Boolean

Não

false

Tabelas orientadas a colunas têm baixo desempenho para consultas pontuais. Recomendamos usar uma tabela orientada a linhas ou híbrida linha-coluna como tabela de dimensão. Um aviso é registrado se este parâmetro for ativado para uma tabela orientada a colunas.

lookup.insert-if-not-exists

Defina se um registro deve ser inserido caso não exista.

Boolean

Não

false

Se uma consulta pontual não encontrar correspondência para o registro atual na tabela de dimensão, o conector insere o registro.

cache

Política de cache.

String

Não

Nenhum

O Hologres suporta apenas duas políticas de cache: None e LRU.

cacheSize

Tamanho do cache, em linhas.

Integer

Não

10000

Após selecione a política de cache LRU, você pode defina o tamanho do cache. A unidade é entradas.

cacheTTLMs

Tempo de vida (TTL) do cache, em milissegundos.

Long

Não

Ver Observações.

A unidade é milissegundos. O valor padrão de cacheTTLMs depende da configuração do cache:

• Se o cache estiver configurado como LRU, cacheTTLMs especifique o timeout do cache. A configuração padrão é sem expiração.

• Se o cache estiver configurado como None, cacheTTLMs pode ser omitido, indicando que o cache não expira.

cacheEmpty

Defina se resultados de junção vazios devem ser armazenados em cache.

Boolean

Não

true

• true (Padrão): Armazena resultados de junção vazios em cache.

• false: Não armazena resultados de junção vazios em cache.

  No entanto, se a condição antes de AND em uma instrução de junção for atendida, mas a condição após AND não for, o resultado vazio ainda será armazenado em cache. O código a seguir fornece um exemplo.

  LEFT JOIN latest_emergency FOR SYSTEM_TIME AS OF PROCTIME() AS t2
   ON t1.alarm_id = t2.alarm_id -- Se um alarme dinâmico for detectado, faça a correspondência usando o ID do alarme dinâmico. Caso contrário, ignore o campo de ID do alarme dinâmico.
   AND CASE
   WHEN alarm_type = 2 THEN t1.dynamic_id = t2.dynamic_alarm_id
   ELSE true
   END

async

Defina se os resultados devem ser retornados de forma assíncrona.

Boolean

Não

false

• true: Retorna resultados de forma assíncrona.

• false (Padrão): Retorna resultados de forma síncrona.

lookup.async

Defina se consultas assíncronas devem ser ativadas para tabelas de dimensão.

Boolean

Não

true

• true (Padrão): Ative consultas assíncronas.

• false: Desativa consultas assíncronas.

lookup.filter-push-down.enabled

Defina se as condições de filtro da tabela de dimensão devem ser enviadas (push down) para o servidor Hologres.

Boolean

Não

false

Este recurso suporta apenas operações de comparação entre uma coluna e uma constante. O conector envia apenas operadores de igualdade (=) e comparação (<, <=, >, >=).