titus.genpy.FastAvroCorrector¶

class titus.genpy.FastAvroCorrector(inputStream, avroType)[source]¶

Bases: object

The fastavro library reads Avro strings as non-Unicode and doesn’t tag unions. This wrapper class corrects it.

__init__(inputStream, avroType)¶

correctFastAvro(x, avroType)¶

next()¶