Details
-
Improvement
-
Status: Open
-
Major
-
Resolution: Unresolved
-
None
-
None
Description
Currently, flume ships with a flume.avdl that has a reference implementation of a AvroSource / AvroSink , to deal with the default flume transports ( Event / Channel - s) .
We need to customize the avro schema that goes in, for our purposes - but would still like to reuse a majority of code of AvroSource / AvroSink that does the marshalling/ unmarshalling.