Uploaded image for project: 'Flume'
  1. Flume
  2. FLUME-918

customizable avro source/sink events

    Details

    • Type: Improvement
    • Status: Open
    • Priority: Major
    • Resolution: Unresolved
    • Affects Version/s: None
    • Fix Version/s: None
    • Component/s: Sinks+Sources

      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.

        Attachments

          Activity

            People

            • Assignee:
              kaykay.unique Karthik K
              Reporter:
              kaykay.unique Karthik K
            • Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

              • Created:
                Updated: