org.apache.hive.hcatalog.har

Class HarOutputCommitterPostProcessor

java.lang.Object

org.apache.hive.hcatalog.har.HarOutputCommitterPostProcessor

public class HarOutputCommitterPostProcessor
extends Object

Constructor Summary

Constructors

Constructor and Description
HarOutputCommitterPostProcessor()

Method Summary

Modifier and Type	Method and Description
void	exec(org.apache.hadoop.mapreduce.JobContext context, org.apache.hadoop.hive.metastore.api.Partition partition, org.apache.hadoop.fs.Path partPath)
String	getParentFSPath(org.apache.hadoop.fs.Path ptnPath)
String	getProcessedLocation(org.apache.hadoop.fs.Path ptnPath)
String	harFile(org.apache.hadoop.fs.Path ptnPath)
boolean	isEnabled()
static void	makeHar(org.apache.hadoop.mapreduce.JobContext context, String dir, String harFile) Creates a har file from the contents of a given directory, using that as root.
void	setEnabled(boolean enabled)

Methods inherited from class java.lang.Object

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

Constructor Detail

HarOutputCommitterPostProcessor

public HarOutputCommitterPostProcessor()

Method Detail

isEnabled

public boolean isEnabled()

setEnabled

public void setEnabled(boolean enabled)

exec

public void exec(org.apache.hadoop.mapreduce.JobContext context,
                 org.apache.hadoop.hive.metastore.api.Partition partition,
                 org.apache.hadoop.fs.Path partPath)
          throws IOException

Throws:

IOException

harFile

public String harFile(org.apache.hadoop.fs.Path ptnPath)
               throws IOException

Throws:

IOException

getParentFSPath

public String getParentFSPath(org.apache.hadoop.fs.Path ptnPath)
                       throws IOException

Throws:

IOException

getProcessedLocation

public String getProcessedLocation(org.apache.hadoop.fs.Path ptnPath)
                            throws IOException

Throws:

IOException

makeHar

public static void makeHar(org.apache.hadoop.mapreduce.JobContext context,
                           String dir,
                           String harFile)
                    throws IOException

Creates a har file from the contents of a given directory, using that as root.

Parameters:

dir - Directory to archive

harFile - The HAR file to create

Throws:

IOException