Search Java Classes and Packages
#Org.apache.flume.source Classes and Interfaces - 65 results found.
| Name | Description | Type | Package | Framework |
| AbstractEventDrivenSource | Base class which ensures sub-classes will inherit all the properties of BasicSourceSemantics. | Class | org.apache.flume.source | Flume |
| AbstractPollableSource | Base class which ensures sub-classes will inherit all the properties of BasicSourceSemantics in addition to: | Class | org.apache.flume.source | Flume |
| AbstractSource | Class | org.apache.flume.source | Flume | |
| AvroLegacySource | A Source implementation that receives Avro events from Avro sink of Configuration options | Class | org.apache.flume.source.avroLegacy | Flume |
| AvroSource | A Source implementation that receives Avro events from clients that implement AvroSourceProtocol. | Class | org.apache.flume.source | Flume |
| BasicSourceSemantics | Alternative 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. | Class | org.apache.flume.source | Flume |
| DefaultJMSMessageConverter | Converts BytesMessage, TextMessage, and ObjectMessage to a Flume Event. | Class | org.apache.flume.source.jms | Flume |
| DefaultJMSMessageConverter .Builder | Constructor SummaryDefaultJMSMessageConverter. | Class | org.apache.flume.source.jms.DefaultJMSMessageConverter | Flume |
| DefaultSourceFactory | Class | org.apache.flume.source | Flume | |
| EventDrivenSourceRunner | Starts, stops, and manages event-driven sources. | Class | org.apache.flume.source | Flume |
| ExecSource | A Source implementation that executes a Unix process and turns each line of text into an event. | Class | org.apache.flume.source | Flume |
| ExecSourceConfigurationConstants | Class | org.apache.flume.source | Flume | |
| HTTPBadRequestException | Exception thrown by an HTTP Handler if the request was not parsed correctly into an event because the request was not in the expected format. | Class | org.apache.flume.source.http | Flume |
| HTTPSource | A source which accepts Flume Events by HTTP POST and GET. | Class | org.apache.flume.source.http | Flume |
| HTTPSourceConfigurationConstants | Class | org.apache.flume.source.http | Flume | |
| HTTPSourceHandler | Interface | org.apache.flume.source.http | Flume | |
| InitialContextFactory | Class | org.apache.flume.source.jms | Flume | |
| JMSDestinationLocator | enum JMSDestinationLocatorextends Enum | Class | org.apache.flume.source.jms | Flume |
| JMSDestinationType | enum JMSDestinationTypeextends Enum | Class | org.apache.flume.source.jms | Flume |
| JMSMessageConsumerFactory | Constructor SummaryJMSMessageConsumerFactory()Methods inherited from class java. | Class | org.apache.flume.source.jms | Flume |
| JMSMessageConverter | Converts a JMS Message to an Event. | Interface | org.apache.flume.source.jms | Flume |
| JMSMessageConverter .Builder | a suitable builder or implement the Configurable interface. | Interface | org.apache.flume.source.jms.JMSMessageConverter | Flume |
| JMSSource | Nested Class SummaryNested classes/interfaces inherited from interface org. | Class | org.apache.flume.source.jms | Flume |
| JMSSourceConfiguration | Class | org.apache.flume.source.jms | Flume | |
| JSONHandler | JSONHandler for HTTPSource that accepts an array of events. | Class | org.apache.flume.source.http | Flume |
| LogEntry | Class | org.apache.flume.source.scribe | Flume | |
| LogEntry ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | org.apache.flume.source.scribe.LogEntry | Flume |
| MultiportSyslogTCPSource | Class | org.apache.flume.source | Flume | |
| 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, acts | Class | org.apache.flume.source | Flume |
| NetcatSourceConfigurationConstants | Class | org.apache.flume.source | Flume | |
| PollableSourceRunner | An implementation of SourceRunner that can drive a A PollableSourceRunner wraps a PollableSource in the required | Class | org.apache.flume.source | Flume |
| PollableSourceRunner .PollingRunner | Constructor SummaryPollableSourceRunner. | Class | org.apache.flume.source.PollableSourceRunner | Flume |
| ResultCode | enum ResultCodeextends Enum | Class | org.apache.flume.source.scribe | Flume |
| Scribe | Class | org.apache.flume.source.scribe | Flume | |
| Scribe .AsyncClient | Class | org.apache.flume.source.scribe.Scribe | Flume | |
| Scribe .AsyncClient .Factory | Constructor SummaryScribe. | Class | org.apache.flume.source.scribe.Scribe.AsyncClient | Flume |
| Scribe .AsyncClient .Log_call | Nested Class SummaryNested classes/interfaces inherited from class org. | Class | org.apache.flume.source.scribe.Scribe.AsyncClient | Flume |
| Scribe .AsyncIface | Interface | org.apache.flume.source.scribe.Scribe | Flume | |
| Scribe .Client | Class | org.apache.flume.source.scribe.Scribe | Flume | |
| Scribe .Client .Factory | Constructor SummaryScribe. | Class | org.apache.flume.source.scribe.Scribe.Client | Flume |
| Scribe .Iface | Interface | org.apache.flume.source.scribe.Scribe | Flume | |
| Scribe .Log_args | Class | org.apache.flume.source.scribe.Scribe | Flume | |
| Scribe .Log_args ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | org.apache.flume.source.scribe.Scribe.Log_args | Flume |
| Scribe .Log_result | Class | org.apache.flume.source.scribe.Scribe | Flume | |
| Scribe .Log_result ._Fields | The set of fields this struct contains, along with convenience methods for finding and manipulating them. | Class | org.apache.flume.source.scribe.Scribe.Log_result | Flume |
| Scribe .Processor | Class | org.apache.flume.source.scribe.Scribe | Flume | |
| ScribeSource | Flume should adopt the Scribe entry LogEntry from existing Scribe system. | Class | org.apache.flume.source.scribe | Flume |
| SequenceGeneratorSource | Nested Class SummaryNested classes/interfaces inherited from interface org. | Class | org.apache.flume.source | Flume |
| Source | A source generates and calls methods on the configured ChannelProcessor to persist those events into the | Interface | org.apache.flume | Flume |
| SourceFactory | Interface | org.apache.flume | Flume | |
| SourceRunner | A source runner controls how a source is driven. | Class | org.apache.flume | Flume |
| SpoolDirectorySource | Class | org.apache.flume.source | Flume | |
| SpoolDirectorySourceConfigurationConstants | Class | org.apache.flume.source | Flume | |
| SpoolDirectorySourceConfigurationConstants .ConsumeOrder | Class | org.apache.flume.source.SpoolDirectorySourceConfigurationConstants | Flume | |
| StressSource | Internal load-generating source implementation. | Class | org.apache.flume.source | Flume |
| SyslogParser | Class | org.apache.flume.source | Flume | |
| SyslogSourceConfigurationConstants | Class | org.apache.flume.source | Flume | |
| SyslogTcpSource | Class | org.apache.flume.source | Flume | |
| SyslogUDPSource | Class | org.apache.flume.source | Flume | |
| SyslogUtils | Class | org.apache.flume.source | Flume | |
| SyslogUtils .SyslogStatus | Class | org.apache.flume.source.SyslogUtils | Flume | |
| ThriftLegacySource | Class | org.apache.flume.source.thriftLegacy | Flume | |
| ThriftLegacySource .ThriftHandler | Constructor SummaryThriftLegacySource. | Class | org.apache.flume.source.thriftLegacy.ThriftLegacySource | Flume |
| ThriftSource | Class | org.apache.flume.source | Flume | |
| TwitterSource | Demo Flume source that connects via Streaming API to the 1% sample twitter firehose, continously downloads tweets, converts them to Avro format and | Class | org.apache.flume.source.twitter | Flume |