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.kafka   
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()
           
 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
 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
 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.
 class SpillableMemoryChannel
           SpillableMemoryChannel will use main memory for buffering events until it has reached capacity.
 

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()
           
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
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
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
 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.kafka
 

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

Uses of Channel in org.apache.flume.node
 

Methods in org.apache.flume.node that return types with arguments of type Channel
 com.google.common.collect.ImmutableMap<String,Channel> SimpleMaterializedConfiguration.getChannels()
           
 com.google.common.collect.ImmutableMap<String,Channel> MaterializedConfiguration.getChannels()
           
 

Methods in org.apache.flume.node with parameters of type Channel
 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
 Channel AbstractSink.getChannel()
           
 

Methods in org.apache.flume.sink with parameters of type Channel
 void AbstractSink.setChannel(Channel channel)
           
 



Copyright © 2009-2015 Apache Software Foundation. All Rights Reserved.