apache / apache/beam

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

Ouverte
#19,829 0 commentaires 0 réactions 0 personnes assignées Voir sur GitHub
gcp improvement io java P3
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

Recevez les nouvelles issues par e-mail

Un résumé court des issues GitHub adaptées aux débutants.