apache / apache/beam

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

Aperta
#19,829 0 commenti 0 reazioni 0 assegnatari Vedi su GitHub
gcp improvement io java P3
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

Ricevi le nuove issue nella tua casella

Un breve riepilogo di issue GitHub adatte ai principianti.