PubSubIO.readAvros should produce a schema'd PCollection if clazz has a schema
- Langage dominant
- Java
- Étoiles
- 8.7k
- Forks
- 4.7k
- Merge moyen
- 2 j 9 h
- PR mergées (30 j)
- 202
Description
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.
Guide de contribution
Ouvrir le guide de contribution
Piste de recherche
Commencez au point d’entrée Java PubsubIO.readAvros(clazz) et examinez comment son coder est sélectionné. Vérifiez dans les tests PubSubIO existants les assertions concernant le coder ou le schema. C’est terminé lorsqu’une classe avec un schema inférable produit une schema-backed PCollection, tandis que AvroCoder reste le fallback lorsqu’aucun coder ne peut être inféré.
Rédigé par le modèle d'indexation à partir du texte de l'issue.
Évaluation
- Stack technique
- java
- Domaine
- api
- Type d'issue
- Fonctionnalité
- Difficulté
- 3/5
- Temps estimé
- 1-2 jours
- Activité
- À l'abandon
- Clarté
- Plutôt claire
- Accessibilité débutants
- 45/100