|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Uses of Context in org.apache.flume.channel |
---|
Methods in org.apache.flume.channel with parameters of type Context | |
---|---|
void |
ReplicatingChannelSelector.configure(Context context)
|
void |
PseudoTxnMemoryChannel.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 |
ChannelProcessor.configure(Context context)
The Context of the associated Source is passed. |
void |
AbstractChannel.configure(Context context)
|
Uses of Context in org.apache.flume.channel.file |
---|
Methods in org.apache.flume.channel.file with parameters of type Context | |
---|---|
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 | |
---|---|
KeyProvider |
KeyProvider.Builder.build(Context context)
|
KeyProvider |
JCEFileKeyProvider.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 | |
---|---|
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 | |
---|---|
void |
JdbcChannelProviderImpl.initialize(Context context)
|
Uses of Context in org.apache.flume.channel.recoverable.memory |
---|
Methods in org.apache.flume.channel.recoverable.memory with parameters of type Context | |
---|---|
void |
RecoverableMemoryChannel.configure(Context context)
Deprecated. |
Uses of Context in org.apache.flume.conf |
---|
Methods in org.apache.flume.conf that return types with arguments of type Context | |
---|---|
Map<String,Context> |
FlumeConfiguration.AgentConfiguration.getChannelContext()
|
Map<String,Context> |
FlumeConfiguration.AgentConfiguration.getSinkContext()
|
Map<String,Context> |
FlumeConfiguration.AgentConfiguration.getSourceContext()
|
Methods in org.apache.flume.conf with parameters of type Context | |
---|---|
void |
ComponentConfiguration.configure(Context context)
|
void |
Configurable.configure(Context context)
Request the implementing class to (re)configure itself. |
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.channel |
---|
Methods in org.apache.flume.conf.channel with parameters of type Context | |
---|---|
void |
ChannelSelectorConfiguration.configure(Context context)
|
void |
ChannelConfiguration.configure(Context context)
|
Uses of Context in org.apache.flume.conf.sink |
---|
Methods in org.apache.flume.conf.sink that return Context | |
---|---|
Context |
SinkGroupConfiguration.getProcessorContext()
|
Methods in org.apache.flume.conf.sink with parameters of type Context | |
---|---|
void |
SinkProcessorConfiguration.configure(Context context)
|
void |
SinkGroupConfiguration.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 | |
---|---|
void |
SourceConfiguration.configure(Context context)
|
Uses of Context in org.apache.flume.instrumentation |
---|
Methods in org.apache.flume.instrumentation with parameters of type Context | |
---|---|
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 | |
---|---|
void |
HTTPMetricsServer.configure(Context context)
|
Uses of Context in org.apache.flume.interceptor |
---|
Methods in org.apache.flume.interceptor with parameters of type Context | |
---|---|
void |
TimestampInterceptor.Builder.configure(Context context)
|
void |
StaticInterceptor.Builder.configure(Context context)
|
void |
RegexFilteringInterceptor.Builder.configure(Context context)
|
void |
RegexExtractorInterceptorPassThroughSerializer.configure(Context context)
|
void |
RegexExtractorInterceptorMillisSerializer.configure(Context context)
|
void |
RegexExtractorInterceptor.Builder.configure(Context context)
|
void |
HostInterceptor.Builder.configure(Context context)
|
Uses of Context in org.apache.flume.serialization |
---|
Methods in org.apache.flume.serialization with parameters of type Context | |
---|---|
EventSerializer |
FlumeEventAvroEventSerializer.Builder.build(Context context,
OutputStream out)
|
EventSerializer |
EventSerializer.Builder.build(Context context,
OutputStream out)
|
EventSerializer |
BodyTextEventSerializer.Builder.build(Context context,
OutputStream out)
|
void |
AbstractAvroEventSerializer.configure(Context context)
|
static EventSerializer |
EventSerializerFactory.getInstance(String serializerType,
Context context,
OutputStream out)
|
Uses of Context in org.apache.flume.sink |
---|
Methods in org.apache.flume.sink with parameters of type Context | |
---|---|
void |
SinkGroup.configure(Context context)
|
void |
RollingFileSink.configure(Context context)
|
void |
NullSink.configure(Context context)
|
void |
LoadBalancingSinkProcessor.configure(Context context)
|
void |
FailoverSinkProcessor.configure(Context context)
|
void |
DefaultSinkProcessor.configure(Context context)
|
void |
AvroSink.configure(Context context)
|
void |
AbstractSinkSelector.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.elasticsearch |
---|
Methods in org.apache.flume.sink.elasticsearch with parameters of type Context | |
---|---|
void |
ElasticSearchSink.configure(Context context)
|
void |
ElasticSearchLogStashEventSerializer.configure(Context context)
|
void |
ElasticSearchDynamicSerializer.configure(Context context)
|
Uses of Context in org.apache.flume.sink.hbase |
---|
Methods in org.apache.flume.sink.hbase with parameters of type Context | |
---|---|
void |
SimpleHbaseEventSerializer.configure(Context context)
|
void |
SimpleAsyncHbaseEventSerializer.configure(Context context)
|
void |
RegexHbaseEventSerializer.configure(Context context)
|
void |
HBaseSink.configure(Context context)
|
void |
AsyncHBaseSink.configure(Context context)
|
Uses of Context in org.apache.flume.sink.hdfs |
---|
Methods in org.apache.flume.sink.hdfs with parameters of type Context | |
---|---|
void |
HDFSSequenceFile.configure(Context context)
|
void |
HDFSEventSink.configure(Context context)
|
void |
HDFSDataStream.configure(Context context)
|
void |
HDFSCompressedDataStream.configure(Context context)
|
Uses of Context in org.apache.flume.sink.irc |
---|
Methods in org.apache.flume.sink.irc with parameters of type Context | |
---|---|
void |
IRCSink.configure(Context context)
|
Uses of Context in org.apache.flume.source |
---|
Methods in org.apache.flume.source with parameters of type Context | |
---|---|
void |
SyslogUDPSource.configure(Context context)
|
void |
SyslogTcpSource.configure(Context context)
|
void |
StressSource.configure(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 total number of events to be sent -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 |
void |
SpoolDirectorySource.configure(Context context)
|
void |
SequenceGeneratorSource.configure(Context context)
Read parameters from context batchSize = type int that defines the size of event batches |
void |
NetcatSource.configure(Context context)
|
void |
MultiportSyslogTCPSource.configure(Context context)
|
void |
ExecSource.configure(Context context)
|
void |
AvroSource.configure(Context context)
|
Uses of Context in org.apache.flume.source.avroLegacy |
---|
Methods in org.apache.flume.source.avroLegacy with parameters of type Context | |
---|---|
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 | |
---|---|
void |
JSONHandler.configure(Context context)
|
void |
HTTPSource.configure(Context context)
|
Uses of Context in org.apache.flume.source.scribe |
---|
Methods in org.apache.flume.source.scribe with parameters of type Context | |
---|---|
void |
ScribeSource.configure(Context context)
|
Uses of Context in org.apache.flume.source.thriftLegacy |
---|
Methods in org.apache.flume.source.thriftLegacy with parameters of type Context | |
---|---|
void |
ThriftLegacySource.configure(Context context)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |