Windowing

Kind: mechanism

Layer: Execution Core

Record: architecture:windowing

Severity: contextual

Scope: data processing, streaming, aggregation

Canonical: Ontology

A mechanism that groups an unbounded stream into bounded windows of event time and aggregates each window separately.

Listed in Architecture principles, after Stateless Processing and before Fan-out/Fan-in.

Requires

• Event Time

Reinforces

• Streaming Architecture
• Bounded State

Enables

• Bounded Aggregation over Unbounded Streams

Conflicts with

• Unbounded Accumulation

In tension with

• Late-Data Handling

Tensions

• Windowing / Late-Data Handling

Violated by

• Unbounded Accumulation

Severity

• contextual

Category

• Streaming / Pipeline / Dataflow Processing

Refactors

• Forward-Only Processing

Linked from

• Streaming / Pipeline / Dataflow Processing
• Streaming / Pipeline / Dataflow Processing
• Severity levels
• The resolutions