Constructor Detail

• FlumeEmbeddedManager

  protected FlumeEmbeddedManager(String name,
                      String shortName,
                      org.apache.flume.agent.embedded.EmbeddedAgent agent)

  Constructor

  Parameters:

  name - The unique name of this manager.

  shortName - The short version of the agent name.

  agent - The embedded agent.

Method Detail

• getManager

  public static FlumeEmbeddedManager getManager(String name,
                                Agent[] agents,
                                Property[] properties,
                                int batchSize,
                                String dataDir)

  Returns a FlumeEmbeddedManager.

  Parameters:

  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.

  Returns:

  A FlumeAvroManager.

• send

  public void send(org.apache.flume.Event event)

  Specified by:

  send in class AbstractFlumeManager

• releaseSub

  protected void releaseSub()

  Overrides:

  releaseSub in class AbstractManager