`$tumblingWindow`

Nesta página

Definição

Sintaxe
Comportamento

Definição

O estágio $tumblingWindow especifica umajanela em cascata para agregação de dados. As janelas do Atlas Stream Processing são com estado, podem ser recuperadas se interrompidas e têm mecanismos para processar dados atrasados. Você deve aplicar todas as outras queries de agregação aos seus dados de streaming dentro desse estágio da janela.

$tumblingWindow

Um estágio de pipeline do $tumblingWindow tem a seguinte forma de protótipo:

{
  "$tumblingWindow": {
    "interval": {
      "size": <int>,
      "unit": "<unit-of-time>"
    },
    "pipeline" : [
      <aggregation-stage-array>
    ],
    "offset": {
      "offsetFromUtc": <int>,
      "unit": "<unit-of-time>"
    },
    "idleTimeout": {
      "size": <int>,
      "unit": "<unit-of-time>"
    },
    "allowedLateness": {
      size: <int>,
      unit: "<unit-of-time>"
    }
  }
}

Sintaxe

O estágio $tumblingWindow recebe um documento com os seguintes campos:

Campo	Tipo	necessidade	Descrição
`interval`	documento	Obrigatório	Documento que especifica o intervalo de uma janela de salto como uma combinação de um tamanho e uma unidade de tempo em que: O valor de `size` deve ser um número inteiro positivo diferente de zero. O valor de `unit` deve ser um dos seguintes: `"ms"` (milésimo de segundo) `"second"` `"minute"` `"hour"` `"day"` Por exemplo, um `size` de `20` e um `unit` de `second` define cada janela para permanecer aberta por 20 segundos.
`pipeline`	array	Obrigatório	Pipeline de agregação aninhado avaliado em relação às mensagens dentro da janela.
`offset`	documento	Opcional	Documento que especifica uma compensação de horário para os limites da janela em relação ao UTC. O documento é uma combinação do campo de tamanho `offsetFromUtc` e uma unidade de tempo em que: O valor de `offsetFromUtc` deve ser um número inteiro positivo diferente de zero. O valor de `unit` deve ser um dos seguintes: `"ms"` (milésimo de segundo) `"second"` `"minute"` `"hour"` Por exemplo, um `offsetFromUtc` de `8` e um `unit` de `hour` gera limites que são deslocados oito horas à frente do UTC. Se você não especificar um deslocamento, os limites da janela se alinharão com UTC.
`idleTimeout`	documento	Opcional	Documento que especifica quanto tempo esperar antes de fechar Windows se `$source` estiver ocioso. Defina essa configuração como uma combinação de `size` e `unit` de tempo em que: O valor de `size` deve ser um número inteiro positivo diferente de zero. O valor de `unit` pode ser um dos seguintes: `"ms"` (milésimo de segundo) `"second"` `"minute"` `"hour"` `"day"` Se você definir `idleTimeout`, o Atlas Stream Processing fechará as Windows abertas somente se `$source` estiver ocioso por mais tempo do que o maior entre o tempo restante da janela ou o tempo `idleTimeout`. O temporizador ocioso começa assim que `$source` fica ocioso. Por exemplo, considere uma janela 12:00 pm a 1:00 pm e `idleTimeout` tempo de 2 horas. Se o último evento for às 12:02 pm, após o qual `$source` fica inativo, o tempo restante da janela é 58 minutos. O Atlas Stream Processing fecha a janela após 2 horas de inatividade às 2:02 pm, que é maior que o tempo restante da janela e o tempo `idleTimeout` . Se o tempo `idleTimeout` estiver definido para apenas 10 minutos, o Atlas Stream Processing fechará a janela após 58 minutos de inatividade às 1:00 pm, que é mais longo que o tempo `idleTimeout` e a janela restante tempo.
`allowedLateness`	documento	Opcional	Documento que especifica por quanto tempo manter as janelas geradas a partir da origem abertas para aceitar dados que chegam atrasados após o processamento de documentos para o tempo final da janela. Se omitido, o padrão é 3 segundos.

Comportamento

O Atlas Stream Processing permite apenas um estágio de janela por pipeline.

Quando você aplica o estágio $group ao estágio da janela, uma única chave de grupo tem um limite de 100 megabytes de RAM.

O suporte para determinados estágios de agregação pode ser limitado ou indisponível no Windows. Para saber mais, consulte Estágios de aggregation pipeline suportados.

No caso de uma interrupção de serviço, você pode retomar o pipeline interno de uma janela de seu estado no ponto de interrupção. Para saber mais, consulte Checkpoints.

← $hoppingWindow

$emit →