Flume: Customize sink for receiving log on predictionio

[Kim Trang Le]

Dear all,

I am trying to config Flume sink for receiving log on PredictionIO event server. My web source have a log file and I would like to transfer part of the log to PredictionIO event server. My question is which type of source and sink I can use in my case. Do I need to customize sink. Below is the link list all types of source and sink available for using flume.

http://www.cloudera.com/documentation/archive/cdh/4-x/4-7-1/CDH4-Installation-Guide/cdh4ig_topic_12_9.html#topic_12_9

Thank you very much.