public class FlumeEmbeddedManager extends AbstractFlumeManager
count, LOGGER| Modifier | Constructor and Description |
|---|---|
protected |
FlumeEmbeddedManager(String name,
String shortName,
org.apache.flume.agent.embedded.EmbeddedAgent agent)
Constructor
|
| Modifier and Type | Method and Description |
|---|---|
static FlumeEmbeddedManager |
getManager(String name,
Agent[] agents,
Property[] properties,
int batchSize,
String dataDir)
Returns a FlumeEmbeddedManager.
|
protected boolean |
releaseSub(long timeout,
TimeUnit timeUnit) |
void |
send(org.apache.flume.Event event) |
close, getContentFormat, getCount, getLoggerContext, getManager, getName, hasManager, log, logDebug, logError, logger, logWarn, narrow, release, stop, updateDatapublic static FlumeEmbeddedManager getManager(String name, Agent[] agents, Property[] properties, int batchSize, String dataDir)
name - The name of the manager.agents - The agents to use.properties - Properties for the embedded manager.batchSize - The number of events to include in a batch.dataDir - The directory where the Flume FileChannel should write to.public void send(org.apache.flume.Event event)
send in class AbstractFlumeManagerprotected boolean releaseSub(long timeout,
TimeUnit timeUnit)
releaseSub in class AbstractManagerCopyright © 1999-2021 The Apache Software Foundation. All Rights Reserved.
Apache Logging, Apache Log4j, Log4j, Apache, the Apache feather logo, the Apache Logging project logo, and the Apache Log4j logo are trademarks of The Apache Software Foundation.