Package org.apache.hadoop.mapred.lib
Class InputSampler<K,V>
java.lang.Object
org.apache.hadoop.conf.Configured
org.apache.hadoop.mapreduce.lib.partition.InputSampler<K,V>
org.apache.hadoop.mapred.lib.InputSampler<K,V>
- All Implemented Interfaces:
Configurable,Tool
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic classorg.apache.hadoop.mapred.lib.InputSampler.IntervalSampler<K,V> Sample from s splits at regular intervals.static classorg.apache.hadoop.mapred.lib.InputSampler.RandomSampler<K,V> Sample from random points in the input.static interfaceorg.apache.hadoop.mapred.lib.InputSampler.Sampler<K,V> Interface to sample using anInputFormat.static classorg.apache.hadoop.mapred.lib.InputSampler.SplitSampler<K,V> Samples the first n records from s splits. -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic <K,V> void writePartitionFile(JobConf job, org.apache.hadoop.mapred.lib.InputSampler.Sampler<K, V> sampler) Methods inherited from class org.apache.hadoop.mapreduce.lib.partition.InputSampler
main, run, writePartitionFileMethods inherited from class org.apache.hadoop.conf.Configured
getConf, setConfMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.apache.hadoop.conf.Configurable
getConf, setConf
-
Constructor Details
-
InputSampler
-
-
Method Details
-
writePartitionFile
public static <K,V> void writePartitionFile(JobConf job, org.apache.hadoop.mapred.lib.InputSampler.Sampler<K, V> sampler) throws IOException, ClassNotFoundException, InterruptedException
-