apache/beam

Auf GitHub ansehen

Apache Beam is a unified programming model for Batch and Streaming data processing.

Sterne: 8.7k
Forks: 4.7k
Offene Anfänger-Issues: 0
Indexierte Issues: 3.8k
Ø Merge: 2 T. 5 Std.
Gemergte PRs (30 T.): 204

Vorherrschende Sprache: Java
Lizenz: Apache-2.0
Letzter GitHub-Push: 14.9.2026
Zuletzt indexiert: 14.9.2026
Beitragsleitfaden: Beitragsleitfaden
Verhaltenskodex: Verhaltenskodex
Anfänger-Labels: good first issue

Offen Alle

Bisher 3810 offene Issues indexiert

Make Spark RDDs readable as PCollections Offen

new feature P3 runners spark

apache/beam#17957 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 14.9.2026
DatastoreIO: upgrade error handling Offen

gcp io java new feature P3

apache/beam#17959 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 14.9.2026
Implement a CSV file reader Offen

ideas io new feature P3

apache/beam#17960 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 14.9.2026
In TriggerRunner, avoid reading the set of finished subtriggers when no subtrigger ever finishes. Offen

core improvement P3 runners

apache/beam#17961 · 2 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 14.9.2026
Support Google Cloud Storage encryption keys Offen

gcp io java new feature P3

apache/beam#17962 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 14.9.2026
Support for limiting parallelism of a step Offen

beam-model new feature P3

apache/beam#17963 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 14.9.2026
Support side inputs for Sessions Offen

beam-model new feature P3

apache/beam#17964 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 14.9.2026
When triggers are changed via pipeline update, stale finished triggers data applied Offen

bug dataflow P3 runners

apache/beam#17965 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 14.9.2026
Model for validation of user state upon pipeline update Offen

dataflow new feature P3 runners

apache/beam#17966 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 14.9.2026
Merging of watermark holds depends on runner-specific "take the minimum" behavior Offen

bug core P3 runners

apache/beam#17967 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 14.9.2026
Add SocketStream IO Offen

ideas io new feature P3

apache/beam#17968 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 14.9.2026
Add declarative DSLs (XML & JSON) Offen

new feature P3 sdk-ideas

apache/beam#17969 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 14.9.2026
Create OSGi/Karaf runner Offen

ideas new feature P3 runners

apache/beam#17970 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 14.9.2026
Storm Runner Offen

ideas P3 runners wish

apache/beam#17971 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 14.9.2026
Running tests of dynamic work rebalancing Offen

core java new feature P3

apache/beam#17972 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 14.9.2026
Testing harness for Unbounded Sources Offen

core java new feature P3

apache/beam#17973 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 14.9.2026
DataflowPipelineJob should have an API that prints messages but doesn't wait for completion Offen

core improvement java P3

apache/beam#17974 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 14.9.2026
Source design pattern: option to retain metadata Offen

core java new feature P3

apache/beam#17975 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 14.9.2026
General decompression registry Offen

core java new feature P3

apache/beam#17976 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 14.9.2026
Bound Instant values used as timestamps at TIMESTAMP_MIN_VALUE and TIMESTAMP_MAX_VALUE Offen

bug core java P3

apache/beam#17977 · 1 Kommentar · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 14.9.2026
FileBasedSource/IOChannelFactory: Custom glob expansion Offen

core java new feature P3

apache/beam#17978 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 14.9.2026
Native support for conditional iteration Offen

new feature P3 sdk-ideas

apache/beam#17979 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 14.9.2026
Data-dependent sinks Offen

core java new feature P3

apache/beam#17980 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 14.9.2026
Data-driven triggers Offen

beam-model new feature P3

apache/beam#17981 · 0 Kommentare · 4 Reaktionen · 0 zugewiesene Personen · Indexiert am 14.9.2026
Retractions Offen

beam-model new feature P3

apache/beam#17982 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 14.9.2026
ProtoIO Offen

gcp good first issue io java new feature P3

apache/beam#17983 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 14.9.2026
Add 'garbage collection' hold when receive late element Offen

bug core P3 runners

apache/beam#17984 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 14.9.2026
Provide Beam turnkey binary distributions embedding runners and execution runtime Offen

build P3 wish

apache/beam#17985 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 14.9.2026
BigQueryIO.Read should give good error message for views and federated tables Offen

bug gcp io java P3

apache/beam#17986 · 2 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 14.9.2026
Version annotations in capability matrix Offen

P3 project-management website wish

apache/beam#17987 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 14.9.2026
Don't leak garbage collection timers in GlobalWindow Offen

bug core P3 runners

apache/beam#17988 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 14.9.2026
Integrate code coverage to build and review process Offen

core improvement java P3

apache/beam#17989 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 14.9.2026
Add Hadoop MapReduce runner Offen

ideas mapreduce new feature P3 runners

apache/beam#17991 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 14.9.2026
IOChannelUtils.getFactory should throw an unchecked exception rather than IOException Offen

bug core java P3

apache/beam#17992 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 14.9.2026
Improve TypeDescriptor inference of DoFn's created inside a generic PTransform Offen

core java P3 wish

apache/beam#17993 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 14.9.2026
Add implicit conf/pipeline-default.conf options file Offen

core java new feature P3

apache/beam#17994 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 14.9.2026
Using Merging Windows and/or Triggers without a downstream aggregation should fail Offen

backward-incompatible bug core java P3

apache/beam#17995 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 14.9.2026
Need serialized form and serialVersionUID for user-facing superclasses Offen

bug core java P3

apache/beam#17996 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 14.9.2026
Matcher(s) for TableRow Offen

core good first issue java new feature P3

apache/beam#17997 · 1 Kommentar · 0 Reaktionen · 1 zugewiesene Person · Indexiert am 14.9.2026
Make TextIOTest and AvroIOTest runner-agnostic Offen

bug core java P3

apache/beam#17998 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 14.9.2026
Make sure we unit test bounded sessions Offen

bug core java P3

apache/beam#17999 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 14.9.2026
Incremental join Offen

beam-model bug P3

apache/beam#18001 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 14.9.2026
Should use allowedLateness from downstream computations in ReduceFnRunner Offen

core P3 runners wish

apache/beam#18002 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 14.9.2026
Visual Pipeline Designers / Editors Offen

new feature P3 sdk-ideas

apache/beam#18003 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 14.9.2026
Add Scio Scala DSL to Beam Offen

P3 sdk-ideas wish

apache/beam#18004 · 0 Kommentare · 1 Reaktion · 0 zugewiesene Personen · Indexiert am 14.9.2026
Retry failures in the DirectRunner Offen

direct good first issue improvement P3 runners

apache/beam#18005 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 14.9.2026
Add Machine Learning DSL and dedicated functions Offen

P3 sdk-ideas wish

apache/beam#18006 · 1 Kommentar · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 14.9.2026
Create Vector, Matrix types and operations to enable linear algebra API Offen

P3 sdk-ideas sub-task

apache/beam#18007 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 14.9.2026
Need an UnboundedSourceFromHell to test runner's respect of its implied contract Offen

bug P3 tests

apache/beam#18008 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 14.9.2026
DirectRunner RunnableOnService tempLocation configuration insufficient Offen

bug direct P3 runners

apache/beam#18010 · 0 Kommentare · 0 Reaktionen · 0 zugewiesene Personen · Indexiert am 14.9.2026

apache/beam

Neue Issues direkt in Ihr Postfach