org.apache.nifi.processors.flume

Class NifiChannelSelector

java.lang.Object

org.apache.nifi.processors.flume.NifiChannelSelector

All Implemented Interfaces:

org.apache.flume.ChannelSelector, org.apache.flume.conf.Configurable, org.apache.flume.NamedComponent

public class NifiChannelSelector
extends java.lang.Object
implements org.apache.flume.ChannelSelector

Constructor Summary

Constructors

Constructor and Description
NifiChannelSelector(org.apache.flume.Channel channel)

Method Summary

Modifier and Type	Method and Description
void	configure(org.apache.flume.Context context)
java.util.List<org.apache.flume.Channel>	getAllChannels()
java.lang.String	getName()
java.util.List<org.apache.flume.Channel>	getOptionalChannels(org.apache.flume.Event event)
java.util.List<org.apache.flume.Channel>	getRequiredChannels(org.apache.flume.Event event)
void	setChannels(java.util.List<org.apache.flume.Channel> channels)
void	setName(java.lang.String name)

Methods inherited from class java.lang.Object

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

Constructor Detail

NifiChannelSelector

public NifiChannelSelector(org.apache.flume.Channel channel)

Method Detail

getRequiredChannels

public java.util.List<org.apache.flume.Channel> getRequiredChannels(org.apache.flume.Event event)

Specified by:

getRequiredChannels in interface org.apache.flume.ChannelSelector

getOptionalChannels

public java.util.List<org.apache.flume.Channel> getOptionalChannels(org.apache.flume.Event event)

Specified by:

getOptionalChannels in interface org.apache.flume.ChannelSelector

getAllChannels

public java.util.List<org.apache.flume.Channel> getAllChannels()

Specified by:

getAllChannels in interface org.apache.flume.ChannelSelector

setChannels

public void setChannels(java.util.List<org.apache.flume.Channel> channels)

Specified by:

setChannels in interface org.apache.flume.ChannelSelector

getName

public java.lang.String getName()

Specified by:

getName in interface org.apache.flume.NamedComponent

setName

public void setName(java.lang.String name)

Specified by:

setName in interface org.apache.flume.NamedComponent

configure

public void configure(org.apache.flume.Context context)

Specified by:

configure in interface org.apache.flume.conf.Configurable