apache / apache/beam

PubSubIO.readAvros should produce a schema'd PCollection if clazz has a schema

Offen
#19,829 0 Kommentare 0 Reaktionen 0 zugewiesene Personen Auf GitHub ansehen
gcp improvement io java P3
Vorherrschende Sprache
Java
Sterne
8.7k
Forks
4.7k
Ø Merge
2 T. 2 Std.
Gemergte PRs (30 T.)
205

Beschreibung

Currently `PubsubIO.readAvros(clazz)` *always* yields a PCollection with an AvroCoder. This should only be a fallback in the event that no coder can be inferred. That way if we can infer a schema for `clazz` we will produce a PCollection with a schema.

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

Beitragsleitfaden

Beitragsleitfaden öffnen

Rechercherichtung

Beginne beim Java-Einstiegspunkt PubsubIO.readAvros(clazz) und prüfe, wie sein coder ausgewählt wird. Prüfe bestehende PubSubIO-Tests auf coder- oder schema-bezogene Assertions. Als erledigt gilt die Aufgabe, wenn eine Klasse mit inferierbarem schema eine schema-backed PCollection erzeugt, während AvroCoder der Fallback bleibt, wenn kein coder inferiert werden kann.

Vom Indexierungsmodell aus dem Issue-Text verfasst.

Bewertung

Tech-Stack
java
Bereich
api
Issue-Typ
Feature
Schwierigkeit
3/5
Geschätzter Aufwand
1-2 Tage
Aktivitätsstatus
Veraltet
Klarheit
Größtenteils klar
Anfängerfreundlichkeit
45/100

Neue Issues direkt in Ihr Postfach

Eine kurze Übersicht über anfängerfreundliche GitHub-Issues.