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)
Class<? extends Sink>	getClass(String type)

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

create

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

Specified by:

create in interface SinkFactory

Throws:

FlumeException

getClass

public Class<? extends Sink> getClass(String type)
                               throws FlumeException

Specified by:

getClass in interface SinkFactory

Throws:

FlumeException