org.apache.flume.sink
Class DefaultSinkFactory

java.lang.Object
  extended by 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()


Copyright © 2009-2012 Apache Software Foundation. All Rights Reserved.