Uses of Class
org.apache.flume.Context

Packages that use Context

Package	Description
org.apache.flume.agent.embedded	This package provides Flume users the ability to embed simple agents in applications.
org.apache.flume.channel
org.apache.flume.channel.file
org.apache.flume.channel.file.encryption
org.apache.flume.channel.jdbc
org.apache.flume.channel.jdbc.impl
org.apache.flume.channel.kafka
org.apache.flume.client.avro
org.apache.flume.conf
org.apache.flume.conf.sink
org.apache.flume.conf.source
org.apache.flume.formatter.output
org.apache.flume.instrumentation
org.apache.flume.instrumentation.http
org.apache.flume.interceptor
org.apache.flume.serialization
org.apache.flume.sink
org.apache.flume.sink.hbase2
org.apache.flume.sink.hdfs
org.apache.flume.sink.hive
org.apache.flume.sink.http	This package provides an HTTP sink for Flume so that events can be sent out to a target HTTP endpoint.
org.apache.flume.sink.irc
org.apache.flume.sink.kafka
org.apache.flume.sink.kite
org.apache.flume.sink.kite.parser
org.apache.flume.sink.kite.policy
org.apache.flume.sink.solr.morphline
org.apache.flume.source
org.apache.flume.source.avroLegacy
org.apache.flume.source.http
org.apache.flume.source.jms
org.apache.flume.source.kafka
org.apache.flume.source.scribe
org.apache.flume.source.taildir
org.apache.flume.source.thriftLegacy
org.apache.flume.source.twitter
org.apache.flume.tools

Uses of Context in org.apache.flume.agent.embedded

Methods in org.apache.flume.agent.embedded with parameters of type Context

Modifier and Type	Method and Description
void	EmbeddedSource.configure(Context context)

Uses of Context in org.apache.flume.channel

Methods in org.apache.flume.channel with parameters of type 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	ReplicatingChannelSelector.configure(Context context)
void	MultiplexingChannelSelector.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)
void	ChannelProcessor.configure(Context context) The Context of the associated Source is passed.

Uses of Context in org.apache.flume.channel.file

Methods in org.apache.flume.channel.file with parameters of type Context

Modifier and Type	Method and Description
void	FileChannel.configure(Context context)

Uses of Context in org.apache.flume.channel.file.encryption

Methods in org.apache.flume.channel.file.encryption with parameters of type 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)

Uses of Context in org.apache.flume.channel.jdbc

Methods in org.apache.flume.channel.jdbc with parameters of type 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.

Uses of Context in org.apache.flume.channel.jdbc.impl

Methods in org.apache.flume.channel.jdbc.impl with parameters of type Context

Modifier and Type	Method and Description
void	JdbcChannelProviderImpl.initialize(Context context)

Uses of Context in org.apache.flume.channel.kafka

Methods in org.apache.flume.channel.kafka with parameters of type Context

Modifier and Type	Method and Description
void	KafkaChannel.configure(Context ctx)

Uses of Context in org.apache.flume.client.avro

Methods in org.apache.flume.client.avro with parameters of type Context

Modifier and Type	Method and Description
ReliableSpoolingFileEventReader.Builder	ReliableSpoolingFileEventReader.Builder.deserializerContext(Context deserializerContext)

Uses of Context in org.apache.flume.conf

Methods in org.apache.flume.conf that return types with arguments of type Context

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()

Methods in org.apache.flume.conf with parameters of type Context

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)

Uses of Context in org.apache.flume.conf.sink

Methods in org.apache.flume.conf.sink that return Context

Modifier and Type	Method and Description
Context	SinkGroupConfiguration.getProcessorContext()

Methods in org.apache.flume.conf.sink with parameters of type Context

Modifier and Type	Method and Description
void	SinkGroupConfiguration.configure(Context context)
void	SinkProcessorConfiguration.configure(Context context)
void	SinkConfiguration.configure(Context context)
void	SinkGroupConfiguration.setProcessorContext(Context processorContext)

Uses of Context in org.apache.flume.conf.source

Methods in org.apache.flume.conf.source with parameters of type Context

Modifier and Type	Method and Description
void	SourceConfiguration.configure(Context context)

Uses of Context in org.apache.flume.formatter.output

Methods in org.apache.flume.formatter.output with parameters of type Context

Modifier and Type	Method and Description
PathManager	DefaultPathManager.Builder.build(Context context)
PathManager	RollTimePathManager.Builder.build(Context context)
PathManager	PathManager.Builder.build(Context context)
static PathManager	PathManagerFactory.getInstance(String managerType, Context context)

Constructors in org.apache.flume.formatter.output with parameters of type Context

