org.apache.hadoop.hive.ql.exec

Class PartitionKeySampler

java.lang.Object

org.apache.hadoop.hive.ql.exec.PartitionKeySampler

All Implemented Interfaces:

org.apache.hadoop.mapred.OutputCollector<HiveKey,Object>

public class PartitionKeySampler
extends Object
implements org.apache.hadoop.mapred.OutputCollector<HiveKey,Object>

Field Summary

Fields

Modifier and Type	Field and Description
static Comparator<byte[]>	C

Constructor Summary

Constructors

Constructor and Description
PartitionKeySampler()

Method Summary

Modifier and Type	Method and Description
void	addSampleFile(org.apache.hadoop.fs.Path inputPath, org.apache.hadoop.mapred.JobConf job)
void	collect(HiveKey key, Object value)
static FetchOperator	createSampler(FetchWork work, org.apache.hadoop.mapred.JobConf job, Operator<?> operator)
void	writePartitionKeys(org.apache.hadoop.fs.Path path, org.apache.hadoop.mapred.JobConf job)

Methods inherited from class java.lang.Object

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

Field Detail

C

public static final Comparator<byte[]> C

Constructor Detail

PartitionKeySampler

public PartitionKeySampler()

Method Detail

addSampleFile

public void addSampleFile(org.apache.hadoop.fs.Path inputPath,
                          org.apache.hadoop.mapred.JobConf job)
                   throws IOException

Throws:

IOException

collect

public void collect(HiveKey key,
                    Object value)
             throws IOException

Specified by:

collect in interface org.apache.hadoop.mapred.OutputCollector<HiveKey,Object>

Throws:

IOException

writePartitionKeys

public void writePartitionKeys(org.apache.hadoop.fs.Path path,
                               org.apache.hadoop.mapred.JobConf job)
                        throws IOException

Throws:

IOException

createSampler

public static FetchOperator createSampler(FetchWork work,
                                          org.apache.hadoop.mapred.JobConf job,
                                          Operator<?> operator)
                                   throws HiveException

Throws:

HiveException