org.apache.flume.spring.boot.config

Class AbstractFlumeConfiguration

java.lang.Object

org.apache.flume.spring.boot.config.AbstractFlumeConfiguration

public abstract class AbstractFlumeConfiguration
extends Object

Constructor Summary

Constructors

Constructor and Description
AbstractFlumeConfiguration()

Method Summary

Modifier and Type	Method and Description
protected <T extends Channel> T	configureChannel(String name, Class<T> clazz, Map<String,String> params)
protected <T extends Sink> Sink	configureSink(String name, Class<T> sinkClazz, Channel channel, Map<String,String> params)
protected <T extends SinkProcessor> T	configureSinkProcessor(Map<String,String> params, Class<T> clazz, List<Sink> sinks)
protected <T extends Source> SourceRunner	configureSource(String name, Class<T> clazz, ChannelSelector selector, Map<String,String> params)
protected <T extends Source> SourceRunner	configureSource(T source, ChannelSelector selector, Map<String,String> params)
protected ChannelSelector	createChannelSelector(Class<? extends ChannelSelector> clazz, Map<String,String> params)
protected SinkRunner	createSinkRunner(SinkProcessor sinkProcessor)
protected <T> List<T>	listOf(T... items) Creates a List from a Varargs array.

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractFlumeConfiguration

public AbstractFlumeConfiguration()

Method Detail

configureChannel

protected <T extends Channel> T configureChannel(String name,
                                                 Class<T> clazz,
                                                 Map<String,String> params)

configureSource

protected <T extends Source> SourceRunner configureSource(String name,
                                                          Class<T> clazz,
                                                          ChannelSelector selector,
                                                          Map<String,String> params)

configureSource

protected <T extends Source> SourceRunner configureSource(T source,
                                                          ChannelSelector selector,
                                                          Map<String,String> params)

configureSinkProcessor

protected <T extends SinkProcessor> T configureSinkProcessor(Map<String,String> params,
                                                             Class<T> clazz,
                                                             List<Sink> sinks)

createSinkRunner

protected SinkRunner createSinkRunner(SinkProcessor sinkProcessor)

configureSink

protected <T extends Sink> Sink configureSink(String name,
                                              Class<T> sinkClazz,
                                              Channel channel,
                                              Map<String,String> params)

createChannelSelector

protected ChannelSelector createChannelSelector(Class<? extends ChannelSelector> clazz,
                                                Map<String,String> params)

listOf

@SafeVarargs
protected final <T> List<T> listOf(T... items)

Creates a List from a Varargs array.

Type Parameters:

T - The type of objects in the List.

Parameters:

items - The items to add to the list.

Returns:

a List containing the supplied items.