Constructor and Description
DefaultPathManager(Context context)
RollTimePathManager(Context context)

Uses of Context in org.apache.flume.instrumentation

Methods in org.apache.flume.instrumentation with parameters of type Context

Modifier and Type	Method and Description
void	GangliaServer.configure(Context context)

Uses of Context in org.apache.flume.instrumentation.http

Methods in org.apache.flume.instrumentation.http with parameters of type Context

Modifier and Type	Method and Description
void	HTTPMetricsServer.configure(Context context)

Uses of Context in org.apache.flume.interceptor

Methods in org.apache.flume.interceptor with parameters of type Context

Modifier and Type	Method and Description
void	RegexExtractorInterceptor.Builder.configure(Context context)
void	RemoveHeaderInterceptor.Builder.configure(Context context)
void	RegexExtractorInterceptorPassThroughSerializer.configure(Context context)
void	TimestampInterceptor.Builder.configure(Context context)
void	StaticInterceptor.Builder.configure(Context context)
void	SearchAndReplaceInterceptor.Builder.configure(Context context)
void	HostInterceptor.Builder.configure(Context context)
void	RegexFilteringInterceptor.Builder.configure(Context context)
void	RegexExtractorInterceptorMillisSerializer.configure(Context context)

Uses of Context in org.apache.flume.serialization

Methods in org.apache.flume.serialization with parameters of type Context

Modifier and Type	Method and Description
EventSerializer	FlumeEventAvroEventSerializer.Builder.build(Context context, OutputStream out)
EventSerializer	HeaderAndBodyTextEventSerializer.Builder.build(Context context, OutputStream out)
EventSerializer	EventSerializer.Builder.build(Context context, OutputStream out)
EventSerializer	BodyTextEventSerializer.Builder.build(Context context, OutputStream out)
EventDeserializer	AvroEventDeserializer.Builder.build(Context context, ResettableInputStream in)
EventDeserializer	LineDeserializer.Builder.build(Context context, ResettableInputStream in)
EventDeserializer	EventDeserializer.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)

Uses of Context in org.apache.flume.sink

Methods in org.apache.flume.sink with parameters of type Context

Modifier and Type	Method and Description
void	LoggerSink.configure(Context context)
void	DefaultSinkProcessor.configure(Context context)
void	FailoverSinkProcessor.configure(Context context)
void	NullSink.configure(Context context)
void	SinkGroup.configure(Context context)
void	AbstractSinkSelector.configure(Context context)
void	LoadBalancingSinkProcessor.configure(Context context)
void	AbstractRpcSink.configure(Context context)
void	RollingFileSink.configure(Context context)
static SinkProcessor	SinkProcessorFactory.getProcessor(Context context, List<Sink> sinks) Creates a sink processor and configures it using the provided context

Uses of Context in org.apache.flume.sink.hbase2

Methods in org.apache.flume.sink.hbase2 with parameters of type Context

Modifier and Type	Method and Description
void	SimpleHBase2EventSerializer.configure(Context context)
void	RegexHBase2EventSerializer.configure(Context context)
void	HBase2Sink.configure(Context context)

Uses of Context in org.apache.flume.sink.hdfs

Methods in org.apache.flume.sink.hdfs with parameters of type Context

Modifier and Type	Method and Description
SequenceFileSerializer	HDFSWritableSerializer.Builder.build(Context context)
SequenceFileSerializer	SequenceFileSerializer.Builder.build(Context context)
SequenceFileSerializer	HDFSTextSerializer.Builder.build(Context context)
EventSerializer	AvroEventSerializer.Builder.build(Context context, OutputStream out)
void	HDFSSequenceFile.configure(Context context)
void	HDFSDataStream.configure(Context context)
void	AvroEventSerializer.configure(Context context)
void	HDFSCompressedDataStream.configure(Context context)
void	AbstractHDFSWriter.configure(Context context)
void	HDFSEventSink.configure(Context context)

Uses of Context in org.apache.flume.sink.hive

Methods in org.apache.flume.sink.hive with parameters of type Context

Modifier and Type	Method and Description
void	HiveDelimitedTextSerializer.configure(Context context)
void	HiveSink.configure(Context context)
void	HiveJsonSerializer.configure(Context context)

Uses of Context in org.apache.flume.sink.http

Methods in org.apache.flume.sink.http with parameters of type Context

Modifier and Type	Method and Description
void	HttpSink.configure(Context context)

Uses of Context in org.apache.flume.sink.irc

Methods in org.apache.flume.sink.irc with parameters of type Context

Modifier and Type	Method and Description
void	IRCSink.configure(Context context)

Uses of Context in org.apache.flume.sink.kafka

Methods in org.apache.flume.sink.kafka with parameters of type 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.

