apache / apache/beam

Port game example in Beam repo to use InjectorUnboundedSource

Open
#18,258 0 comments 0 reactions 0 assignees View on GitHub
examples improvement java P3
Dominant language
Java
Stars
8.7k
Forks
4.7k
Avg merge
1d 20h
Merged PRs (30d)
196

Description

We developed an UnboundedSource so users didn't have to run a separate injector, but it isn't in the Beam example. We should put it there, which eliminates a big chunk of complexity.

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

Contributor guide

Open the contributing guide

Research direction

Start by locating the Beam game example and its current injector setup, then inspect InjectorUnboundedSource and the additional context in Jira BEAM-1785. Done means the example uses InjectorUnboundedSource directly and no longer requires a separate injector, while preserving the example's behavior.

Written by the indexing model from the issue text.

Assessment

Tech stack
java
Domain
stream-processing
Issue type
Refactor
Difficulty
3/5
Estimated time
1-2 days
Activity status
Stale
Clarity
Mostly clear
Newbie friendliness
45/100

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.