org.kitesdk.data.flume
Class Log4jAppender

java.lang.Object
  extended by org.apache.log4j.AppenderSkeleton
      extended by org.apache.flume.clients.log4jappender.Log4jAppender
          extended by 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


Copyright © 2013–2014. All rights reserved.