Share

Search Java Classes and Packages

Search Java Frameworks and Libraries

255581 classes and counting ...
Search Tips Index Status



# Classes and Interfaces in #Flume - 323 results found.
NameDescriptionTypePackageFrameworkJavaDoc
AbstractAvroEventSerializerThis is a helper class provided to make it straightforward to serialize Flume events into Avro data.Classorg.apache.flume.serializationFlumejavadoc
AbstractChannelClassorg.apache.flume.channelFlumejavadoc
AbstractChannelSelectorClassorg.apache.flume.channelFlumejavadoc
AbstractConfigurationProviderClassorg.apache.flume.nodeFlumejavadoc
AbstractElasticSearchIndexRequestBuilderFactoryAbstract base class for custom implementations of ElasticSearchIndexRequestBuilderFactory.Classorg.apache.flume.sink.elasticsearchFlumejavadoc
AbstractEventDrivenSourceBase class which ensures sub-classes will inherit all the properties of BasicSourceSemantics.Classorg.apache.flume.sourceFlumejavadoc
AbstractHDFSWriterClassorg.apache.flume.sink.hdfsFlumejavadoc
AbstractPollableSourceBase class which ensures sub-classes will inherit all the properties of BasicSourceSemantics in addition to:Classorg.apache.flume.sourceFlumejavadoc
AbstractRpcClientClassorg.apache.flume.apiFlumejavadoc
AbstractRpcSinkThis sink provides the basic RPC functionality for Flume.Classorg.apache.flume.sinkFlumejavadoc
AbstractSinkNested Class SummaryNested classes/interfaces inherited from interface org.Classorg.apache.flume.sinkFlumejavadoc
AbstractSinkProcessorA convenience base class for sink processors.Classorg.apache.flume.sinkFlumejavadoc
AbstractSinkSelectorClassorg.apache.flume.sinkFlumejavadoc
AbstractSourceClassorg.apache.flume.sourceFlumejavadoc
AESCTRNoPaddingProviderClassorg.apache.flume.channel.file.encryptionFlumejavadoc
ApplicationClassorg.apache.flume.nodeFlumejavadoc
AsyncHbaseEventSerializerInterface for an event serializer which serializes the headers and body of an event to write them to hbase.Interfaceorg.apache.flume.sink.hbaseFlumejavadoc
AsyncHBaseSinkA simple sink which reads events from a channel and writes them to HBase.Classorg.apache.flume.sink.hbaseFlumejavadoc
AvroCLIClientClassorg.apache.flume.client.avroFlumejavadoc
AvroEventDeserializerA deserializer that parses Avro container files, generating one Flume event per record in the Avro file, and storing binary avro-encoded records inClassorg.apache.flume.serializationFlumejavadoc
AvroEventSerializer This class serializes Flume events into Avro data files.Classorg.apache.flume.sink.hdfsFlumejavadoc
AvroEventSerializerConfigurationConstantsClassorg.apache.flume.serializationFlumejavadoc
AvroLegacySource A Source implementation that receives Avro events from Avro sink of Configuration optionsClassorg.apache.flume.source.avroLegacyFlumejavadoc
AvroSink A Sink implementation that can send events to an RPC server (such as Flume's AvroSource).Classorg.apache.flume.sinkFlumejavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

AvroSource A Source implementation that receives Avro events from clients that implement AvroSourceProtocol.Classorg.apache.flume.sourceFlumejavadoc
BadCheckpointExceptionException thrown when the checkpoint directory contains invalid data, probably due to the channel stopping while the checkpoint was written.Classorg.apache.flume.channel.fileFlumejavadoc
BasicChannelSemantics An implementation of basic Channel semantics, including the implied thread-local semantics of the Transaction class,Classorg.apache.flume.channelFlumejavadoc
BasicConfigurationConstantsClassorg.apache.flume.confFlumejavadoc
BasicSourceSemanticsAlternative to AbstractSource, which: Ensure configure cannot be called while startedExceptions thrown during configure, start, stop put source in ERROR stateExceptions thrown during start, stop will be logged but not re-thrown.Classorg.apache.flume.sourceFlumejavadoc
BasicTransactionSemantics An implementation of basic Transaction semantics designed to work in concert with BasicChannelSemantics to simplifyClassorg.apache.flume.channelFlumejavadoc
BatchAwareThis interface allows for implementing HBase serializers that are aware of batching.Interfaceorg.apache.flume.sink.hbaseFlumejavadoc
BlobDeserializerA deserializer that reads a Binary Large Object (BLOB) per event, typically one BLOB per file; To be used in conjunction with Flume SpoolDirectorySource.Classorg.apache.flume.sink.solr.morphlineFlumejavadoc
BlobHandlerBlobHandler for HTTPSource that returns event that contains the request parameters as well as the Binary Large Object (BLOB) uploaded with thisClassorg.apache.flume.sink.solr.morphlineFlumejavadoc
BodyTextEventSerializerThis class simply writes the body of the event to the output stream and appends a newline after each event.Classorg.apache.flume.serializationFlumejavadoc
BucketClosedExceptionClassorg.apache.flume.sink.hdfsFlumejavadoc
BucketPathClassorg.apache.flume.formatter.outputFlumejavadoc
Channel A channel connects a Source to a Sink.Interfaceorg.apache.flumeFlumejavadoc
Check Code Snippets / Samples for org.apache.flume.Channel
ChannelConfigurationClassorg.apache.flume.conf.channelFlumejavadoc
ChannelCounterNested Class SummaryNested classes/interfaces inherited from class org.Classorg.apache.flume.instrumentationFlumejavadoc
ChannelCounterMBeanThis interface represents a channel counter mbean.Interfaceorg.apache.flume.instrumentationFlumejavadoc
ChannelExceptionA channel exception is raised whenever a channel operation fails.Classorg.apache.flumeFlumejavadoc
ChannelFactoryInterfaceorg.apache.flumeFlumejavadoc
ChannelFullExceptionClassorg.apache.flumeFlumejavadoc
ChannelProcessorA channel processor exposes operations to put Events into Channels.Classorg.apache.flume.channelFlumejavadoc
ChannelProcessorCounterNested Class SummaryNested classes/interfaces inherited from class org.Classorg.apache.flume.instrumentationFlumejavadoc
ChannelSelector Allows the selection of a subset of channels from the given set based on its implementation policy.Interfaceorg.apache.flumeFlumejavadoc
ChannelSelectorConfigurationClassorg.apache.flume.conf.channelFlumejavadoc
ChannelSelectorFactoryClassorg.apache.flume.channelFlumejavadoc
ChannelSelectorTypeenum ChannelSelectorTypeextends EnumEnumeration of built in channel selector types available in the system.Classorg.apache.flume.conf.channelFlumejavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

ChannelTypeenum ChannelTypeextends EnumEnumeration of built in channel types available in the system.Classorg.apache.flume.conf.channelFlumejavadoc
ChannelUtils A collection of utilities for interacting with Channel objects.Classorg.apache.flume.channelFlumejavadoc
CheckpointRebuilderClassorg.apache.flume.channel.fileFlumejavadoc
CipherProviderClassorg.apache.flume.channel.file.encryptionFlumejavadoc
CipherProviderFactoryClassorg.apache.flume.channel.file.encryptionFlumejavadoc
CipherProviderTypeenum CipherProviderTypeextends EnumEnum Constant SummaryAESCTRNOPADDINGClassorg.apache.flume.channel.file.encryptionFlumejavadoc
ClockFacade for System.Interfaceorg.apache.flumeFlumejavadoc
ComponentConfigurationAbstract implementation of the Component Configuration Manager.Classorg.apache.flume.confFlumejavadoc
ComponentConfigurationFactoryClassorg.apache.flume.confFlumejavadoc
Configurable Any class marked as Configurable may have a context including its sub-configuration passed to it, requesting it configure itself.Interfaceorg.apache.flume.confFlumejavadoc
ConfigurableComponentInterfaceorg.apache.flume.confFlumejavadoc
ConfigurablesMethods for working with Configurables.Classorg.apache.flume.confFlumejavadoc
ConfigurationConstantsContains configuration keys used by the JDBC channel implementation.Classorg.apache.flume.channel.jdbcFlumejavadoc
ConfigurationExceptionClassorg.apache.flume.confFlumejavadoc
ConfigurationProviderInterfaceorg.apache.flume.nodeFlumejavadoc
ConstantsClassorg.apache.flumeFlumejavadoc
ContentBuilderUtilClassorg.apache.flume.sink.elasticsearchFlumejavadoc
ContextThe context is a key-value store used to pass configuration information throughout the system.Classorg.apache.flumeFlumejavadoc
CorruptEventExceptionSee Also:Serialized FormConstructor SummaryCorruptEventException()Classorg.apache.flume.channel.fileFlumejavadoc
CounterGroupUsed for counting events, collecting metrics, etc.Classorg.apache.flumeFlumejavadoc
DatabaseTypeenum DatabaseTypeextends EnumEnum Constant SummaryDERBYClassorg.apache.flume.channel.jdbcFlumejavadoc
DecodeErrorPolicyenum DecodeErrorPolicyextends EnumEnum Constant SummaryFAILClassorg.apache.flume.serializationFlumejavadoc
DecryptionFailureExceptionException that is thrown when the channel is unable to decrypt an even read from the channel.Classorg.apache.flume.channel.file.encryptionFlumejavadoc
DefaultChannelFactoryClassorg.apache.flume.channelFlumejavadoc
DefaultJMSMessageConverterConverts BytesMessage, TextMessage, and ObjectMessage to a Flume Event.Classorg.apache.flume.source.jmsFlumejavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

DefaultSinkFactoryClassorg.apache.flume.sinkFlumejavadoc
DefaultSinkProcessorDefault sink processor that only accepts a single sink, passing on process results without any additional handling.Classorg.apache.flume.sinkFlumejavadoc
DefaultSourceFactoryClassorg.apache.flume.sourceFlumejavadoc
DerbySchemaHandler Schema handler for Derby Database.Classorg.apache.flume.channel.jdbc.implFlumejavadoc
DirectMemoryUtilsClassorg.apache.flume.toolsFlumejavadoc
DummyPlaceholder class so the git mirror does not leave out the src/main/java dirConstructor SummaryDummy()Classorg.apache.flumeFlumejavadoc
DurablePositionTrackerClass that stores object state in an avro container file.Classorg.apache.flume.serializationFlumejavadoc
ElasticSearchClientInterface for an ElasticSearch client which is responsible for sending bulks of events to ElasticSearch.Interfaceorg.apache.flume.sink.elasticsearch.clientFlumejavadoc
ElasticSearchClientFactoryInternal ElasticSearch client factory.Classorg.apache.flume.sink.elasticsearch.clientFlumejavadoc
ElasticSearchDynamicSerializerBasic serializer that serializes the event body and header fields into A best effort will be used to determine the content-type, if it cannot beClassorg.apache.flume.sink.elasticsearchFlumejavadoc
ElasticSearchEventSerializerInterface for an event serializer which serializes the headers and body of an event to write them to ElasticSearch.Interfaceorg.apache.flume.sink.elasticsearchFlumejavadoc
ElasticSearchIndexRequestBuilderFactoryInterface for creating ElasticSearch IndexRequestBuilder instances from serialized flume events.Interfaceorg.apache.flume.sink.elasticsearchFlumejavadoc
ElasticSearchLogStashEventSerializerSerialize flume events into the same format LogStash uses This can be used to send events to ElasticSearch and use clients such asClassorg.apache.flume.sink.elasticsearchFlumejavadoc
ElasticSearchRestClientRest ElasticSearch client which is responsible for sending bulks of events to ElasticSearch using ElasticSearch HTTP API.Classorg.apache.flume.sink.elasticsearch.clientFlumejavadoc
ElasticSearchSinkA sink which reads events from a channel and writes them to ElasticSearch based on the work done by https://github.Classorg.apache.flume.sink.elasticsearchFlumejavadoc
ElasticSearchSinkConstantsClassorg.apache.flume.sink.elasticsearchFlumejavadoc
ElasticSearchTransportClientClassorg.apache.flume.sink.elasticsearch.clientFlumejavadoc
EmbeddedAgentEmbeddedAgent gives Flume users the ability to embed simple agents in applications.Classorg.apache.flume.agent.embeddedFlumejavadoc
EmbeddedAgentConfigurationStores publicly accessible configuration constants and private configuration constants and methods.Classorg.apache.flume.agent.embeddedFlumejavadoc
EmbeddedSourceSimple source used to allow direct access to the channel for the EmbeddedConstructor SummaryEmbeddedSource()Classorg.apache.flume.agent.embeddedFlumejavadoc
EncryptionConfigurationClassorg.apache.flume.channel.file.encryptionFlumejavadoc
EventBasic representation of a data object in Flume.Interfaceorg.apache.flumeFlumejavadoc
EventBuilderClassorg.apache.flume.eventFlumejavadoc
EventDeliveryExceptionAn event delivery exception is raised whenever an Event fails to reach at least one of its intended (next-hop) destinations.Classorg.apache.flumeFlumejavadoc
EventDeserializerEstablishes a contract for reading events stored in arbitrary formats from reliable, resettable streams.Interfaceorg.apache.flume.serializationFlumejavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

EventDeserializerFactoryClassorg.apache.flume.serializationFlumejavadoc
EventDeserializerTypeenum EventDeserializerTypeextends EnumEnum Constant SummaryAVROClassorg.apache.flume.serializationFlumejavadoc
EventDrivenSourceA Source that does not need an external driver to poll for events to ingest; it provides its own event-drivenInterfaceorg.apache.flumeFlumejavadoc
EventDrivenSourceRunnerStarts, stops, and manages event-driven sources.Classorg.apache.flume.sourceFlumejavadoc
EventHelperClassorg.apache.flume.eventFlumejavadoc
EventReaderA line reader produces a stream of lines for the AvroCLIClient to ingest into Flume.Interfaceorg.apache.flume.client.avroFlumejavadoc
EventSerDeA class that is able to both serialize and deserialize events.Interfaceorg.apache.flume.serializationFlumejavadoc
EventSerializer This interface provides callbacks for important serialization-related events.Interfaceorg.apache.flume.serializationFlumejavadoc
EventSerializerFactoryClassorg.apache.flume.serializationFlumejavadoc
EventSerializerIndexRequestBuilderFactoryDefault implementation of ElasticSearchIndexRequestBuilderFactory.Classorg.apache.flume.sink.elasticsearchFlumejavadoc
EventSerializerTypeenum EventSerializerTypeextends EnumEnum Constant SummaryAVRO_EVENTClassorg.apache.flume.serializationFlumejavadoc
EventStatusenum EventStatusextends Enumimplements org.Classcom.cloudera.flume.handlers.thriftFlumejavadoc
ExecSource A Source implementation that executes a Unix process and turns each line of text into an event.Classorg.apache.flume.sourceFlumejavadoc
ExecSourceConfigurationConstantsClassorg.apache.flume.sourceFlumejavadoc
FailoverRpcClientAvro/Netty implementation of RpcClient which supports failover.Classorg.apache.flume.apiFlumejavadoc
FailoverSinkProcessorFailoverSinkProcessor maintains a prioritized list of sinks, guarranteeing that so long as one is available events will be processed.Classorg.apache.flume.sinkFlumejavadoc
FileChannel A durable Channel implementation that uses the local file system for FileChannel works by writing all transactions to a set of directoriesClassorg.apache.flume.channel.fileFlumejavadoc
FileChannelConfigurationClassorg.apache.flume.channel.fileFlumejavadoc
FileChannelIntegrityToolClassorg.apache.flume.toolsFlumejavadoc
FlumeConfiguration FlumeConfiguration is an in memory representation of the hierarchical configuration namespace required by the ConfigurationProvider.Classorg.apache.flume.confFlumejavadoc
FlumeConfigurationErrorClassorg.apache.flume.confFlumejavadoc
FlumeConfigurationErrorTypeenum FlumeConfigurationErrorTypeextends EnumEnum Constant SummaryAGENT_CONFIGURATION_INVALIDClassorg.apache.flume.confFlumejavadoc
FlumeEventAvroEventSerializerClassorg.apache.flume.serializationFlumejavadoc
FlumeExceptionBase class of all flume exceptions.Classorg.apache.flumeFlumejavadoc
FlumeToolInterfaceorg.apache.flume.toolsFlumejavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

FlumeToolsMainClassorg.apache.flume.toolsFlumejavadoc
FlumeToolTypeenum FlumeToolTypeextends EnumEnum Constant SummaryFCINTEGRITYTOOLClassorg.apache.flume.toolsFlumejavadoc
GangliaServerA Ganglia server that polls JMX based at a configured frequency (defaults to once every 60 seconds).Classorg.apache.flume.instrumentationFlumejavadoc
GetJavaPropertyA generic way for querying Java properties.Classorg.apache.flume.toolsFlumejavadoc
HbaseEventSerializerInterface for an event serializer which serializes the headers and body of an event to write them to hbase.Interfaceorg.apache.flume.sink.hbaseFlumejavadoc
HBaseSinkA simple sink which reads events from a channel and writes them to HBase.Classorg.apache.flume.sink.hbaseFlumejavadoc
HBaseSinkConfigurationConstantsClassorg.apache.flume.sink.hbaseFlumejavadoc
HBaseSinkSecurityManagerClass to handle logging into HBase with the credentials passed in.Classorg.apache.flume.sink.hbaseFlumejavadoc
HDFSCompressedDataStreamClassorg.apache.flume.sink.hdfsFlumejavadoc
HDFSDataStreamClassorg.apache.flume.sink.hdfsFlumejavadoc
HDFSEventSinkClassorg.apache.flume.sink.hdfsFlumejavadoc
HDFSSequenceFileClassorg.apache.flume.sink.hdfsFlumejavadoc
HDFSTextSerializerClassorg.apache.flume.sink.hdfsFlumejavadoc
HDFSWritableSerializerClassorg.apache.flume.sink.hdfsFlumejavadoc
HDFSWriterInterfaceorg.apache.flume.sink.hdfsFlumejavadoc
HDFSWriterFactoryClassorg.apache.flume.sink.hdfsFlumejavadoc
HeaderAndBodyTextEventSerializerThis class simply writes the body of the event to the output stream and appends a newline after each event.Classorg.apache.flume.serializationFlumejavadoc
HostInfoA convenience class that holds the property reference name along with the hostname and port number of a specified host address.Classorg.apache.flume.apiFlumejavadoc
HostInterceptorSimple Interceptor class that sets the host name or IP on all events that are intercepted.Classorg.apache.flume.interceptorFlumejavadoc
HTTPBadRequestExceptionException thrown by an HTTP Handler if the request was not parsed correctly into an event because the request was not in the expected format.Classorg.apache.flume.source.httpFlumejavadoc
HTTPMetricsServerA Monitor service implementation that runs a web server on a configurable port and returns the metrics for components in JSON format.Classorg.apache.flume.instrumentation.httpFlumejavadoc
HTTPServerConstraintUtilClassorg.apache.flume.toolsFlumejavadoc
HTTPSourceA source which accepts Flume Events by HTTP POST and GET.Classorg.apache.flume.source.httpFlumejavadoc
HTTPSourceConfigurationConstantsClassorg.apache.flume.source.httpFlumejavadoc
HTTPSourceHandlerInterfaceorg.apache.flume.source.httpFlumejavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

IndexNameBuilderInterfaceorg.apache.flume.sink.elasticsearchFlumejavadoc
InitialContextFactoryClassorg.apache.flume.source.jmsFlumejavadoc
InterceptorInterfaceorg.apache.flume.interceptorFlumejavadoc
InterceptorBuilderFactoryFactory used to register instances of Interceptors & their builders, as well as to instantiate the builders.Classorg.apache.flume.interceptorFlumejavadoc
InterceptorChainNested Class SummaryNested classes/interfaces inherited from interface org.Classorg.apache.flume.interceptorFlumejavadoc
InterceptorTypeenum InterceptorTypeextends EnumEnum Constant SummaryHOSTClassorg.apache.flume.interceptorFlumejavadoc
InterfaceAudienceAnnotation to inform users of a package, class or method's intended audience.Classorg.apache.flume.annotationsFlumejavadoc
InterfaceStabilityAnnotation to inform users of how much to rely on a particular package, class or method not changing over time.Classorg.apache.flume.annotationsFlumejavadoc
IRCSinkClassorg.apache.flume.sink.ircFlumejavadoc
JCEFileKeyProviderClassorg.apache.flume.channel.file.encryptionFlumejavadoc
JdbcChannel A JDBC based channel implementation.Classorg.apache.flume.channel.jdbcFlumejavadoc
JdbcChannelExceptionClassorg.apache.flume.channel.jdbcFlumejavadoc
JdbcChannelProviderService provider interface for JDBC channel providers.Interfaceorg.apache.flume.channel.jdbcFlumejavadoc
JdbcChannelProviderFactoryClassorg.apache.flume.channel.jdbcFlumejavadoc
JdbcChannelProviderImplClassorg.apache.flume.channel.jdbc.implFlumejavadoc
JdbcTransactionFactoryClassorg.apache.flume.channel.jdbc.implFlumejavadoc
JdbcTransactionImplNested Class SummaryNested classes/interfaces inherited from interface org.Classorg.apache.flume.channel.jdbc.implFlumejavadoc
JMSDestinationLocatorenum JMSDestinationLocatorextends EnumEnum Constant SummaryCDIClassorg.apache.flume.source.jmsFlumejavadoc
JMSDestinationTypeenum JMSDestinationTypeextends EnumEnum Constant SummaryQUEUEClassorg.apache.flume.source.jmsFlumejavadoc
JMSMessageConsumerFactoryConstructor SummaryJMSMessageConsumerFactory()Methods inherited from class java.Classorg.apache.flume.source.jmsFlumejavadoc
JMSMessageConverterConverts a JMS Message to an Event.Interfaceorg.apache.flume.source.jmsFlumejavadoc
JMSSourceNested Class SummaryNested classes/interfaces inherited from interface org.Classorg.apache.flume.source.jmsFlumejavadoc
JMSSourceConfigurationClassorg.apache.flume.source.jmsFlumejavadoc
JMXPollUtilClassorg.apache.flume.instrumentation.utilFlumejavadoc
JSONEventClassorg.apache.flume.eventFlumejavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

JSONHandlerJSONHandler for HTTPSource that accepts an array of events.Classorg.apache.flume.source.httpFlumejavadoc
KerberosUserSimple Pair class used to define a unique (principal, keyTab) combination.Classorg.apache.flume.sink.hdfsFlumejavadoc
KeyProviderClassorg.apache.flume.channel.file.encryptionFlumejavadoc
KeyProviderFactoryClassorg.apache.flume.channel.file.encryptionFlumejavadoc
KeyProviderTypeenum KeyProviderTypeextends EnumEnum Constant SummaryJCEKSFILEClassorg.apache.flume.channel.file.encryptionFlumejavadoc
LengthMeasurableInterfaceorg.apache.flume.serializationFlumejavadoc
LifecycleAware An interface implemented by any class that has a defined, stateful, Implementations of LifecycleAware conform to a standard method ofInterfaceorg.apache.flume.lifecycleFlumejavadoc
LifecycleControllerClassorg.apache.flume.lifecycleFlumejavadoc
LifecycleExceptionSee Also:Serialized FormConstructor SummaryLifecycleException()Classorg.apache.flume.lifecycleFlumejavadoc
LifecycleStateenum LifecycleStateextends EnumEnum Constant SummaryERRORClassorg.apache.flume.lifecycleFlumejavadoc
LifecycleSupervisorClassorg.apache.flume.lifecycleFlumejavadoc
LineDeserializerA deserializer that parses text lines from a file.Classorg.apache.flume.serializationFlumejavadoc
LoadBalancingLog4jAppenderAppends Log4j Events to an external Flume client which is decribed by the Log4j configuration file.Classorg.apache.flume.clients.log4jappenderFlumejavadoc
LoadBalancingRpcClientAn implementation of RpcClient interface that uses NettyAvroRpcClient instances to load-balance the requests over many different hosts.Classorg.apache.flume.apiFlumejavadoc
LoadBalancingSinkProcessorProvides the ability to load-balance flow over multiple sinks.Classorg.apache.flume.sinkFlumejavadoc
LogStores FlumeEvents on disk and pointers to the events in a in memory queue.Classorg.apache.flume.channel.fileFlumejavadoc
Log4jAppenderAppends Log4j Events to an external Flume client which is decribed by the Log4j configuration file.Classorg.apache.flume.clients.log4jappenderFlumejavadoc
Log4jAvroHeadersenum Log4jAvroHeadersextends EnumEnum Constant SummaryAVRO_SCHEMA_LITERALClassorg.apache.flume.clients.log4jappenderFlumejavadoc
LogEntryClassorg.apache.flume.source.scribeFlumejavadoc
LogFileClassorg.apache.flume.channel.fileFlumejavadoc
LogFileRetryableIOExceptionSee Also:Serialized FormConstructor SummaryLogFileRetryableIOException()Classorg.apache.flume.channel.fileFlumejavadoc
LogFileV3Represents a single data file on disk.Classorg.apache.flume.channel.fileFlumejavadoc
LoggerSink A Sink implementation that logs all events received at the INFO level to the org.Classorg.apache.flume.sinkFlumejavadoc
LogRecordClassorg.apache.flume.channel.fileFlumejavadoc
LogUtilsConstructor SummaryLogUtils()Methods inherited from class java.Classorg.apache.flume.channel.fileFlumejavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

MaterializedConfigurationMaterializedConfiguration represents the materialization of a Flume properties file.Interfaceorg.apache.flume.nodeFlumejavadoc
MemoryChannel MemoryChannel is the recommended channel to use when speeds which writing to disk is impractical is required or durability of data is notClassorg.apache.flume.channelFlumejavadoc
MonitoredCounterGroupUsed for keeping track of internal metrics using atomic integers This is used by a variety of component types such as Sources, Channels,Classorg.apache.flume.instrumentationFlumejavadoc
MonitoringTypeenum MonitoringTypeextends EnumEnum for Monitoring types.Classorg.apache.flume.instrumentationFlumejavadoc
MonitorServiceInterface that any monitoring service should implement.Interfaceorg.apache.flume.instrumentationFlumejavadoc
MorphlineHandlerInterfaceorg.apache.flume.sink.solr.morphlineFlumejavadoc
MorphlineHandlerImplA MorphlineHandler that processes it's events using a morphline Command chain.Classorg.apache.flume.sink.solr.morphlineFlumejavadoc
MorphlineInterceptorFlume Interceptor that executes a morphline on events that are intercepted.Classorg.apache.flume.sink.solr.morphlineFlumejavadoc
MorphlineSinkClassorg.apache.flume.sink.solr.morphlineFlumejavadoc
MorphlineSolrSinkFlume sink that extracts search documents from Flume events, processes them using a morphline Command chain, and loads them into Apache Solr.Classorg.apache.flume.sink.solr.morphlineFlumejavadoc
MultiplexingChannelSelectorClassorg.apache.flume.channelFlumejavadoc
MultiportSyslogTCPSourceClassorg.apache.flume.sourceFlumejavadoc
MySQLSchemaHandlerClassorg.apache.flume.channel.jdbc.implFlumejavadoc
NamedComponentEnables a component to be tagged with a name so that it can be referred to uniquely within the configuration system.Interfaceorg.apache.flumeFlumejavadoc
NetcatSource A netcat-like source that listens on a given port and turns each line of text This source, primarily built for testing and exceedingly simple systems, actsClassorg.apache.flume.sourceFlumejavadoc
NetcatSourceConfigurationConstantsClassorg.apache.flume.sourceFlumejavadoc
NettyAvroRpcClientAvro/Netty implementation of RpcClient.Classorg.apache.flume.apiFlumejavadoc
NoopRecordExceptionSee Also:Serialized FormConstructor SummaryNoopRecordException()Classorg.apache.flume.channel.fileFlumejavadoc
NullSink A Sink implementation that simply discards all events it receives.Classorg.apache.flume.sinkFlumejavadoc
OrderSelectorA basic implementation of an order selector that implements a simple exponential backoff algorithm.Classorg.apache.flume.utilFlumejavadoc
PathManagerClassorg.apache.flume.formatter.outputFlumejavadoc
PersistableEventClassorg.apache.flume.channel.jdbc.implFlumejavadoc
PlatformDetectUtilities for platform & operating system detectionConstructor SummaryPlatformDetect()Classorg.apache.flume.toolsFlumejavadoc
PollableSourceA Source that requires an external driver to poll to determine whether there are events that are available to ingestInterfaceorg.apache.flumeFlumejavadoc
PollableSourceRunner An implementation of SourceRunner that can drive a A PollableSourceRunner wraps a PollableSource in the requiredClassorg.apache.flume.sourceFlumejavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

PollingPropertiesFileConfigurationProviderClassorg.apache.flume.nodeFlumejavadoc
PositionTrackerDefines an interface for tracking the offset position in a target file.Interfaceorg.apache.flume.serializationFlumejavadoc
Priorityenum Priorityextends Enumimplements org.Classcom.cloudera.flume.handlers.thriftFlumejavadoc
PropertiesFileConfigurationProvider A configuration provider that uses properties file for specifying configuration.Classorg.apache.flume.nodeFlumejavadoc
ProtosFactoryClassorg.apache.flume.channel.file.protoFlumejavadoc
PseudoTxnMemoryChannel A capacity-capped Channel implementation that supports in-memory buffering and delivery of events.Classorg.apache.flume.channelFlumejavadoc
RandomOrderSelectorAn implementation of OrderSelector which returns objects in random order.Classorg.apache.flume.utilFlumejavadoc
RegexExtractorInterceptorInterceptor that extracts matches using a specified regular expression and appends the matches to the event headers using the specified serializersClassorg.apache.flume.interceptorFlumejavadoc
RegexExtractorInterceptorMillisSerializerSerializer that converts the passed in value into milliseconds using the specified formatting patternClassorg.apache.flume.interceptorFlumejavadoc
RegexExtractorInterceptorPassThroughSerializerSerializer that simply returns the passed in valueConstructor SummaryRegexExtractorInterceptorPassThroughSerializer()Classorg.apache.flume.interceptorFlumejavadoc
RegexExtractorInterceptorSerializerSerializer for serializing groups matched by the RegexExtractorInterceptorInterfaceorg.apache.flume.interceptorFlumejavadoc
RegexFilteringInterceptorInterceptor that filters events selectively based on a configured regular expression matching against the event body.Classorg.apache.flume.interceptorFlumejavadoc
RegexHbaseEventSerializerAn HbaseEventSerializer which parses columns based on a supplied regular expression and column name list.Classorg.apache.flume.sink.hbaseFlumejavadoc
ReliableEventReaderA reliable event reader.Interfaceorg.apache.flume.client.avroFlumejavadoc
ReliableSpoolingFileEventReaderA ReliableEventReader which reads log data from files stored in a spooling directory and renames each file once all of its data has beenClassorg.apache.flume.client.avroFlumejavadoc
RemoteMarkableInterfaceorg.apache.flume.serializationFlumejavadoc
ReplicatingChannelSelectorReplicating channel selector.Classorg.apache.flume.channelFlumejavadoc
ResettableDefines an API for objects that can be mark()ed and reset() on arbitrary boundaries.Interfaceorg.apache.flume.serializationFlumejavadoc
ResettableFileInputStreamThis class makes the following assumptions: The underlying file is not changing while it is being readClassorg.apache.flume.serializationFlumejavadoc
ResettableInputStream This abstract class defines an interface for which the stream may be marked and reset with no limit toClassorg.apache.flume.serializationFlumejavadoc
ResultCodeenum ResultCodeextends Enumimplements org.Classorg.apache.flume.source.scribeFlumejavadoc
RollingFileSinkNested Class SummaryNested classes/interfaces inherited from interface org.Classorg.apache.flume.sinkFlumejavadoc
RoundRobinListClassorg.apache.flume.sink.elasticsearch.clientFlumejavadoc
RoundRobinOrderSelectorAn implementation of OrderSelector which returns objects in round robin order.Classorg.apache.flume.utilFlumejavadoc
RpcClientPublic client interface for sending data to Flume.Interfaceorg.apache.flume.apiFlumejavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

RpcClientConfigurationConstantsConfiguration constants used by the RpcClient.Classorg.apache.flume.apiFlumejavadoc
RpcClientFactoryFactory class to construct Flume RPCClient implementations.Classorg.apache.flume.apiFlumejavadoc
SchemaHandlerA handler for creating and validating database schema for use by the JDBC channel implementation.Interfaceorg.apache.flume.channel.jdbc.implFlumejavadoc
SchemaHandlerFactoryA factory for SchemaHandlers.Classorg.apache.flume.channel.jdbc.implFlumejavadoc
ScribeClassorg.apache.flume.source.scribeFlumejavadoc
ScribeSourceFlume should adopt the Scribe entry LogEntry from existing Scribe system.Classorg.apache.flume.source.scribeFlumejavadoc
SeekableInterfaceorg.apache.flume.serializationFlumejavadoc
SequenceFileSerializerInterfaceorg.apache.flume.sink.hdfsFlumejavadoc
SequenceFileSerializerFactoryConstructor SummarySequenceFileSerializerFactory()Methods inherited from class java.Classorg.apache.flume.sink.hdfsFlumejavadoc
SequenceFileSerializerTypeenum SequenceFileSerializerTypeextends EnumEnum Constant SummaryOtherClassorg.apache.flume.sink.hdfsFlumejavadoc
SequenceGeneratorSourceNested Class SummaryNested classes/interfaces inherited from interface org.Classorg.apache.flume.sourceFlumejavadoc
SerializationClassorg.apache.flume.channel.fileFlumejavadoc
SimpleAsyncHbaseEventSerializerA simple serializer to be used with the AsyncHBaseSink that returns puts from an event, by writing the eventClassorg.apache.flume.sink.hbaseFlumejavadoc
SimpleEventClassorg.apache.flume.eventFlumejavadoc
SimpleHbaseEventSerializerA simple serializer that returns puts from an event, by writing the event body into it.Classorg.apache.flume.sink.hbaseFlumejavadoc
SimpleIndexNameBuilderClassorg.apache.flume.sink.elasticsearchFlumejavadoc
SimpleMaterializedConfigurationClassorg.apache.flume.nodeFlumejavadoc
SimpleRowKeyGeneratorUtility class for users to generate their own keys.Classorg.apache.flume.sink.hbaseFlumejavadoc
SimpleTextLineEventReaderClassorg.apache.flume.client.avroFlumejavadoc
Sink A sink is connected to a Channel and consumes its contents, sending them to a configured destination that may vary according toInterfaceorg.apache.flumeFlumejavadoc
SinkConfigurationClassorg.apache.flume.conf.sinkFlumejavadoc
SinkCounterNested Class SummaryNested classes/interfaces inherited from class org.Classorg.apache.flume.instrumentationFlumejavadoc
SinkCounterMBeanThis interface represents a sink counter mbean.Interfaceorg.apache.flume.instrumentationFlumejavadoc
SinkFactoryInterfaceorg.apache.flumeFlumejavadoc
SinkGroupConfiguration concept for handling multiple sinks working together.Classorg.apache.flume.sinkFlumejavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

SinkGroupConfigurationNested Class SummaryNested classes/interfaces inherited from class org.Classorg.apache.flume.conf.sinkFlumejavadoc
SinkProcessor Interface for a device that allows abstraction of the behavior of multiple sinks, always assigned to a SinkRunnerInterfaceorg.apache.flumeFlumejavadoc
SinkProcessorConfigurationClassorg.apache.flume.conf.sinkFlumejavadoc
SinkProcessorCounterNested Class SummaryNested classes/interfaces inherited from class org.Classorg.apache.flume.instrumentationFlumejavadoc
SinkProcessorFactoryClassorg.apache.flume.sinkFlumejavadoc
SinkProcessorTypeenum SinkProcessorTypeextends EnumEnum Constant SummaryDEFAULTClassorg.apache.flume.conf.sinkFlumejavadoc
SinkRunner A driver for sinks that polls them, attempting to process events if any are available in theClassorg.apache.flumeFlumejavadoc
SinkTypeenum SinkTypeextends EnumEnumeration of built in sink types available in the system.Classorg.apache.flume.conf.sinkFlumejavadoc
Source A source generates and calls methods on the configured ChannelProcessor to persist those events into theInterfaceorg.apache.flumeFlumejavadoc
SourceConfigurationClassorg.apache.flume.conf.sourceFlumejavadoc
SourceCounterNested Class SummaryNested classes/interfaces inherited from class org.Classorg.apache.flume.instrumentationFlumejavadoc
SourceCounterMBeanThis interface represents a source counter mbean.Interfaceorg.apache.flume.instrumentationFlumejavadoc
SourceFactoryInterfaceorg.apache.flumeFlumejavadoc
SourceRunnerA source runner controls how a source is driven.Classorg.apache.flumeFlumejavadoc
SourceTypeenum SourceTypeextends EnumEnumeration of built in source types available in the system.Classorg.apache.flume.conf.sourceFlumejavadoc
SpecificOrderIteratorA utility class that iterates over the given ordered list of items via the specified order array.Classorg.apache.flume.utilFlumejavadoc
SpillableMemoryChannel SpillableMemoryChannel will use main memory for buffering events until it has reached capacity.Classorg.apache.flume.channelFlumejavadoc
SpoolDirectorySourceClassorg.apache.flume.sourceFlumejavadoc
SpoolDirectorySourceConfigurationConstantsClassorg.apache.flume.sourceFlumejavadoc
StaticInterceptorInterceptor class that appends a static, pre-configured header to all events.Classorg.apache.flume.interceptorFlumejavadoc
Statusenum Statusextends Enumimplements org.Classorg.apache.flume.thriftFlumejavadoc
StressSourceInternal load-generating source implementation.Classorg.apache.flume.sourceFlumejavadoc
SyslogParserClassorg.apache.flume.sourceFlumejavadoc
SyslogSourceConfigurationConstantsClassorg.apache.flume.sourceFlumejavadoc
SyslogTcpSourceClassorg.apache.flume.sourceFlumejavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

SyslogUDPSourceClassorg.apache.flume.sourceFlumejavadoc
SyslogUtilsClassorg.apache.flume.sourceFlumejavadoc
SystemClockDefault implementation of Clock which uses SystemConstructor SummarySystemClock()Classorg.apache.flumeFlumejavadoc
TextDelimitedOutputFormatterClassorg.apache.flume.formatter.outputFlumejavadoc
ThriftFlumeEventClasscom.cloudera.flume.handlers.thriftFlumejavadoc
ThriftFlumeEventClassorg.apache.flume.thriftFlumejavadoc
ThriftFlumeEventServerClasscom.cloudera.flume.handlers.thriftFlumejavadoc
ThriftLegacySourceClassorg.apache.flume.source.thriftLegacyFlumejavadoc
ThriftRpcClientFields inherited from class org.Classorg.apache.flume.apiFlumejavadoc
ThriftSink A Sink implementation that can send events to an RPC server (such as Flume's ThriftSource).Classorg.apache.flume.sinkFlumejavadoc
ThriftSourceClassorg.apache.flume.sourceFlumejavadoc
ThriftSourceProtocolClassorg.apache.flume.thriftFlumejavadoc
TimeBasedIndexNameBuilderDefault index name builder.Classorg.apache.flume.sink.elasticsearchFlumejavadoc
TimestampInterceptorSimple Interceptor class that sets the current system timestamp on all events that are intercepted.Classorg.apache.flume.interceptorFlumejavadoc
TimestampRoundDownUtilClassorg.apache.flume.toolsFlumejavadoc
TransactionProvides the transaction boundary while accessing a channel.Interfaceorg.apache.flumeFlumejavadoc
TransactionEventRecordClassorg.apache.flume.channel.fileFlumejavadoc
TransactionIDOracleClassorg.apache.flume.channel.fileFlumejavadoc
TransactionIsolationenum TransactionIsolationextends EnumEnum Constant SummaryREAD_COMMITTEDClassorg.apache.flume.channel.jdbcFlumejavadoc
TwitterSourceDemo Flume source that connects via Streaming API to the 1% sample twitter firehose, continously downloads tweets, converts them to Avro format andClassorg.apache.flume.source.twitterFlumejavadoc
UUIDInterceptorFlume Interceptor that sets a universally unique identifier on all events that are intercepted.Classorg.apache.flume.sink.solr.morphlineFlumejavadoc
VersionAnnotationThis class is about package attribute that captures version info of Flume that was compiled.Classorg.apache.flumeFlumejavadoc
VersionInfoClassorg.apache.flume.toolsFlumejavadoc
WriteOrderOracleClassorg.apache.flume.channel.fileFlumejavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner



comments powered by Disqus