Package | Description |
---|---|
org.apache.flume.agent.embedded |
This package provides Flume users the ability to embed simple agents
in applications.
|
org.apache.flume.channel.file | |
org.apache.flume.client.avro | |
org.apache.flume.formatter.output | |
org.apache.flume.serialization | |
org.apache.flume.source.jms | |
org.apache.flume.source.twitter |
Modifier and Type | Class and Description |
---|---|
class |
EmbeddedSource
Simple source used to allow direct access to the channel for the Embedded
Agent.
|
Modifier and Type | Class and Description |
---|---|
class |
Log
Stores FlumeEvents on disk and pointers to the events in a in memory queue.
|
class |
LogFile |
class |
LogFileV3
Represents a single data file on disk.
|
class |
Serialization |
class |
TransactionEventRecord
Base class for records in data file: Put, Take, Rollback, Commit
|
Modifier and Type | Class and Description |
---|---|
static class |
ReliableSpoolingFileEventReader.TrackingPolicy |
Modifier and Type | Class and Description |
---|---|
class |
PathManagerType |
Modifier and Type | Class and Description |
---|---|
class |
EventDeserializerType |
interface |
EventSerDe
A class that is able to both serialize and deserialize events.
|
class |
EventSerializerType |
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 |
JMSSource |
Modifier and Type | Class and Description |
---|---|
class |
TwitterSource
Demo Flume source that connects via Streaming API to the 1% sample twitter
firehose, continuously downloads tweets, converts them to Avro format and
sends Avro events to a downstream Flume sink.
|
Copyright © 2009–2019 Apache Software Foundation. All rights reserved.