| Modifier and Type | Method and Description | 
|---|---|
void | 
EmbeddedSource.configure(Context context)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
SpillableMemoryChannel.configure(Context context)
Read parameters from context
 memoryCapacity = total number of events allowed at one time in the memory queue. 
 | 
void | 
MultiplexingChannelSelector.configure(Context context)  | 
void | 
ReplicatingChannelSelector.configure(Context context)  | 
void | 
ChannelProcessor.configure(Context context)
The Context of the associated Source is passed. 
 | 
void | 
LoadBalancingChannelSelector.configure(Context context)  | 
void | 
MemoryChannel.configure(Context context)
Read parameters from context
 capacity = type long that defines the total number of events allowed at one time in the queue. 
 | 
void | 
PseudoTxnMemoryChannel.configure(Context context)  | 
void | 
AbstractChannel.configure(Context context)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
FileChannel.configure(Context context)  | 
| Modifier and Type | Method and Description | 
|---|---|
KeyProvider | 
JCEFileKeyProvider.Builder.build(Context context)  | 
KeyProvider | 
KeyProvider.Builder.build(Context context)  | 
static KeyProvider | 
KeyProviderFactory.getInstance(String keyProviderType,
           Context context)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
JdbcChannel.configure(Context context)  | 
static JdbcChannelProvider | 
JdbcChannelProviderFactory.getProvider(Context context,
           String name)  | 
void | 
JdbcChannelProvider.initialize(Context context)
Initializes the channel provider. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
JdbcChannelProviderImpl.initialize(Context context)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
KafkaChannel.configure(Context ctx)  | 
| Modifier and Type | Method and Description | 
|---|---|
ReliableSpoolingFileEventReader.Builder | 
ReliableSpoolingFileEventReader.Builder.deserializerContext(Context deserializerContext)  | 
| Modifier and Type | Method and Description | 
|---|---|
Map<String,Context> | 
FlumeConfiguration.AgentConfiguration.getChannelContext()  | 
Map<String,Context> | 
FlumeConfiguration.AgentConfiguration.getConfigFilterContext()  | 
Map<String,Context> | 
FlumeConfiguration.AgentConfiguration.getSinkContext()  | 
Map<String,Context> | 
FlumeConfiguration.AgentConfiguration.getSourceContext()  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
Configurable.configure(Context context)
 Request the implementing class to (re)configure itself. 
 | 
void | 
ComponentConfiguration.configure(Context context)  | 
static boolean | 
Configurables.configure(Object target,
         Context context)
Check that  
target implements Configurable and, if so, ask
 it to configure itself using the supplied context. | 
static void | 
Configurables.ensureOptionalNonNull(Context context,
                     String... keys)  | 
static void | 
Configurables.ensureRequiredNonNull(Context context,
                     String... keys)  | 
| Modifier and Type | Method and Description | 
|---|---|
Context | 
SinkGroupConfiguration.getProcessorContext()  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
SinkGroupConfiguration.configure(Context context)  | 
void | 
SinkConfiguration.configure(Context context)  | 
void | 
SinkProcessorConfiguration.configure(Context context)  | 
void | 
SinkGroupConfiguration.setProcessorContext(Context processorContext)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
SourceConfiguration.configure(Context context)  | 
| Modifier and Type | Method and Description | 
|---|---|
PathManager | 
PathManager.Builder.build(Context context)  | 
PathManager | 
RollTimePathManager.Builder.build(Context context)  | 
PathManager | 
DefaultPathManager.Builder.build(Context context)  | 
static PathManager | 
PathManagerFactory.getInstance(String managerType,
           Context context)  | 
