PubSubIO.readAvros should produce a schema'd PCollection if clazz has a schema
- 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
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