Uses of Interface
org.apache.flume.Channel

Packages that use Channel

org.apache.flume
org.apache.flume.channel
org.apache.flume.channel.file
org.apache.flume.channel.jdbc
org.apache.flume.channel.recoverable.memory
org.apache.flume.conf.file
org.apache.flume.node
org.apache.flume.sink

Uses of Channel in org.apache.flume

Methods in org.apache.flume that return Channel

Channel	ChannelFactory.create(String name, String type)
Channel	Sink.getChannel()

Methods in org.apache.flume that return types with arguments of type Channel

List<Channel>	ChannelSelector.getAllChannels()
List<Channel>	ChannelSelector.getOptionalChannels(Event event) Returns a list of optional channels.
List<Channel>	ChannelSelector.getRequiredChannels(Event event) Returns a list of required channels.

Methods in org.apache.flume with parameters of type Channel

void	Sink.setChannel(Channel channel) Sets the channel the sink will consume from
boolean	ChannelFactory.unregister(Channel channel)

Method parameters in org.apache.flume with type arguments of type Channel

void	ChannelSelector.setChannels(List<Channel> channels)

Uses of Channel in org.apache.flume.channel

Classes in org.apache.flume.channel that implement Channel

class	AbstractChannel
class	BasicChannelSemantics An implementation of basic Channel semantics, including the implied thread-local semantics of the Transaction class, which is required to extend BasicTransactionSemantics.
class	MemoryChannel MemoryChannel is the recommended channel to use when speeds which writing to disk is impractical is required or durability of data is not required.
class	PseudoTxnMemoryChannel A capacity-capped Channel implementation that supports in-memory buffering and delivery of events.

Methods in org.apache.flume.channel that return Channel

Channel

DefaultChannelFactory.create(String name, String type)

Methods in org.apache.flume.channel that return types with arguments of type Channel

List<Channel>	AbstractChannelSelector.getAllChannels()
List<Channel>	ReplicatingChannelSelector.getOptionalChannels(Event event)
List<Channel>	MultiplexingChannelSelector.getOptionalChannels(Event event)
Map<Class<?>,Map<String,Channel>>	DefaultChannelFactory.getRegistryClone()
List<Channel>	ReplicatingChannelSelector.getRequiredChannels(Event event)
List<Channel>	MultiplexingChannelSelector.getRequiredChannels(Event event)

Methods in org.apache.flume.channel with parameters of type Channel

static void	ChannelUtils.put(Channel channel, Collection<Event> events) A convenience method for multiple-event put transactions.
static void	ChannelUtils.put(Channel channel, Event event) A convenience method for single-event put transactions.
static Event	ChannelUtils.take(Channel channel) A convenience method for single-event take transactions.
static List<Event>	ChannelUtils.take(Channel channel, int max) A convenience method for multiple-event take transactions.
static <T> T	ChannelUtils.transact(Channel channel, Callable<T> transactor) A general optimistic implementation of Transaction client semantics.
static void	ChannelUtils.transact(Channel channel, Runnable transactor) A convenience method for transactions that don't require a return value.
boolean	DefaultChannelFactory.unregister(Channel channel)

Method parameters in org.apache.flume.channel with type arguments of type Channel

static ChannelSelector	ChannelSelectorFactory.create(List<Channel> channels, ChannelSelectorConfiguration conf)
static ChannelSelector	ChannelSelectorFactory.create(List<Channel> channels, Map<String,String> config)
void	AbstractChannelSelector.setChannels(List<Channel> channels)

Uses of Channel in org.apache.flume.channel.file

Classes in org.apache.flume.channel.file that implement Channel

class

FileChannel A durable Channel implementation that uses the local file system for its storage.

Uses of Channel in org.apache.flume.channel.jdbc

Classes in org.apache.flume.channel.jdbc that implement Channel

class

JdbcChannel A JDBC based channel implementation.

Uses of Channel in org.apache.flume.channel.recoverable.memory

Classes in org.apache.flume.channel.recoverable.memory that implement Channel

class

RecoverableMemoryChannel Deprecated. The RecoverableMemoryChannel has been deprecated in favor of FileChannel, which gives better performance and is also durable.

Uses of Channel in org.apache.flume.conf.file

Methods in org.apache.flume.conf.file that return types with arguments of type Channel

Map<String,Channel>

SimpleNodeConfiguration.getChannels()

Method parameters in org.apache.flume.conf.file with type arguments of type Channel

void	SimpleNodeConfiguration.setChannels(Map<String,Channel> channels)

Uses of Channel in org.apache.flume.node

Methods in org.apache.flume.node that return types with arguments of type Channel

Map<String,Channel>

NodeConfiguration.getChannels()

Uses of Channel in org.apache.flume.sink

Methods in org.apache.flume.sink that return Channel

Channel

AbstractSink.getChannel()

Methods in org.apache.flume.sink with parameters of type Channel

void	AbstractSink.setChannel(Channel channel)