# Streaming / Pipeline / Dataflow Processing

> Every term in this category is listed as one record, with its kind, its definition and its aliases, the principles whose relations name it, the principle or…

Page: Ontology · Lexicon
Canonical: https://banes-lab.com/ontology/lexicon#lex-category-streaming-pipeline-dataflow-processing

Every term in this category is listed as one record, with its kind, its definition and its aliases, the principles whose relations name it, the principle or contract that carries the same name where one exists, and the layer its category belongs to.

### Avoiding Unneeded Work

- Kind: [capability](https://banes-lab.com/records/kind/capability.md)
- Category: [Streaming / Pipeline / Dataflow Processing](https://banes-lab.com/ontology/lexicon/lex-category-streaming-pipeline-dataflow-processing.md)
- Layer: [Execution Core](https://banes-lab.com/records/layer/execution-core.md)

Details

Definition
The ability to skip computing results that are never used.

Referenced by
[Lazy Evaluation](https://banes-lab.com/records/arch/lazy-evaluation.md)

### Backtracking Algorithm

- Kind: [technique](https://banes-lab.com/records/kind/technique.md)
- Category: [Streaming / Pipeline / Dataflow Processing](https://banes-lab.com/ontology/lexicon/lex-category-streaming-pipeline-dataflow-processing.md)
- Layer: [Execution Core](https://banes-lab.com/records/layer/execution-core.md)

Details

Definition
A method that explores options and reverts to an earlier point when one fails, requiring the ability to look back.

Referenced by
[Forward-Only Processing](https://banes-lab.com/records/arch/forward-only-processing.md)

### Batch-Only Processing

- Kind: [approach](https://banes-lab.com/records/kind/approach.md)
- Category: [Streaming / Pipeline / Dataflow Processing](https://banes-lab.com/ontology/lexicon/lex-category-streaming-pipeline-dataflow-processing.md)
- Layer: [Execution Core](https://banes-lab.com/records/layer/execution-core.md)

Details

Definition
Processing data in scheduled batches rather than as a continuous low-latency stream.

Referenced by
[Streaming Architecture](https://banes-lab.com/records/arch/streaming-architecture.md)

### Bounded Aggregation over Unbounded Streams

- Kind: [capability](https://banes-lab.com/records/kind/capability.md)
- Category: [Streaming / Pipeline / Dataflow Processing](https://banes-lab.com/ontology/lexicon/lex-category-streaming-pipeline-dataflow-processing.md)
- Layer: [Execution Core](https://banes-lab.com/records/layer/execution-core.md)

Details

Definition
The ability to aggregate an endless stream by grouping its events into bounded windows.

Referenced by
[Windowing](https://banes-lab.com/records/arch/windowing.md)

### Bounded State

- Kind: [quality-attribute](https://banes-lab.com/records/kind/quality-attribute.md)
- Category: [Streaming / Pipeline / Dataflow Processing](https://banes-lab.com/ontology/lexicon/lex-category-streaming-pipeline-dataflow-processing.md)
- Layer: [Execution Core](https://banes-lab.com/records/layer/execution-core.md)

Details

Definition
The degree to which processing keeps its working state within a fixed bound regardless of input size.

Referenced by
[Windowing](https://banes-lab.com/records/arch/windowing.md)

### Complex Grammar/Global State

- Kind: [quality-attribute](https://banes-lab.com/records/kind/quality-attribute.md)
- Category: [Streaming / Pipeline / Dataflow Processing](https://banes-lab.com/ontology/lexicon/lex-category-streaming-pipeline-dataflow-processing.md)
- Layer: [Execution Core](https://banes-lab.com/records/layer/execution-core.md)

Details

Definition
The degree to which forbidding backtracking makes complex grammars or global-state logic hard to express.

Referenced by
[Forward-Only Processing](https://banes-lab.com/records/arch/forward-only-processing.md)

### Control-Flow-Centric Monolith

- Kind: [anti-pattern](https://banes-lab.com/records/kind/anti-pattern.md)
- Category: [Streaming / Pipeline / Dataflow Processing](https://banes-lab.com/ontology/lexicon/lex-category-streaming-pipeline-dataflow-processing.md)
- Layer: [Execution Core](https://banes-lab.com/records/layer/execution-core.md)

Details

Definition
A monolith driven by imperative control flow rather than data dependencies, so stages cannot run or scale independently.

Referenced by
[Dataflow Architecture](https://banes-lab.com/records/arch/dataflow-architecture.md)

### Data Dependencies

- Kind: [constraint](https://banes-lab.com/records/kind/constraint.md)
- Category: [Streaming / Pipeline / Dataflow Processing](https://banes-lab.com/ontology/lexicon/lex-category-streaming-pipeline-dataflow-processing.md)
- Layer: [Execution Core](https://banes-lab.com/records/layer/execution-core.md)

Details

Definition
The requirement that the data each stage needs from others be declared as explicit dependencies.

Referenced by
[Dataflow Architecture](https://banes-lab.com/records/arch/dataflow-architecture.md)

### Debuggability/Resource Lifetime

- Kind: [quality-attribute](https://banes-lab.com/records/kind/quality-attribute.md)
- Category: [Streaming / Pipeline / Dataflow Processing](https://banes-lab.com/ontology/lexicon/lex-category-streaming-pipeline-dataflow-processing.md)
- Layer: [Execution Core](https://banes-lab.com/records/layer/execution-core.md)

Details

Definition
The degree to which deferring computation makes execution order harder to debug and resource lifetimes harder to reason about.

Referenced by
[Lazy Evaluation](https://banes-lab.com/records/arch/lazy-evaluation.md)

### Deferred Execution Semantics

- Kind: [constraint](https://banes-lab.com/records/kind/constraint.md)
- Category: [Streaming / Pipeline / Dataflow Processing](https://banes-lab.com/ontology/lexicon/lex-category-streaming-pipeline-dataflow-processing.md)
- Layer: [Execution Core](https://banes-lab.com/records/layer/execution-core.md)

Details

Definition
The requirement that a computation's semantics defer its work until the result is demanded.

Referenced by
[Lazy Evaluation](https://banes-lab.com/records/arch/lazy-evaluation.md)

### Eager Full Materialization

- Kind: [technique](https://banes-lab.com/records/kind/technique.md)
- Category: [Streaming / Pipeline / Dataflow Processing](https://banes-lab.com/ontology/lexicon/lex-category-streaming-pipeline-dataflow-processing.md)
- Layer: [Execution Core](https://banes-lab.com/records/layer/execution-core.md)

Details

Definition
Computing and materializing a complete result up front, rather than deferring computation until parts are needed.

Referenced by
[Lazy Evaluation](https://banes-lab.com/records/arch/lazy-evaluation.md)

### Error Propagation/Debugging

- Kind: [quality-attribute](https://banes-lab.com/records/kind/quality-attribute.md)
- Category: [Streaming / Pipeline / Dataflow Processing](https://banes-lab.com/ontology/lexicon/lex-category-streaming-pipeline-dataflow-processing.md)
- Layer: [Execution Core](https://banes-lab.com/records/layer/execution-core.md)

Details

Definition
The degree to which splitting work into pipeline stages makes an error harder to trace back to its origin.

Referenced by
[Pipeline Architecture](https://banes-lab.com/records/arch/pipeline-architecture.md)

### Event Time

- Kind: [artifact](https://banes-lab.com/records/kind/artifact.md)
- Category: [Streaming / Pipeline / Dataflow Processing](https://banes-lab.com/ontology/lexicon/lex-category-streaming-pipeline-dataflow-processing.md)
- Layer: [Execution Core](https://banes-lab.com/records/layer/execution-core.md)

Details

Definition
The time at which an event occurred, carried on the event and used to assign it to a window.

Referenced by
[Windowing](https://banes-lab.com/records/arch/windowing.md)

### Fitness for Purpose

- Kind: [quality-attribute](https://banes-lab.com/records/kind/quality-attribute.md)
- Category: [Streaming / Pipeline / Dataflow Processing](https://banes-lab.com/ontology/lexicon/lex-category-streaming-pipeline-dataflow-processing.md)
- Layer: [Execution Core](https://banes-lab.com/records/layer/execution-core.md)

Details

Definition
The degree to which the chosen processing model matches the latency and volume the problem needs.

Referenced by
[Batch-vs-Stream](https://banes-lab.com/records/arch/batch-vs-stream.md)

### Forward-Only State Model

- Kind: [constraint](https://banes-lab.com/records/kind/constraint.md)
- Category: [Streaming / Pipeline / Dataflow Processing](https://banes-lab.com/ontology/lexicon/lex-category-streaming-pipeline-dataflow-processing.md)
- Layer: [Execution Core](https://banes-lab.com/records/layer/execution-core.md)

Details

Definition
The requirement that processing keep only forward-moving state, never needing to revisit earlier input.

Referenced by
[Single-Pass Processing](https://banes-lab.com/records/arch/single-pass-processing.md)

### Global Optimization

- Kind: [quality-attribute](https://banes-lab.com/records/kind/quality-attribute.md)
- Category: [Streaming / Pipeline / Dataflow Processing](https://banes-lab.com/ontology/lexicon/lex-category-streaming-pipeline-dataflow-processing.md)
- Layer: [Execution Core](https://banes-lab.com/records/layer/execution-core.md)

Details

Definition
The degree to which processing data in a single pass forgoes optimizations that need a full view of the data.

Referenced by
[Single-Pass Processing](https://banes-lab.com/records/arch/single-pass-processing.md)

### Large Data Processing

- Kind: [capability](https://banes-lab.com/records/kind/capability.md)
- Category: [Streaming / Pipeline / Dataflow Processing](https://banes-lab.com/ontology/lexicon/lex-category-streaming-pipeline-dataflow-processing.md)
- Layer: [Execution Core](https://banes-lab.com/records/layer/execution-core.md)

Details

Definition
The ability to process datasets larger than memory by reading them in order, a piece at a time.

Referenced by
[Sequential Access](https://banes-lab.com/records/arch/sequential-access.md)

### Late-Data Handling

- Kind: [quality-attribute](https://banes-lab.com/records/kind/quality-attribute.md)
- Category: [Streaming / Pipeline / Dataflow Processing](https://banes-lab.com/ontology/lexicon/lex-category-streaming-pipeline-dataflow-processing.md)
- Layer: [Execution Core](https://banes-lab.com/records/layer/execution-core.md)

Details

Definition
The degree to which windowing by event time must reckon with events that arrive after their window has closed.

Referenced by
[Windowing](https://banes-lab.com/records/arch/windowing.md)

### Latency Requirement Clarity

- Kind: [constraint](https://banes-lab.com/records/kind/constraint.md)
- Category: [Streaming / Pipeline / Dataflow Processing](https://banes-lab.com/ontology/lexicon/lex-category-streaming-pipeline-dataflow-processing.md)
- Layer: [Execution Core](https://banes-lab.com/records/layer/execution-core.md)

Details

Definition
The requirement that a workload's latency and freshness needs be made explicit before a processing model is chosen.

Referenced by
[Batch-vs-Stream](https://banes-lab.com/records/arch/batch-vs-stream.md)

### Latency-Appropriate Processing Model

- Kind: [capability](https://banes-lab.com/records/kind/capability.md)
- Category: [Streaming / Pipeline / Dataflow Processing](https://banes-lab.com/ontology/lexicon/lex-category-streaming-pipeline-dataflow-processing.md)
- Layer: [Execution Core](https://banes-lab.com/records/layer/execution-core.md)

Details

Definition
The ability to choose batch or stream processing to match a workload's latency needs.

Referenced by
[Batch-vs-Stream](https://banes-lab.com/records/arch/batch-vs-stream.md)

### Lookup Performance

- Kind: [quality-attribute](https://banes-lab.com/records/kind/quality-attribute.md)
- Category: [Streaming / Pipeline / Dataflow Processing](https://banes-lab.com/ontology/lexicon/lex-category-streaming-pipeline-dataflow-processing.md)
- Layer: [Execution Core](https://banes-lab.com/records/layer/execution-core.md)

Details

Definition
The degree to which reading strictly in sequence makes locating a specific item by key slow.

Referenced by
[Sequential Access](https://banes-lab.com/records/arch/sequential-access.md)

### Monolithic Processing Function

- Kind: [anti-pattern](https://banes-lab.com/records/kind/anti-pattern.md)
- Category: [Streaming / Pipeline / Dataflow Processing](https://banes-lab.com/ontology/lexicon/lex-category-streaming-pipeline-dataflow-processing.md)
- Layer: [Execution Core](https://banes-lab.com/records/layer/execution-core.md)

Details

Definition
One large function that performs every processing step at once, so stages cannot be tested or reused independently.

Referenced by
[Pipeline Architecture](https://banes-lab.com/records/arch/pipeline-architecture.md)

### Multi-Pass Full Materialization

- Kind: [technique](https://banes-lab.com/records/kind/technique.md)
- Category: [Streaming / Pipeline / Dataflow Processing](https://banes-lab.com/ontology/lexicon/lex-category-streaming-pipeline-dataflow-processing.md)
- Layer: [Execution Core](https://banes-lab.com/records/layer/execution-core.md)

Details

Definition
Loading a full dataset into memory and traversing it in multiple passes, rather than in a single streaming pass.

Referenced by
[Single-Pass Processing](https://banes-lab.com/records/arch/single-pass-processing.md)

### No Backtracking Requirement

- Kind: [constraint](https://banes-lab.com/records/kind/constraint.md)
- Category: [Streaming / Pipeline / Dataflow Processing](https://banes-lab.com/ontology/lexicon/lex-category-streaming-pipeline-dataflow-processing.md)
- Layer: [Execution Core](https://banes-lab.com/records/layer/execution-core.md)

Details

Definition
The requirement that processing never need to revisit earlier input to make a decision.

Referenced by
[Forward-Only Processing](https://banes-lab.com/records/arch/forward-only-processing.md)

### No Hidden State

- Kind: [constraint](https://banes-lab.com/records/kind/constraint.md)
- Category: [Streaming / Pipeline / Dataflow Processing](https://banes-lab.com/ontology/lexicon/lex-category-streaming-pipeline-dataflow-processing.md)
- Layer: [Execution Core](https://banes-lab.com/records/layer/execution-core.md)

Details

Definition
The requirement that a processor keep no state hidden between invocations, taking all inputs explicitly.

Referenced by
[Stateless Processing](https://banes-lab.com/records/arch/stateless-processing.md)

### One-Size-Fits-All Processing

- Kind: [anti-pattern](https://banes-lab.com/records/kind/anti-pattern.md)
- Category: [Streaming / Pipeline / Dataflow Processing](https://banes-lab.com/ontology/lexicon/lex-category-streaming-pipeline-dataflow-processing.md)
- Layer: [Execution Core](https://banes-lab.com/records/layer/execution-core.md)

Details

Definition
Forcing every workload through a single processing model regardless of its latency or volume needs.

Referenced by
[Batch-vs-Stream](https://banes-lab.com/records/arch/batch-vs-stream.md)

### Operational Duplication

- Kind: [quality-attribute](https://banes-lab.com/records/kind/quality-attribute.md)
- Category: [Streaming / Pipeline / Dataflow Processing](https://banes-lab.com/ontology/lexicon/lex-category-streaming-pipeline-dataflow-processing.md)
- Layer: [Execution Core](https://banes-lab.com/records/layer/execution-core.md)

Details

Definition
The degree to which supporting both batch and streaming paths duplicates operational effort and code.

Referenced by
[Batch-vs-Stream](https://banes-lab.com/records/arch/batch-vs-stream.md)

### Ordered Read Model

- Kind: [constraint](https://banes-lab.com/records/kind/constraint.md)
- Category: [Streaming / Pipeline / Dataflow Processing](https://banes-lab.com/ontology/lexicon/lex-category-streaming-pipeline-dataflow-processing.md)
- Layer: [Execution Core](https://banes-lab.com/records/layer/execution-core.md)

Details

Definition
The requirement that data be read in a fixed forward order rather than by arbitrary index.

Referenced by
[Sequential Access](https://banes-lab.com/records/arch/sequential-access.md)

### Ordering/State

- Kind: [quality-attribute](https://banes-lab.com/records/kind/quality-attribute.md)
- Category: [Streaming / Pipeline / Dataflow Processing](https://banes-lab.com/ontology/lexicon/lex-category-streaming-pipeline-dataflow-processing.md)
- Layer: [Execution Core](https://banes-lab.com/records/layer/execution-core.md)

Details

Definition
The degree to which processing an unbounded stream complicates preserving event order and bounded state.

Referenced by
[Streaming Architecture](https://banes-lab.com/records/arch/streaming-architecture.md)

### Parallel Branch Processing

- Kind: [capability](https://banes-lab.com/records/kind/capability.md)
- Category: [Streaming / Pipeline / Dataflow Processing](https://banes-lab.com/ontology/lexicon/lex-category-streaming-pipeline-dataflow-processing.md)
- Layer: [Execution Core](https://banes-lab.com/records/layer/execution-core.md)

Details

Definition
The ability to process independent branches of work simultaneously across workers.

Referenced by
[Fan-out/Fan-in](https://banes-lab.com/records/arch/fan-out-fan-in.md)

### Parallel Processing

- Kind: [capability](https://banes-lab.com/records/kind/capability.md)
- Category: [Streaming / Pipeline / Dataflow Processing](https://banes-lab.com/ontology/lexicon/lex-category-streaming-pipeline-dataflow-processing.md)
- Layer: [Execution Core](https://banes-lab.com/records/layer/execution-core.md)

Details

Definition
The ability to process many records at once because each is handled independently of the others.

Referenced by
[Stateless Processing](https://banes-lab.com/records/arch/stateless-processing.md)

### Parallel/Stream Processing

- Kind: [capability](https://banes-lab.com/records/kind/capability.md)
- Category: [Streaming / Pipeline / Dataflow Processing](https://banes-lab.com/ontology/lexicon/lex-category-streaming-pipeline-dataflow-processing.md)
- Layer: [Execution Core](https://banes-lab.com/records/layer/execution-core.md)

Details

Definition
The ability to run independent stages in parallel or stream data between them as it is produced.

Referenced by
[Dataflow Architecture](https://banes-lab.com/records/arch/dataflow-architecture.md)

### Random Access Requirement

- Kind: [constraint](https://banes-lab.com/records/kind/constraint.md)
- Category: [Streaming / Pipeline / Dataflow Processing](https://banes-lab.com/ontology/lexicon/lex-category-streaming-pipeline-dataflow-processing.md)
- Layer: [Execution Core](https://banes-lab.com/records/layer/execution-core.md)

Details

Definition
A need to read arbitrary items by position or key on demand rather than strictly in sequence.

Referenced by
[Sequential Access](https://banes-lab.com/records/arch/sequential-access.md)

### Result Aggregation

- Kind: [capability](https://banes-lab.com/records/kind/capability.md)
- Category: [Streaming / Pipeline / Dataflow Processing](https://banes-lab.com/ontology/lexicon/lex-category-streaming-pipeline-dataflow-processing.md)
- Layer: [Execution Core](https://banes-lab.com/records/layer/execution-core.md)

Details

Definition
The ability to combine the outputs of parallel branches back into a single result.

Referenced by
[Fan-out/Fan-in](https://banes-lab.com/records/arch/fan-out-fan-in.md)

### Serial Item Processing

- Kind: [approach](https://banes-lab.com/records/kind/approach.md)
- Category: [Streaming / Pipeline / Dataflow Processing](https://banes-lab.com/ontology/lexicon/lex-category-streaming-pipeline-dataflow-processing.md)
- Layer: [Execution Core](https://banes-lab.com/records/layer/execution-core.md)

Details

Definition
Processing independent items one at a time in sequence, rather than in parallel.

Referenced by
[Fan-out/Fan-in](https://banes-lab.com/records/arch/fan-out-fan-in.md)

### Stage Contracts

- Kind: [constraint](https://banes-lab.com/records/kind/constraint.md)
- Category: [Streaming / Pipeline / Dataflow Processing](https://banes-lab.com/ontology/lexicon/lex-category-streaming-pipeline-dataflow-processing.md)
- Layer: [Execution Core](https://banes-lab.com/records/layer/execution-core.md)

Details

Definition
The requirement that each pipeline stage declare a typed contract for what it consumes and produces.

Referenced by
[Pipeline Architecture](https://banes-lab.com/records/arch/pipeline-architecture.md)

### Stages

- Kind: [constraint](https://banes-lab.com/records/kind/constraint.md)
- Category: [Streaming / Pipeline / Dataflow Processing](https://banes-lab.com/ontology/lexicon/lex-category-streaming-pipeline-dataflow-processing.md)
- Layer: [Execution Core](https://banes-lab.com/records/layer/execution-core.md)

Details

Definition
The requirement that processing be decomposed into discrete stages connected by data flow.

Referenced by
[Dataflow Architecture](https://banes-lab.com/records/arch/dataflow-architecture.md)

### State Coordination

- Kind: [quality-attribute](https://banes-lab.com/records/kind/quality-attribute.md)
- Category: [Streaming / Pipeline / Dataflow Processing](https://banes-lab.com/ontology/lexicon/lex-category-streaming-pipeline-dataflow-processing.md)
- Layer: [Execution Core](https://banes-lab.com/records/layer/execution-core.md)

Details

Definition
The degree to which a data-driven design must still coordinate shared state across concurrent stages.

Referenced by
[Dataflow Architecture](https://banes-lab.com/records/arch/dataflow-architecture.md)

### Stateful Business Rules

- Kind: [quality-attribute](https://banes-lab.com/records/kind/quality-attribute.md)
- Category: [Streaming / Pipeline / Dataflow Processing](https://banes-lab.com/ontology/lexicon/lex-category-streaming-pipeline-dataflow-processing.md)
- Layer: [Execution Core](https://banes-lab.com/records/layer/execution-core.md)

Details

Definition
The degree to which rules that inherently depend on accumulated state resist a purely stateless design.

Referenced by
[Stateless Processing](https://banes-lab.com/records/arch/stateless-processing.md)

### Stateful Hidden Accumulation

- Kind: [anti-pattern](https://banes-lab.com/records/kind/anti-pattern.md)
- Category: [Streaming / Pipeline / Dataflow Processing](https://banes-lab.com/ontology/lexicon/lex-category-streaming-pipeline-dataflow-processing.md)
- Layer: [Execution Core](https://banes-lab.com/records/layer/execution-core.md)

Details

Definition
Accumulating state inside a processor across records, so results depend on invisible history.

Referenced by
[Stateless Processing](https://banes-lab.com/records/arch/stateless-processing.md)

### Stepwise Transformation

- Kind: [capability](https://banes-lab.com/records/kind/capability.md)
- Category: [Streaming / Pipeline / Dataflow Processing](https://banes-lab.com/ontology/lexicon/lex-category-streaming-pipeline-dataflow-processing.md)
- Layer: [Execution Core](https://banes-lab.com/records/layer/execution-core.md)

Details

Definition
The ability to transform data through a sequence of small, composable stages.

Referenced by
[Pipeline Architecture](https://banes-lab.com/records/arch/pipeline-architecture.md)

### Streaming

- Kind: [capability](https://banes-lab.com/records/kind/capability.md)
- Category: [Streaming / Pipeline / Dataflow Processing](https://banes-lab.com/ontology/lexicon/lex-category-streaming-pipeline-dataflow-processing.md)
- Layer: [Execution Core](https://banes-lab.com/records/layer/execution-core.md)

Details

Definition
The ability to process data continuously as it arrives rather than in complete batches.

Referenced by
[Pipeline Architecture](https://banes-lab.com/records/arch/pipeline-architecture.md)

### Streaming Parsers

- Kind: [capability](https://banes-lab.com/records/kind/capability.md)
- Category: [Streaming / Pipeline / Dataflow Processing](https://banes-lab.com/ontology/lexicon/lex-category-streaming-pipeline-dataflow-processing.md)
- Layer: [Execution Core](https://banes-lab.com/records/layer/execution-core.md)

Details

Definition
The ability to parse input incrementally as it streams in, without buffering the whole document.

Referenced by
[Forward-Only Processing](https://banes-lab.com/records/arch/forward-only-processing.md)

### Unbounded Accumulation

- Kind: [anti-pattern](https://banes-lab.com/records/kind/anti-pattern.md)
- Category: [Streaming / Pipeline / Dataflow Processing](https://banes-lab.com/ontology/lexicon/lex-category-streaming-pipeline-dataflow-processing.md)
- Layer: [Execution Core](https://banes-lab.com/records/layer/execution-core.md)

Details

Definition
Aggregating an endless stream into ever-growing state that eventually exhausts memory.

Referenced by
[Windowing](https://banes-lab.com/records/arch/windowing.md)

## Links to

- [capability](https://banes-lab.com/records/kind/capability.md)
- [Execution Core](https://banes-lab.com/records/layer/execution-core.md)
- [Lazy Evaluation](https://banes-lab.com/records/arch/lazy-evaluation.md)
- [technique](https://banes-lab.com/records/kind/technique.md)
- [Forward-Only Processing](https://banes-lab.com/records/arch/forward-only-processing.md)
- [approach](https://banes-lab.com/records/kind/approach.md)
- [Streaming Architecture](https://banes-lab.com/records/arch/streaming-architecture.md)
- [Windowing](https://banes-lab.com/records/arch/windowing.md)
- [quality-attribute](https://banes-lab.com/records/kind/quality-attribute.md)
- [anti-pattern](https://banes-lab.com/records/kind/anti-pattern.md)
- [Dataflow Architecture](https://banes-lab.com/records/arch/dataflow-architecture.md)
- [constraint](https://banes-lab.com/records/kind/constraint.md)
- [Pipeline Architecture](https://banes-lab.com/records/arch/pipeline-architecture.md)
- [artifact](https://banes-lab.com/records/kind/artifact.md)
- [Batch-vs-Stream](https://banes-lab.com/records/arch/batch-vs-stream.md)
- [Single-Pass Processing](https://banes-lab.com/records/arch/single-pass-processing.md)
- [Sequential Access](https://banes-lab.com/records/arch/sequential-access.md)
- [Stateless Processing](https://banes-lab.com/records/arch/stateless-processing.md)
- [Fan-out/Fan-in](https://banes-lab.com/records/arch/fan-out-fan-in.md)
