org.apache.hadoop.chukwa.extraction.demux

Class PostProcessorManager

java.lang.Object

org.apache.hadoop.chukwa.extraction.demux.PostProcessorManager

public class PostProcessorManager
extends Object

Constructor Summary

Constructors

Constructor and Description
PostProcessorManager()
PostProcessorManager(ChukwaConfiguration conf)

Method Summary

Modifier and Type	Method and Description
boolean	deleteDirectory(String directory)
static void	main(String[] args)
boolean	moveToInErrorDirectory(String sourceDirectory, String dirName, String inErrorDirectory)
org.apache.hadoop.fs.Path[]	movetoMainRepository(String sourceDirectory, String repoRootDirectory)
boolean	processDataLoaders(String directory)
boolean	processPostMoveTriggers(org.apache.hadoop.fs.Path[] files)
void	shutdown()
void	start()

Methods inherited from class java.lang.Object

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

Constructor Detail

PostProcessorManager

public PostProcessorManager()
                     throws Exception

Throws:

Exception

PostProcessorManager

public PostProcessorManager(ChukwaConfiguration conf)
                     throws Exception

Throws:

Exception

Method Detail

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception

shutdown

public void shutdown()

start

public void start()

processDataLoaders

public boolean processDataLoaders(String directory)
                           throws IOException

Throws:

IOException

processPostMoveTriggers

public boolean processPostMoveTriggers(org.apache.hadoop.fs.Path[] files)
                                throws IOException

Throws:

IOException

movetoMainRepository

public org.apache.hadoop.fs.Path[] movetoMainRepository(String sourceDirectory,
                                                        String repoRootDirectory)
                                                 throws Exception

Throws:

Exception

moveToInErrorDirectory

public boolean moveToInErrorDirectory(String sourceDirectory,
                                      String dirName,
                                      String inErrorDirectory)
                               throws Exception

Throws:

Exception

deleteDirectory

public boolean deleteDirectory(String directory)
                        throws IOException

Throws:

IOException