public class HarOutputCommitterPostProcessor extends Object
Constructor and Description |
---|
HarOutputCommitterPostProcessor() |
Modifier and Type | Method and Description |
---|---|
void |
exec(org.apache.hadoop.mapreduce.JobContext context,
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) |
public boolean isEnabled()
public void setEnabled(boolean enabled)
public void exec(org.apache.hadoop.mapreduce.JobContext context, Partition partition, org.apache.hadoop.fs.Path partPath) throws IOException
IOException
public String harFile(org.apache.hadoop.fs.Path ptnPath) throws IOException
IOException
public String getParentFSPath(org.apache.hadoop.fs.Path ptnPath) throws IOException
IOException
public String getProcessedLocation(org.apache.hadoop.fs.Path ptnPath) throws IOException
IOException
public static void makeHar(org.apache.hadoop.mapreduce.JobContext context, String dir, String harFile) throws IOException
dir
- Directory to archiveharFile
- The HAR file to createIOException
Copyright © 2017 The Apache Software Foundation. All rights reserved.