org.kitesdk.data.flume
Class Log4jAppender

java.lang.Object
  org.apache.log4j.AppenderSkeleton
      org.apache.flume.clients.log4jappender.Log4jAppender
          org.kitesdk.data.flume.Log4jAppender

All Implemented Interfaces:

org.apache.log4j.Appender, org.apache.log4j.spi.OptionHandler

public class Log4jAppender
extends org.apache.flume.clients.log4jappender.Log4jAppender

Field Summary

Fields inherited from class org.apache.log4j.AppenderSkeleton

closed, errorHandler, headFilter, layout, name, tailFilter, threshold

Constructor Summary

Log4jAppender()

Log4jAppender(String hostname, int port)
Sets the hostname and port.

Method Summary

protected void	populateAvroHeaders(Map<String,String> hdrs, Schema schema, Object message)
boolean	requiresLayout()
void	setDatasetName(String datasetName)
void	setDatasetRepositoryClass(String datasetRepositoryClass) Deprecated. Use datasetRepositoryUri with a 'repo:' URI.
void	setDatasetRepositoryUri(String datasetRepositoryUri)

Methods inherited from class org.apache.flume.clients.log4jappender.Log4jAppender

activateOptions, append, close, getTimeout, setAvroReflectionEnabled, setAvroSchemaUrl, setHostname, setPort, setTimeout

Methods inherited from class org.apache.log4j.AppenderSkeleton

addFilter, clearFilters, doAppend, finalize, getErrorHandler, getFilter, getFirstFilter, getLayout, getName, getThreshold, isAsSevereAsThreshold, setErrorHandler, setLayout, setName, setThreshold

Methods inherited from class java.lang.Object

clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Log4jAppender

public Log4jAppender()

Log4jAppender

public Log4jAppender(String hostname,
                     int port)

Sets the hostname and port. Even if these are passed the activateOptions() function must be called before calling append(), else append() will throw an Exception.

Parameters:

hostname - The first hop where the client should connect to.

port - The port to connect on the host.

Method Detail

requiresLayout

public boolean requiresLayout()

Specified by:

requiresLayout in interface org.apache.log4j.Appender

Overrides:

requiresLayout in class org.apache.flume.clients.log4jappender.Log4jAppender

setDatasetRepositoryClass

@Deprecated
public void setDatasetRepositoryClass(String datasetRepositoryClass)

Deprecated. Use datasetRepositoryUri with a 'repo:' URI.

setDatasetRepositoryUri

public void setDatasetRepositoryUri(String datasetRepositoryUri)

setDatasetName

public void setDatasetName(String datasetName)

populateAvroHeaders

protected void populateAvroHeaders(Map<String,String> hdrs,
                                   Schema schema,
                                   Object message)

Overrides:

populateAvroHeaders in class org.apache.flume.clients.log4jappender.Log4jAppender