Uses of Interface
org.apache.flume.NamedComponent

Packages that use NamedComponent

org.apache.flume
org.apache.flume.agent.embedded	This package provides Flume users the ability to embed simple agents in applications.
org.apache.flume.channel
org.apache.flume.channel.file
org.apache.flume.channel.jdbc
org.apache.flume.channel.kafka
org.apache.flume.sink
org.apache.flume.sink.elasticsearch
org.apache.flume.sink.hbase
org.apache.flume.sink.hdfs
org.apache.flume.sink.hive
org.apache.flume.sink.irc
org.apache.flume.sink.kafka
org.apache.flume.sink.kite
org.apache.flume.sink.solr.morphline
org.apache.flume.source
org.apache.flume.source.avroLegacy
org.apache.flume.source.http
org.apache.flume.source.jms
org.apache.flume.source.kafka
org.apache.flume.source.scribe
org.apache.flume.source.thriftLegacy
org.apache.flume.source.twitter

Uses of NamedComponent in org.apache.flume

Subinterfaces of NamedComponent in org.apache.flume

interface	Channel A channel connects a Source to a Sink.
interface	ChannelSelector Allows the selection of a subset of channels from the given set based on its implementation policy.
interface	EventDrivenSource A Source that does not need an external driver to poll for events to ingest; it provides its own event-driven mechanism to invoke event processing.
interface	PollableSource A Source that requires an external driver to poll to determine whether there are events that are available to ingest from the source.
interface	Sink A sink is connected to a Channel and consumes its contents, sending them to a configured destination that may vary according to the sink type.
interface	Source A source generates and calls methods on the configured ChannelProcessor to persist those events into the configured channels.

Uses of NamedComponent in org.apache.flume.agent.embedded

Classes in org.apache.flume.agent.embedded that implement NamedComponent

class

EmbeddedSource Simple source used to allow direct access to the channel for the Embedded Agent.

Uses of NamedComponent in org.apache.flume.channel

Classes in org.apache.flume.channel that implement NamedComponent

class	AbstractChannel
class	AbstractChannelSelector
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	MultiplexingChannelSelector
class	PseudoTxnMemoryChannel A capacity-capped Channel implementation that supports in-memory buffering and delivery of events.
class	ReplicatingChannelSelector Replicating channel selector.
class	SpillableMemoryChannel SpillableMemoryChannel will use main memory for buffering events until it has reached capacity.

Uses of NamedComponent in org.apache.flume.channel.file

Classes in org.apache.flume.channel.file that implement NamedComponent

class

FileChannel A durable Channel implementation that uses the local file system for its storage.

Uses of NamedComponent in org.apache.flume.channel.jdbc

Classes in org.apache.flume.channel.jdbc that implement NamedComponent

class

JdbcChannel A JDBC based channel implementation.

Uses of NamedComponent in org.apache.flume.channel.kafka

Classes in org.apache.flume.channel.kafka that implement NamedComponent

class

KafkaChannel

Uses of NamedComponent in org.apache.flume.sink

Classes in org.apache.flume.sink that implement NamedComponent

class	AbstractRpcSink This sink provides the basic RPC functionality for Flume.
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
class	ThriftSink A Sink implementation that can send events to an RPC server (such as Flume's ThriftSource).

Uses of NamedComponent in org.apache.flume.sink.elasticsearch

Classes in org.apache.flume.sink.elasticsearch that implement NamedComponent

class

ElasticSearchSink A sink which reads events from a channel and writes them to ElasticSearch based on the work done by https://github.com/Aconex/elasticflume.git.

Uses of NamedComponent in org.apache.flume.sink.hbase

Classes in org.apache.flume.sink.hbase that implement NamedComponent

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 NamedComponent in org.apache.flume.sink.hdfs

Classes in org.apache.flume.sink.hdfs that implement NamedComponent

class

HDFSEventSink

Uses of NamedComponent in org.apache.flume.sink.hive

Classes in org.apache.flume.sink.hive that implement NamedComponent

class

HiveSink

Uses of NamedComponent in org.apache.flume.sink.irc

Classes in org.apache.flume.sink.irc that implement NamedComponent

class

IRCSink

Uses of NamedComponent in org.apache.flume.sink.kafka

Classes in org.apache.flume.sink.kafka that implement NamedComponent

class

KafkaSink A Flume Sink that can publish messages to Kafka.

Uses of NamedComponent in org.apache.flume.sink.kite

Classes in org.apache.flume.sink.kite that implement NamedComponent

class

DatasetSink Sink that writes events to a Kite Dataset.

Uses of NamedComponent in org.apache.flume.sink.solr.morphline

Classes in org.apache.flume.sink.solr.morphline that implement NamedComponent

class	MorphlineSink Flume sink that extracts search documents from Flume events and processes them using a morphline Command chain.
class	MorphlineSolrSink Flume sink that extracts search documents from Flume events, processes them using a morphline Command chain, and loads them into Apache Solr.

Uses of NamedComponent in org.apache.flume.source

Classes in org.apache.flume.source that implement NamedComponent

class	AbstractEventDrivenSource Base class which ensures sub-classes will inherit all the properties of BasicSourceSemantics.
class	AbstractPollableSource Base class which ensures sub-classes will inherit all the properties of BasicSourceSemantics in addition to: Ensuring when configure/start throw an exception process will not be called Ensure that process will not be called unless configure and start have successfully been called
class	AbstractSource
class	AvroSource A Source implementation that receives Avro events from clients that implement AvroSourceProtocol.
class	BasicSourceSemantics Alternative to AbstractSource, which: Ensure configure cannot be called while started Exceptions thrown during configure, start, stop put source in ERROR state Exceptions thrown during start, stop will be logged but not re-thrown. Exception in configure disables starting
class	ExecSource A Source implementation that executes a Unix process and turns each line of text into an event.
class	MultiportSyslogTCPSource
class	NetcatSource A netcat-like source that listens on a given port and turns each line of text into an event.
class	SequenceGeneratorSource
class	SpoolDirectorySource
class	StressSource StressSource is an internal load-generating source implementation which is very useful for stress tests.
class	SyslogTcpSource
class	SyslogUDPSource
class	ThriftSource

Uses of NamedComponent in org.apache.flume.source.avroLegacy

Classes in org.apache.flume.source.avroLegacy that implement NamedComponent

class

AvroLegacySource A Source implementation that receives Avro events from Avro sink of Flume OG

Uses of NamedComponent in org.apache.flume.source.http

Classes in org.apache.flume.source.http that implement NamedComponent

class

HTTPSource A source which accepts Flume Events by HTTP POST and GET.

Uses of NamedComponent in org.apache.flume.source.jms

Classes in org.apache.flume.source.jms that implement NamedComponent

class

JMSSource

Uses of NamedComponent in org.apache.flume.source.kafka

Classes in org.apache.flume.source.kafka that implement NamedComponent

class

KafkaSource A Source for Kafka which reads messages from a kafka topic.

Uses of NamedComponent in org.apache.flume.source.scribe

Classes in org.apache.flume.source.scribe that implement NamedComponent

class

ScribeSource Flume should adopt the Scribe entry LogEntry from existing Scribe system.

Uses of NamedComponent in org.apache.flume.source.thriftLegacy

Classes in org.apache.flume.source.thriftLegacy that implement NamedComponent

class

ThriftLegacySource

Uses of NamedComponent in org.apache.flume.source.twitter

Classes in org.apache.flume.source.twitter that implement NamedComponent

class

TwitterSource Demo Flume source that connects via Streaming API to the 1% sample twitter firehose, continously downloads tweets, converts them to Avro format and sends Avro events to a downstream Flume sink.