| Constructor and Description | 
|---|
DefaultPathManager(Context context)  | 
RollTimePathManager(Context context)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
GangliaServer.configure(Context context)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
HTTPMetricsServer.configure(Context context)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
SearchAndReplaceInterceptor.Builder.configure(Context context)  | 
void | 
RegexExtractorInterceptor.Builder.configure(Context context)  | 
void | 
HostInterceptor.Builder.configure(Context context)  | 
void | 
TimestampInterceptor.Builder.configure(Context context)  | 
void | 
RemoveHeaderInterceptor.Builder.configure(Context context)  | 
void | 
RegexExtractorInterceptorPassThroughSerializer.configure(Context context)  | 
void | 
StaticInterceptor.Builder.configure(Context context)  | 
void | 
RegexExtractorInterceptorMillisSerializer.configure(Context context)  | 
void | 
RegexFilteringInterceptor.Builder.configure(Context context)  | 
| Modifier and Type | Method and Description | 
|---|---|
EventSerializer | 
HeaderAndBodyTextEventSerializer.Builder.build(Context context,
     OutputStream out)  | 
EventSerializer | 
FlumeEventAvroEventSerializer.Builder.build(Context context,
     OutputStream out)  | 
EventSerializer | 
BodyTextEventSerializer.Builder.build(Context context,
     OutputStream out)  | 
EventSerializer | 
EventSerializer.Builder.build(Context context,
     OutputStream out)  | 
EventDeserializer | 
LineDeserializer.Builder.build(Context context,
     ResettableInputStream in)  | 
EventDeserializer | 
EventDeserializer.Builder.build(Context context,
     ResettableInputStream in)  | 
EventDeserializer | 
AvroEventDeserializer.Builder.build(Context context,
     ResettableInputStream in)  | 
EventSerDe | 
EventSerDe.Builder.build(Context context,
     ResettableInputStream in,
     OutputStream out)  | 
void | 
AbstractAvroEventSerializer.configure(Context context)  | 
static EventSerializer | 
EventSerializerFactory.getInstance(String serializerType,
           Context context,
           OutputStream out)  | 
static EventDeserializer | 
EventDeserializerFactory.getInstance(String deserializerType,
           Context context,
           ResettableInputStream in)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
LoggerSink.configure(Context context)  | 
void | 
SinkGroup.configure(Context context)  | 
void | 
DefaultSinkProcessor.configure(Context context)  | 
void | 
AbstractSinkSelector.configure(Context context)  | 
void | 
FailoverSinkProcessor.configure(Context context)  | 
void | 
LoadBalancingSinkProcessor.configure(Context context)  | 
void | 
RollingFileSink.configure(Context context)  | 
void | 
NullSink.configure(Context context)  | 
void | 
AbstractRpcSink.configure(Context context)  | 
static SinkProcessor | 
SinkProcessorFactory.getProcessor(Context context,
            List<Sink> sinks)
 Creates a sink processor and configures it using the provided context 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
SimpleAsyncHbaseEventSerializer.configure(Context context)  | 
void | 
RegexHbaseEventSerializer.configure(Context context)  | 
void | 
HBaseSink.configure(Context context)  | 
void | 
AsyncHBaseSink.configure(Context context)  | 
void | 
SimpleHbaseEventSerializer.configure(Context context)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
SimpleHBase2EventSerializer.configure(Context context)  | 
void | 
HBase2Sink.configure(Context context)  | 
void | 
RegexHBase2EventSerializer.configure(Context context)  | 
| Modifier and Type | Method and Description | 
|---|---|
SequenceFileSerializer | 
SequenceFileSerializer.Builder.build(Context context)  | 
SequenceFileSerializer | 
HDFSTextSerializer.Builder.build(Context context)  | 
SequenceFileSerializer | 
HDFSWritableSerializer.Builder.build(Context context)  | 
EventSerializer | 
AvroEventSerializer.Builder.build(Context context,
     OutputStream out)  | 
void | 
HDFSSequenceFile.configure(Context context)  | 
void | 
HDFSDataStream.configure(Context context)  | 
void | 
AbstractHDFSWriter.configure(Context context)  | 
void | 
AvroEventSerializer.configure(Context context)  | 
void | 
HDFSCompressedDataStream.configure(Context context)  | 
void | 
HDFSEventSink.configure(Context context)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
HiveDelimitedTextSerializer.configure(Context context)  | 
void | 
HiveSink.configure(Context context)  | 
void | 
HiveJsonSerializer.configure(Context context)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
HttpSink.configure(Context context)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
IRCSink.configure(Context context)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
KafkaSink.configure(Context context)
We configure the sink and generate properties for the Kafka Producer
 Kafka producer properties is generated as follows:
 1. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
