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 |
Modifier and Type | Method and Description |
---|---|
Channel |
ChannelFactory.create(String name,
String type) |
Channel |
Sink.getChannel() |
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.
|
Modifier and Type | Method and Description |
---|---|
void |
Sink.setChannel(Channel channel)
Sets the channel the sink will consume from
|
Modifier and Type | Method and Description |
---|---|
void |
ChannelSelector.setChannels(List<Channel> channels) |
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.
|
Modifier and Type | Method and Description |
---|---|
Channel |
DefaultChannelFactory.create(String name,
String type) |
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) |
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.
|
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) |
Modifier and Type | Class and Description |
---|---|
class |
FileChannel
A durable
Channel implementation that uses the local file system for
its storage. |
Modifier and Type | Class and Description |
---|---|
class |
JdbcChannel
A JDBC based channel implementation.
|
Modifier and Type | Class and Description |
---|---|
class |
KafkaChannel |
Modifier and Type | Method and Description |
---|---|
com.google.common.collect.ImmutableMap<String,Channel> |
SimpleMaterializedConfiguration.getChannels() |
com.google.common.collect.ImmutableMap<String,Channel> |
MaterializedConfiguration.getChannels() |
Modifier and Type | Method and Description |
---|---|
void |
SimpleMaterializedConfiguration.addChannel(String name,
Channel channel) |
void |
MaterializedConfiguration.addChannel(String name,
Channel channel) |
Modifier and Type | Method and Description |
---|---|
Channel |
AbstractSink.getChannel() |
Modifier and Type | Method and Description |
---|---|
void |
AbstractSink.setChannel(Channel channel) |
Copyright © 2009-2016 Apache Software Foundation. All Rights Reserved.