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

static Comparator<byte[]>

C

Constructor Summary

PartitionKeySampler()

Method Summary

void	addSampleFile(org.apache.hadoop.fs.Path inputPath, org.apache.hadoop.mapred.JobConf job)
void	collect(HiveKey key, Object value)
static org.apache.hadoop.hive.ql.exec.PartitionKeySampler.FetchSampler	createSampler(FetchWork work, HiveConf conf, 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

equals, 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 org.apache.hadoop.hive.ql.exec.PartitionKeySampler.FetchSampler createSampler(FetchWork work,
                                                                                            HiveConf conf,
                                                                                            org.apache.hadoop.mapred.JobConf job,
                                                                                            Operator<?> operator)