Support for stream processing variable length records
Ouverte
question
- Langage dominant
- Scala
- Étoiles
- 170
- Forks
- 96
- Merge moyen
- 57 min
- PR mergées (30 j)
- 2
Description
@yruslan
I have large set of input files for processing. I wanted to take the stream processing approach. But, when i tried with the same options that i have successfully used for variable length records, like,
`
.option("generate_record_id", true)
.option("is_record_sequence", "true")
.option("is_rdw_big_endian", "true")
.option("variable_size_occurs", "true")
`
It was getting processed as FixedLength records.
Any thoughts or suggestions?
Guide de contribution
Aucun guide de contribution indexé pour ce dépôt
Évaluation
Cette issue n'a pas encore été évaluée.