Uses of Context in org.apache.flume.sink.kite

Methods in org.apache.flume.sink.kite with parameters of type Context

Modifier and Type	Method and Description
void	DatasetSink.configure(Context context)

Uses of Context in org.apache.flume.sink.kite.parser

Methods in org.apache.flume.sink.kite.parser with parameters of type Context

Modifier and Type	Method and Description
EntityParser<E>	EntityParser.Builder.build(org.apache.avro.Schema datasetSchema, Context config)
EntityParser<org.apache.avro.generic.GenericRecord>	AvroParser.Builder.build(org.apache.avro.Schema datasetSchema, Context config)
EntityParser<org.apache.avro.generic.GenericRecord>	EntityParserFactory.newParser(org.apache.avro.Schema datasetSchema, Context config)

Uses of Context in org.apache.flume.sink.kite.policy

Methods in org.apache.flume.sink.kite.policy with parameters of type Context

Modifier and Type	Method and Description
FailurePolicy	SavePolicy.Builder.build(Context config)
FailurePolicy	RetryPolicy.Builder.build(Context config)
FailurePolicy	FailurePolicy.Builder.build(Context config) Build a new FailurePolicy
FailurePolicy	FailurePolicyFactory.newPolicy(Context config)

Uses of Context in org.apache.flume.sink.solr.morphline

Methods in org.apache.flume.sink.solr.morphline with parameters of type Context

Modifier and Type	Method and Description
BlobDeserializer	BlobDeserializer.Builder.build(Context context, ResettableInputStream in)
void	MorphlineInterceptor.Builder.configure(Context context)
void	UUIDInterceptor.Builder.configure(Context context)
void	BlobHandler.configure(Context context)
void	MorphlineSink.configure(Context context)
void	MorphlineSolrSink.configure(Context context)
void	MorphlineHandlerImpl.configure(Context context)

Constructors in org.apache.flume.sink.solr.morphline with parameters of type Context

Constructor and Description
BlobDeserializer(Context context, ResettableInputStream in)
MorphlineInterceptor(Context context)
UUIDInterceptor(Context context)

Uses of Context in org.apache.flume.source

Methods in org.apache.flume.source with parameters of type Context

Modifier and Type	Method and Description
void	ExecSource.configure(Context context)
void	NetcatSource.configure(Context context)
void	NetcatUdpSource.configure(Context context)
void	MultiportSyslogTCPSource.configure(Context context)
void	ThriftSource.configure(Context context)
void	SyslogTcpSource.configure(Context context) Deprecated.
void	AvroSource.configure(Context context)
void	AbstractPollableSource.configure(Context context)
void	SyslogUDPSource.configure(Context context)
void	SpoolDirectorySource.configure(Context context)
void	BasicSourceSemantics.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 void	SequenceGeneratorSource.doConfigure(Context context) Read parameters from context batchSize = type int that defines the size of event batches
protected abstract void	BasicSourceSemantics.doConfigure(Context context)

Uses of Context in org.apache.flume.source.avroLegacy

Methods in org.apache.flume.source.avroLegacy with parameters of type Context

Modifier and Type	Method and Description
void	AvroLegacySource.configure(Context context)

Uses of Context in org.apache.flume.source.http

Methods in org.apache.flume.source.http with parameters of type Context

Modifier and Type	Method and Description
void	BLOBHandler.configure(Context context)
void	HTTPSource.configure(Context context)
void	JSONHandler.configure(Context context)
protected void	HTTPSource.configureSsl(Context context)

Uses of Context in org.apache.flume.source.jms

Methods in org.apache.flume.source.jms with parameters of type 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)

Uses of Context in org.apache.flume.source.kafka

Methods in org.apache.flume.source.kafka with parameters of type 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.

Uses of Context in org.apache.flume.source.scribe

Methods in org.apache.flume.source.scribe with parameters of type Context

Modifier and Type	Method and Description
void	ScribeSource.configure(Context context)

Uses of Context in org.apache.flume.source.taildir

Methods in org.apache.flume.source.taildir with parameters of type Context

Modifier and Type	Method and Description
void	TaildirSource.configure(Context context)

Uses of Context in org.apache.flume.source.thriftLegacy

Methods in org.apache.flume.source.thriftLegacy with parameters of type Context

Modifier and Type	Method and Description
void	ThriftLegacySource.configure(Context context)

Uses of Context in org.apache.flume.source.twitter

Methods in org.apache.flume.source.twitter with parameters of type Context

Modifier and Type	Method and Description
void	TwitterSource.configure(Context context)

Uses of Context in org.apache.flume.tools

Methods in org.apache.flume.tools with parameters of type 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.