Flume
  1. Flume
  2. FLUME-918

customizable avro source/sink events

    Details

    • Type: Improvement Improvement
    • Status: Open
    • Priority: Major Major
    • Resolution: Unresolved
    • Affects Version/s: None
    • Fix Version/s: None
    • Component/s: Sinks+Sources
    • Labels:
      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.

        Activity

          People

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

            Dates

            • Created:
              Updated:

              Development