BlobDeserializer | 
BlobDeserializer.Builder.build(Context context,
     ResettableInputStream in)  | 
void | 
MorphlineSolrSink.configure(Context context)  | 
void | 
MorphlineSink.configure(Context context)  | 
void | 
MorphlineInterceptor.Builder.configure(Context context)  | 
void | 
BlobHandler.configure(Context context)  | 
void | 
MorphlineHandlerImpl.configure(Context context)  | 
void | 
UUIDInterceptor.Builder.configure(Context context)  | 
| Constructor and Description | 
|---|
BlobDeserializer(Context context,
                ResettableInputStream in)  | 
MorphlineInterceptor(Context context)  | 
UUIDInterceptor(Context context)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
SpoolDirectorySource.configure(Context context)  | 
void | 
NetcatSource.configure(Context context)  | 
void | 
MultiportSyslogTCPSource.configure(Context context)  | 
void | 
AvroSource.configure(Context context)  | 
void | 
SyslogTcpSource.configure(Context context)
Deprecated.  
  | 
void | 
NetcatUdpSource.configure(Context context)  | 
void | 
BasicSourceSemantics.configure(Context context)  | 
void | 
ExecSource.configure(Context context)  | 
void | 
SyslogUDPSource.configure(Context context)  | 
void | 
ThriftSource.configure(Context context)  | 
void | 
AbstractPollableSource.configure(Context context)  | 
protected void | 
SslContextAwareAbstractSource.configureSsl(Context context)  | 
protected void | 
StressSource.doConfigure(Context context)
Read parameters from context
 -maxTotalEvents = type long that defines the total number of Events to be sent
 -maxSuccessfulEvents = type long that defines the number of successful Events
 -size = type int that defines the number of bytes in each Event
 -batchSize = type int that defines the number of Events being sent in one batch 
 | 
protected abstract void | 
BasicSourceSemantics.doConfigure(Context context)  | 
protected void | 
SequenceGeneratorSource.doConfigure(Context context)
Read parameters from context
 batchSize = type int that defines the size of event batches 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
AvroLegacySource.configure(Context context)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
JSONHandler.configure(Context context)  | 
void | 
BLOBHandler.configure(Context context)  | 
void | 
HTTPSource.configure(Context context)  | 
protected void | 
HTTPSource.configureSsl(Context context)  | 
| Modifier and Type | Method and Description | 
|---|---|
JMSMessageConverter | 
JMSMessageConverter.Builder.build(Context context)  | 
JMSMessageConverter | 
DefaultJMSMessageConverter.Builder.build(Context context)  | 
protected void | 
JMSSource.doConfigure(Context context)  | 
| Modifier and Type | Method and Description | 
|---|---|
protected void | 
KafkaSource.doConfigure(Context context)
We configure the source and generate properties for the Kafka Consumer
 Kafka Consumer properties are generated as follows:
 1. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
ScribeSource.configure(Context context)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
TaildirSource.configure(Context context)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
ThriftLegacySource.configure(Context context)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
TwitterSource.configure(Context context)  | 
| Modifier and Type | Method and Description | 
|---|---|
static void | 
FlumeBeanConfigurator.setConfigurationFields(Object configurable,
                      Context context)
Utility method that will set properties on a Java bean ( 
Object configurable)
 based on the provided Context. | 
static void | 
FlumeBeanConfigurator.setConfigurationFields(Object configurable,
                      Context context,
                      String subPropertiesPrefix)
Utility method that will set properties on a Java bean ( 
Object configurable)
 based on the provided Context. | 
Copyright © 2009-2022 Apache Software Foundation. All Rights Reserved.