apache / apache/beam

Retractions

Open
#17,982 0 comments 0 reactions 0 assignees View on GitHub
beam-model new feature P3
Dominant language
Java
Stars
8.7k
Forks
4.7k
Avg merge
1d 20h
Merged PRs (30d)
196

Description

We still haven't added retractions to Beam, even though they're a core part of the model. We should document all the necessary aspects (uncombine, reverting DoFn output with DoOvers, sink integration, source-level retractions, etc), and then implement them.

Imported from Jira [BEAM-91](https://issues.apache.org/jira/browse/BEAM-91). Original Jira may contain additional context.
Reported by: takidau.

Contributor guide

Open the contributing guide

Research direction

The issue names no files or tests. Start by defining the required retraction behavior for uncombine, reverting DoFn output with DoOvers, sink integration, and source-level retractions; done means those aspects are documented and implemented across Beam.

Written by the indexing model from the issue text.

Assessment

Domain
data-engineering, stream-processing
Issue type
Feature
Difficulty
5/5
Estimated time
Over a week
Activity status
Stale
Clarity
Needs clarification
Newbie friendliness
20/100

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.