package com.cloudera.flume.handlers.text.output;
import java.io.IOException;
import java.io.OutputStream;
import com.cloudera.flume.core.Event;
import com.cloudera.flume.handlers.text.FormatFactory.OutputFormatBuilder;
import com.google.common.base.Preconditions;
private static final String NAME = "debug";
@Override
public void format(OutputStream o, Event e)
throws IOException {
o.write((e.toString() + "\n").getBytes());
}
public static OutputFormatBuilder
builder() {
return new OutputFormatBuilder() {
@Override
public OutputFormat
build(String... args) {
Preconditions.checkArgument(args.length == 0, "usage: debug");
OutputFormat format = new DebugOutputFormat();
format.setBuilder(this);
return format;
}
@Override
return NAME;
}
};
}
}