org.apache.flume.sink
Class DefaultSinkFactory

java.lang.Object
  org.apache.flume.sink.DefaultSinkFactory

All Implemented Interfaces:

SinkFactory

public class DefaultSinkFactory
extends Object
implements SinkFactory

Constructor Summary

DefaultSinkFactory()

Method Summary

Sink	create(String name, String type)
Map<Class<?>,Map<String,Sink>>	getRegistryClone()
boolean	unregister(Sink sink)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DefaultSinkFactory

public DefaultSinkFactory()

Method Detail

unregister

public boolean unregister(Sink sink)

Specified by:

unregister in interface SinkFactory

create

public Sink create(String name,
                   String type)
            throws FlumeException

Specified by:

create in interface SinkFactory

Throws:

FlumeException

getRegistryClone

public Map<Class<?>,Map<String,Sink>> getRegistryClone()