Return-Path: X-Original-To: apmail-flume-user-archive@www.apache.org Delivered-To: apmail-flume-user-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 4C6C498D2 for ; Wed, 22 Aug 2012 00:53:01 +0000 (UTC) Received: (qmail 3014 invoked by uid 500); 22 Aug 2012 00:53:01 -0000 Delivered-To: apmail-flume-user-archive@flume.apache.org Received: (qmail 2965 invoked by uid 500); 22 Aug 2012 00:53:01 -0000 Mailing-List: contact user-help@flume.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@flume.apache.org Delivered-To: mailing list user@flume.apache.org Received: (qmail 2955 invoked by uid 99); 22 Aug 2012 00:53:01 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 22 Aug 2012 00:53:01 +0000 X-ASF-Spam-Status: No, hits=1.5 required=5.0 tests=HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: domain of mohitanchlia@gmail.com designates 209.85.213.179 as permitted sender) Received: from [209.85.213.179] (HELO mail-yx0-f179.google.com) (209.85.213.179) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 22 Aug 2012 00:52:54 +0000 Received: by yenq7 with SMTP id q7so355463yen.38 for ; Tue, 21 Aug 2012 17:52:33 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:date:message-id:subject:from:to:content-type; bh=FuCKz4BxvfzqLfUrelZoRtRfg4ZtSOJBIv6EcbshJ9M=; b=c1fDEhRvBpgkh71ZjGdmF/WplBhkvzoPe8tC8CJ/mI18EgJ2WLWhlHHlJlE4YWcs5v U9j2ZHGj8J1dkviblxpEWnit/gLD5xLMNrREGqkEMTOvgiZFThPEwW2ITYBoV7hmrkdh QmXZ2H6Cvy+3JBrN5tiKcEDPwZZi7XvQE7Np4waMaYH2Msuc6Lhbc/+72cacYAvPprAX UBAFxppqu1IafUfJl1LwvBC4X3taccXw9QxETvdPsIc1RQXej36ElkaSr2ia4zaiKtc3 y/SezjQJ7yhn2UddXPOmsFA+feIuxlWfEAGFnPuF3Wn9OnY/TpEEBVTSfUjFq2N3SF0N oBOw== MIME-Version: 1.0 Received: by 10.50.88.229 with SMTP id bj5mr395638igb.21.1345596752930; Tue, 21 Aug 2012 17:52:32 -0700 (PDT) Received: by 10.64.39.12 with HTTP; Tue, 21 Aug 2012 17:52:32 -0700 (PDT) Date: Tue, 21 Aug 2012 17:52:32 -0700 Message-ID: Subject: HDFS escape sequence and use of timestamp header From: Mohit Anchlia To: user@flume.apache.org Content-Type: multipart/alternative; boundary=e89a8f2352ad78285504c7d028dc X-Virus-Checked: Checked by ClamAV on apache.org --e89a8f2352ad78285504c7d028dc Content-Type: text/plain; charset=ISO-8859-1 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 headers = *new* HashMap(); headers.put("host", *hostName*); event.setHeaders(headers); *try* { rpcClient.append(event); } *catch* (EventDeliveryException e) { connect(); } } --e89a8f2352ad78285504c7d028dc Content-Type: text/html; charset=ISO-8859-1 Content-Transfer-Encoding: quoted-printable
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 e= xample? Currently my AvroClient looks like this:
=A0

public void sendDataToFlume(String data= ) {

// Create flume event object

Event event =3D EventBuilder.withBody(data, Charse= t.forName(

"UTF-8"));

Map<String,String> headers =3D

new HashM= ap<String,String>();

headers.put(

"host", hostName);

event.setHeaders(headers);

try {

rpcClient.append(event);

}

catch (EventDeliveryException e) {

connect();

}

}

--e89a8f2352ad78285504c7d028dc--