|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
| Packages that use Sink | |
|---|---|
| org.apache.flume | |
| org.apache.flume.sink | |
| org.apache.flume.sink.hbase | |
| org.apache.flume.sink.hdfs | |
| org.apache.flume.sink.irc | |
| Uses of Sink in org.apache.flume |
|---|
| Methods in org.apache.flume that return Sink | |
|---|---|
Sink |
SinkFactory.create(String name,
String type)
|
| Methods in org.apache.flume with parameters of type Sink | |
|---|---|
boolean |
SinkFactory.unregister(Sink sink)
|
| Method parameters in org.apache.flume with type arguments of type Sink | |
|---|---|
void |
SinkProcessor.setSinks(List<Sink> sinks)
Set all sinks to work with. |
| Uses of Sink in org.apache.flume.sink |
|---|
| Classes in org.apache.flume.sink that implement Sink | |
|---|---|
class |
AbstractSink
|
class |
AvroSink
A Sink implementation that can send events to an RPC server (such as
Flume's AvroSource). |
class |
LoggerSink
A Sink implementation that logs all events received at the INFO level
to the org.apache.flume.sink.LoggerSink logger. |
class |
NullSink
A Sink implementation that simply discards all events it receives. |
class |
RollingFileSink
|
| Methods in org.apache.flume.sink that return Sink | |
|---|---|
Sink |
DefaultSinkFactory.create(String name,
String type)
|
| Methods in org.apache.flume.sink that return types with arguments of type Sink | |
|---|---|
Iterator<Sink> |
LoadBalancingSinkProcessor.SinkSelector.createSinkIterator()
|
Map<Class<?>,Map<String,Sink>> |
DefaultSinkFactory.getRegistryClone()
|
protected List<Sink> |
AbstractSinkSelector.getSinks()
|
protected List<Sink> |
AbstractSinkProcessor.getSinks()
|
| Methods in org.apache.flume.sink with parameters of type Sink | |
|---|---|
boolean |
DefaultSinkFactory.unregister(Sink sink)
|
| Method parameters in org.apache.flume.sink with type arguments of type Sink | |
|---|---|
static SinkProcessor |
SinkProcessorFactory.getProcessor(ComponentConfiguration conf,
List<Sink> sinks)
|
static SinkProcessor |
SinkProcessorFactory.getProcessor(Context context,
List<Sink> sinks)
Creates a sink processor and configures it using the provided context |
void |
LoadBalancingSinkProcessor.SinkSelector.setSinks(List<Sink> sinks)
|
void |
FailoverSinkProcessor.setSinks(List<Sink> sinks)
|
void |
DefaultSinkProcessor.setSinks(List<Sink> sinks)
|
void |
AbstractSinkSelector.setSinks(List<Sink> sinks)
|
void |
AbstractSinkProcessor.setSinks(List<Sink> sinks)
|
| Constructor parameters in org.apache.flume.sink with type arguments of type Sink | |
|---|---|
SinkGroup(List<Sink> groupSinks)
|
|
| Uses of Sink in org.apache.flume.sink.hbase |
|---|
| Classes in org.apache.flume.sink.hbase that implement Sink | |
|---|---|
class |
AsyncHBaseSink
A simple sink which reads events from a channel and writes them to HBase. |
class |
HBaseSink
A simple sink which reads events from a channel and writes them to HBase. |
| Uses of Sink in org.apache.flume.sink.hdfs |
|---|
| Classes in org.apache.flume.sink.hdfs that implement Sink | |
|---|---|
class |
HDFSEventSink
|
| Uses of Sink in org.apache.flume.sink.irc |
|---|
| Classes in org.apache.flume.sink.irc that implement Sink | |
|---|---|
class |
IRCSink
|
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||