Database Reference
In-Depth Information
priate. It allows you to log an Avro Generic, Specific, or Reflect object using a log4j
Logger and send it to an Avro source running in a Flume agent (see Distribution: Agent
Tiers ) . In this case, the serializer property for the HDFS sink should be set to
org.apache.flume.sink.hdfs.AvroEventSerializer$Builder , and the
Avro schema set in the header (see the class documentation).
Alternatively, if the events are not originally derived from Avro objects, you can write a
custom serializer to convert a Flume event into an Avro object with a custom schema. The
helper class AbstractAvroEventSerializer in the
org.apache.flume.serialization package is a good starting point.
Search WWH ::




Custom Search