|
||||||||||
| 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 | |||||||||