You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flume.apache.org by es...@apache.org on 2011/08/19 20:10:28 UTC

svn commit: r1159722 - in /incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/formatter: ./ output/ output/TextDelimitedOutputFormatter.java

Author: esammer
Date: Fri Aug 19 18:10:27 2011
New Revision: 1159722

URL: http://svn.apache.org/viewvc?rev=1159722&view=rev
Log:
- Added an output formatter to stringify Events. Temporary. This will
  become an interface for all Event -> byte[] formatters (i.e. serializers).

Added:
    incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/formatter/
    incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/formatter/output/
    incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/formatter/output/TextDelimitedOutputFormatter.java

Added: incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/formatter/output/TextDelimitedOutputFormatter.java
URL: http://svn.apache.org/viewvc/incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/formatter/output/TextDelimitedOutputFormatter.java?rev=1159722&view=auto
==============================================================================
--- incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/formatter/output/TextDelimitedOutputFormatter.java (added)
+++ incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/formatter/output/TextDelimitedOutputFormatter.java Fri Aug 19 18:10:27 2011
@@ -0,0 +1,11 @@
+package org.apache.flume.formatter.output;
+
+import org.apache.flume.Event;
+
+public class TextDelimitedOutputFormatter {
+
+  public byte[] format(Event event) {
+    return (new String(event.getBody()) + "\n").getBytes();
+  }
+
+}