Add timestamp header to Flume source

cloudera · Aug 31, 2012 · 1c2dbf1 · 1c2dbf1
1 parent b7f2a3d
commit 1c2dbf1
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/flume-sources/src/main/java/com/cloudera/flume/source/TwitterSource.java b/flume-sources/src/main/java/com/cloudera/flume/source/TwitterSource.java
@@ -105,6 +105,7 @@ public void start() {
       public void onStatus(Status status) {
         // The EventBuilder is used to build an event using the headers and
         // the raw JSON of a tweet
+        headers.put("timestamp", String.valueOf(System.currentTimeMillis()));
         eventList.add(EventBuilder.withBody(
             DataObjectFactory.getRawJSON(status).getBytes(), headers));