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
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.