PubSubIO.readAvros should produce a schema'd PCollection if clazz has a schema
- Lingua principale
- Java
- Stelle
- 8.7k
- Fork
- 4.7k
- Merge medio
- 2g 2h
- PR unite (30g)
- 205
Descrizione
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.
Guida per i contributori
Apri la guida per i contributori
Direzione di ricerca
Inizia dal punto di ingresso Java PubsubIO.readAvros(clazz) e verifica come viene selezionato il relativo coder. Controlla i test PubSubIO esistenti per individuare assertions su coder o schema. Il lavoro è completato quando una classe con uno schema inferibile produce una schema-backed PCollection, mentre AvroCoder rimane il fallback quando non è possibile inferire alcun coder.
Scritto dal modello di indicizzazione a partire dal testo della issue.
Valutazione
- Stack tecnologico
- java
- Ambito
- api
- Tipo di issue
- Funzionalità
- Difficoltà
- 3/5
- Tempo stimato
- 1-2 giorni
- Stato di attività
- Ferma
- Chiarezza
- Abbastanza chiara
- Idoneità per principianti
- 45/100