org.apache.flume.channel
Class MultiplexingChannelSelector
java.lang.Object
org.apache.flume.channel.AbstractChannelSelector
org.apache.flume.channel.MultiplexingChannelSelector
- All Implemented Interfaces:
- ChannelSelector, Configurable, NamedComponent
public class MultiplexingChannelSelector
- extends AbstractChannelSelector
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
CONFIG_MULTIPLEX_HEADER_NAME
public static final String CONFIG_MULTIPLEX_HEADER_NAME
- See Also:
- Constant Field Values
DEFAULT_MULTIPLEX_HEADER
public static final String DEFAULT_MULTIPLEX_HEADER
- See Also:
- Constant Field Values
CONFIG_PREFIX_MAPPING
public static final String CONFIG_PREFIX_MAPPING
- See Also:
- Constant Field Values
CONFIG_PREFIX_DEFAULT
public static final String CONFIG_PREFIX_DEFAULT
- See Also:
- Constant Field Values
MultiplexingChannelSelector
public MultiplexingChannelSelector()
getRequiredChannels
public List<Channel> getRequiredChannels(Event event)
- Description copied from interface:
ChannelSelector
- Returns a list of required channels. A failure in writing the event to
these channels must be communicated back to the source that received this
event.
- Returns:
- the list of required channels that this selector has selected for
the given event.
getOptionalChannels
public List<Channel> getOptionalChannels(Event event)
- Description copied from interface:
ChannelSelector
- Returns a list of optional channels. A failure in writing the event to
these channels must be ignored.
- Returns:
- the list of optional channels that this selector has selected for
the given event.
configure
public void configure(Context context)
Copyright © 2009-2012 Apache Software Foundation. All Rights Reserved.