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

Field Summary

Map<String,Class<? extends Sink>>

sinkRegistry

Constructor Summary

DefaultSinkFactory()

Method Summary

Sink	create(String name)
Set<String>	getSinkNames()
Map<String,Class<? extends Sink>>	getSinkRegistry()
boolean	register(String name, Class<? extends Sink> sinkClass)
void	setSinkRegistry(Map<String,Class<? extends Sink>> sinkRegistry)
String	toString()
boolean	unregister(String name)

Methods inherited from class java.lang.Object

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

Field Detail

sinkRegistry

public Map<String,Class<? extends Sink>> sinkRegistry

Constructor Detail

DefaultSinkFactory

public DefaultSinkFactory()

Method Detail

register

public boolean register(String name,
                        Class<? extends Sink> sinkClass)

Specified by:

register in interface SinkFactory

unregister

public boolean unregister(String name)

Specified by:

unregister in interface SinkFactory

getSinkNames

public Set<String> getSinkNames()

Specified by:

getSinkNames in interface SinkFactory

create

public Sink create(String name)
            throws InstantiationException

Specified by:

create in interface SinkFactory

Throws:

InstantiationException

toString

public String toString()

Overrides:

toString in class Object

getSinkRegistry

public Map<String,Class<? extends Sink>> getSinkRegistry()

setSinkRegistry

public void setSinkRegistry(Map<String,Class<? extends Sink>> sinkRegistry)