|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Uses of Channel in org.apache.flume |
---|
Methods in org.apache.flume that return Channel | |
---|---|
Channel |
ChannelFactory.create(String name)
|
Channel |
ChannelFactory.createFanout(String chList,
Map<String,Channel> chMap)
|
Channel |
Source.getChannel()
|
Channel |
Sink.getChannel()
|
Methods in org.apache.flume with parameters of type Channel | |
---|---|
void |
Source.setChannel(Channel channel)
|
void |
Sink.setChannel(Channel channel)
|
Method parameters in org.apache.flume with type arguments of type Channel | |
---|---|
Channel |
ChannelFactory.createFanout(String chList,
Map<String,Channel> chMap)
|
boolean |
ChannelFactory.register(String name,
Class<? extends Channel> channelClass)
|
Uses of Channel in org.apache.flume.channel |
---|
Classes in org.apache.flume.channel that implement Channel | |
---|---|
class |
FanoutChannel
|
class |
MemoryChannel
Memory channel that with full transaction support Uses transaction object for each thread (source and sink) attached to channel. |
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)
|
Channel |
DefaultChannelFactory.createFanout(String chList,
Map<String,Channel> chMap)
|
Methods in org.apache.flume.channel that return types with arguments of type Channel | |
---|---|
Map<String,Class<? extends Channel>> |
DefaultChannelFactory.getChannelRegistry()
|
Methods in org.apache.flume.channel with parameters of type Channel | |
---|---|
void |
FanoutChannel.addFanout(Channel ch)
|
Method parameters in org.apache.flume.channel with type arguments of type Channel | |
---|---|
Channel |
DefaultChannelFactory.createFanout(String chList,
Map<String,Channel> chMap)
|
boolean |
DefaultChannelFactory.register(String name,
Class<? extends Channel> channelClass)
|
void |
DefaultChannelFactory.setChannelRegistry(Map<String,Class<? extends Channel>> channelRegistry)
|
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.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)
|
Uses of Channel in org.apache.flume.source |
---|
Methods in org.apache.flume.source that return Channel | |
---|---|
Channel |
AbstractSource.getChannel()
|
Methods in org.apache.flume.source with parameters of type Channel | |
---|---|
void |
AbstractSource.setChannel(Channel channel)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |