Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Threaded View
Flume, mail # user - HDFS escape sequence and use of timestamp header


Copy link to this message
-
HDFS escape sequence and use of timestamp header
Mohit Anchlia 2012-08-22, 00:52
I am using flume-ng 1.2.0 and I need to use %Y%M%D escape sequence. Do I
need to write some custom interceptor? Could you please point me to an
example? Currently my AvroClient looks like this:
*public* *void* sendDataToFlume(String data) {

// Create *flume* event object

Event event = EventBuilder.*withBody*(data, Charset.*forName*("UTF-8"));

Map<String,String> headers = *new* HashMap<String,String>();

headers.put("host", *hostName*);

event.setHeaders(headers);

*try* {

rpcClient.append(event);

} *catch* (EventDeliveryException e) {

connect();

}

}