package com.cloudera.flume.handlers.debug;
import com.cloudera.flume.conf.Context;
import com.cloudera.flume.conf.SinkFactory.SinkBuilder;
import com.cloudera.flume.core.EventSink;
import com.google.common.base.Preconditions;
public class NullSink extends EventSink.Base {
public static SinkBuilder
builder() {
return new SinkBuilder() {
@Override
public EventSink
build(Context context, String... argv) {
Preconditions.checkArgument(argv.length == 0, "usage: null");
return new NullSink();
}
};
}
}