Uses of Interface
org.apache.flume.Channel

Packages that use Channel

Package	Description
org.apache.flume
org.apache.flume.channel
org.apache.flume.channel.file
org.apache.flume.channel.jdbc
org.apache.flume.channel.kafka
org.apache.flume.node
org.apache.flume.sink

Uses of Channel in org.apache.flume

Methods in org.apache.flume that return Channel

Modifier and Type	Method and Description
Channel	ChannelFactory.create(String name, String type)
Channel	Sink.getChannel()

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

Modifier and Type	Method and Description
List<Channel>	ChannelSelector.getAllChannels()
Class<? extends Channel>	ChannelFactory.getClass(String type)
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

Modifier and Type	Method and Description
void	Sink.setChannel(Channel channel) Sets the channel the sink will consume from

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

Modifier and Type	Method and Description
void	ChannelSelector.setChannels(List<Channel> channels)

Uses of Channel in org.apache.flume.channel

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

Modifier and Type	Class and Description
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.
class	SpillableMemoryChannel SpillableMemoryChannel will use main memory for buffering events until it has reached capacity.

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

Modifier and Type	Method and Description
Channel	DefaultChannelFactory.create(String name, String type)

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

Modifier and Type	Method and Description
List<Channel>	AbstractChannelSelector.getAllChannels()
protected List<Channel>	AbstractChannelSelector.getChannelListFromNames(String channels, Map<String,Channel> channelNameMap) Given a list of channel names as space delimited string, returns list of channels.
protected Map<String,Channel>	AbstractChannelSelector.getChannelNameMap()
Class<? extends Channel>	DefaultChannelFactory.getClass(String type)
List<Channel>	ReplicatingChannelSelector.getOptionalChannels(Event event)
List<Channel>	MultiplexingChannelSelector.getOptionalChannels(Event event)
List<Channel>	ReplicatingChannelSelector.getRequiredChannels(Event event)
List<Channel>	MultiplexingChannelSelector.getRequiredChannels(Event event)

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

Modifier and Type	Method and Description
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.

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

Modifier and Type	Method and Description
static ChannelSelector	ChannelSelectorFactory.create(List<Channel> channels, ChannelSelectorConfiguration conf)
static ChannelSelector	ChannelSelectorFactory.create(List<Channel> channels, Map<String,String> config)
protected List<Channel>	AbstractChannelSelector.getChannelListFromNames(String channels, Map<String,Channel> channelNameMap) Given a list of channel names as space delimited string, returns list of channels.
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

Modifier and Type	Class and Description
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

Modifier and Type	Class and Description
class	JdbcChannel A JDBC based channel implementation.

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

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

Modifier and Type	Class and Description
class	KafkaChannel

Uses of Channel in org.apache.flume.node

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

Modifier and Type	Method and Description
Map<String,Channel>	SimpleMaterializedConfiguration.getChannels()
Map<String,Channel>	MaterializedConfiguration.getChannels()

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

Modifier and Type	Method and Description
void	SimpleMaterializedConfiguration.addChannel(String name, Channel channel)
void	MaterializedConfiguration.addChannel(String name, Channel channel)

Uses of Channel in org.apache.flume.sink

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

Modifier and Type	Method and Description
Channel	AbstractSink.getChannel()

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

Modifier and Type	Method and Description
void	AbstractSink.setChannel(Channel channel)