public class FlumeEmbeddedManager extends AbstractFlumeManager
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,
org.apache.logging.log4j.core.config.Property[] properties,
int batchSize,
String dataDir)
Returns a FlumeEmbeddedManager.
|
protected void |
releaseSub() |
void |
send(org.apache.flume.Event event) |
protected FlumeEmbeddedManager(String name, String shortName, org.apache.flume.agent.embedded.EmbeddedAgent agent)
name
- The unique name of this manager.shortName
- The short version of the agent name.agent
- The embedded agent.public static FlumeEmbeddedManager getManager(String name, Agent[] agents, org.apache.logging.log4j.core.config.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 AbstractFlumeManager
protected void releaseSub()
releaseSub
in class org.apache.logging.log4j.core.appender.AbstractManager
Copyright © 1999-2016 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.