public class RCFileMergeMapper
extends MapReduceBase
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
BACKUP_PREFIX |
static org.apache.commons.logging.Log |
LOG |
Constructor and Description |
---|
RCFileMergeMapper() |
Modifier and Type | Method and Description |
---|---|
static Path |
backupOutputPath(FileSystem fs,
Path outpath,
JobConf job) |
void |
close() |
void |
configure(JobConf job) |
static void |
jobClose(java.lang.String outputPath,
boolean success,
JobConf job,
SessionState.LogHelper console,
DynamicPartitionCtx dynPartCtx,
Reporter reporter) |
void |
map(java.lang.Object k,
RCFileValueBufferWrapper value,
<any> output,
Reporter reporter) |
public static final org.apache.commons.logging.Log LOG
public static java.lang.String BACKUP_PREFIX
public void configure(JobConf job)
public void map(java.lang.Object k, RCFileValueBufferWrapper value, <any> output, Reporter reporter) throws java.io.IOException
java.io.IOException
public void close() throws java.io.IOException
java.io.IOException
public static Path backupOutputPath(FileSystem fs, Path outpath, JobConf job) throws java.io.IOException, HiveException
java.io.IOException
HiveException
public static void jobClose(java.lang.String outputPath, boolean success, JobConf job, SessionState.LogHelper console, DynamicPartitionCtx dynPartCtx, Reporter reporter) throws HiveException, java.io.IOException
HiveException
java.io.IOException
Copyright © 2012 The Apache Software Foundation