org.apache.flume.channel
Class ReplicatingChannelSelector
java.lang.Object
org.apache.flume.channel.AbstractChannelSelector
org.apache.flume.channel.ReplicatingChannelSelector
- All Implemented Interfaces:
- ChannelSelector, Configurable, NamedComponent
public class ReplicatingChannelSelector
- extends AbstractChannelSelector
Replicating channel selector. This selector allows the event to be placed
in all the channels that the source is configured with.
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ReplicatingChannelSelector
public ReplicatingChannelSelector()
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.