public class FlumeAvroManager extends AbstractFlumeManager
count, LOGGER| Modifier | Constructor and Description |
|---|---|
protected |
FlumeAvroManager(String name,
String shortName,
Agent[] agents,
int batchSize,
int delayMillis,
int retries,
int connectTimeout,
int requestTimeout)
Constructor
|
| Modifier and Type | Method and Description |
|---|---|
Agent[] |
getAgents()
Returns the agents.
|
int |
getBatchSize() |
int |
getConnectTimeoutMillis() |
int |
getCurrent()
Returns the index of the current agent.
|
int |
getDelayMillis() |
static FlumeAvroManager |
getManager(String name,
Agent[] agents,
int batchSize,
int delayMillis,
int retries,
int connectTimeoutMillis,
int requestTimeoutMillis)
Returns a FlumeAvroManager.
|
int |
getRequestTimeoutMillis() |
int |
getRetries() |
protected void |
releaseSub() |
void |
send(BatchEvent events) |
void |
send(org.apache.flume.Event event) |
getContentFormat, getCount, getManager, getName, hasManager, releaseprotected FlumeAvroManager(String name, String shortName, Agent[] agents, int batchSize, int delayMillis, int retries, int connectTimeout, int requestTimeout)
name - The unique name of this manager.agents - An array of Agents.batchSize - The number of events to include in a batch.retries - The number of times to retry connecting before giving up.connectTimeout - The connection timeout in ms.requestTimeout - The request timeout in ms.public static FlumeAvroManager getManager(String name, Agent[] agents, int batchSize, int delayMillis, int retries, int connectTimeoutMillis, int requestTimeoutMillis)
name - The name of the manager.agents - The agents to use.batchSize - The number of events to include in a batch.delayMillis - The number of milliseconds to wait before sending an incomplete batch.retries - The number of times to retry connecting before giving up.connectTimeoutMillis - The connection timeout in ms.requestTimeoutMillis - The request timeout in ms.public Agent[] getAgents()
public int getCurrent()
public int getRetries()
public int getConnectTimeoutMillis()
public int getRequestTimeoutMillis()
public int getBatchSize()
public int getDelayMillis()
public void send(BatchEvent events)
public void send(org.apache.flume.Event event)
send in class AbstractFlumeManagerprotected void releaseSub()
releaseSub in class AbstractManagerCopyright © 1999-2015 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.