org.apache.hadoop.hive.ql.io.rcfile.merge

Class RCFileMergeMapper

java.lang.Object

MapReduceBase

org.apache.hadoop.hive.ql.io.rcfile.merge.RCFileMergeMapper

public class RCFileMergeMapper
extends MapReduceBase

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	BACKUP_PREFIX
static org.apache.commons.logging.Log	LOG

Constructor Summary

Constructors

Constructor and Description
RCFileMergeMapper()

Method Summary

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)

Methods inherited from class java.lang.Object

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

Field Detail

LOG

public static final org.apache.commons.logging.Log LOG

BACKUP_PREFIX

public static java.lang.String BACKUP_PREFIX

Constructor Detail

RCFileMergeMapper

public RCFileMergeMapper()

Method Detail

configure

public void configure(JobConf job)

map

public void map(java.lang.Object k,
                RCFileValueBufferWrapper value,
                <any> output,
                Reporter reporter)
         throws java.io.IOException

Throws:

java.io.IOException

close

public void close()
           throws java.io.IOException

Throws:

java.io.IOException

backupOutputPath

public static Path backupOutputPath(FileSystem fs,
                                    Path outpath,
                                    JobConf job)
                             throws java.io.IOException,
                                    HiveException

Throws:

java.io.IOException

HiveException

jobClose

public static void jobClose(java.lang.String outputPath,
                            boolean success,
                            JobConf job,
                            SessionState.LogHelper console,
                            DynamicPartitionCtx dynPartCtx,
                            Reporter reporter)
                     throws HiveException,
                            java.io.IOException

Throws:

HiveException

java.io.IOException