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

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
protected void	populateAvroHeaders(Map<String,String> hdrs, Schema schema, Object message)
boolean	requiresLayout()
void	setDatasetName(String datasetName)
void	setDatasetNamespace(String datasetNamespace)
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)

setDatasetNamespace

public void setDatasetNamespace(String datasetNamespace)

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