Package | Description |
---|---|
org.apache.flume | |
org.apache.flume.agent.embedded |
This package provides Flume users the ability to embed simple agents
in applications.
|
org.apache.flume.annotations | |
org.apache.flume.channel | |
org.apache.flume.conf | |
org.apache.flume.interceptor | |
org.apache.flume.lifecycle | |
org.apache.flume.serialization | |
org.apache.flume.sink | |
org.apache.flume.source | |
org.apache.flume.source.jms |
Modifier and Type | Interface and Description |
---|---|
interface |
Channel
|
interface |
NamedComponent
Enables a component to be tagged with a name so that it can be referred
to uniquely within the configuration system.
|
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. |
Modifier and Type | Class and Description |
---|---|
class |
EmbeddedAgent
EmbeddedAgent gives Flume users the ability to embed simple agents in
applications.
|
class |
EmbeddedAgentConfiguration
Stores publicly accessible configuration constants and private
configuration constants and methods.
|
Modifier and Type | Class and Description |
---|---|
class |
InterfaceAudience
Annotation to inform users of a package, class or method's intended audience.
|
class |
InterfaceStability
Annotation to inform users of how much to rely on a particular package,
class or method not changing over time.
|
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.
|
Modifier and Type | Interface and Description |
---|---|
interface |
Configurable
Any class marked as Configurable may have a context including its
sub-configuration passed to it, requesting it configure itself.
|
Modifier and Type | Interface and Description |
---|---|
interface |
Interceptor |
Modifier and Type | Interface and Description |
---|---|
interface |
LifecycleAware
An interface implemented by any class that has a defined, stateful,
lifecycle.
|
Modifier and Type | Interface and Description |
---|---|
interface |
EventDeserializer
Establishes a contract for reading events stored in arbitrary formats from
reliable, resettable streams.
|
interface |
EventSerializer
This interface provides callbacks for important serialization-related events.
|
interface |
Resettable
Defines an API for objects that can be mark()ed and reset() on arbitrary
boundaries.
|
class |
ResettableInputStream
This abstract class defines an interface for which
the stream may be
mark ed and reset with no limit to
the number of bytes which may have been read between the calls. |
Modifier and Type | Class and Description |
---|---|
class |
AbstractSink |
Modifier and Type | Class and Description |
---|---|
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 |
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
|
Modifier and Type | Interface and Description |
---|---|
interface |
JMSMessageConverter
Converts a JMS Message to an Event.
|
Copyright © 2009–2019 Apache Software Foundation. All rights reserved.