public class TFRecordFileMRExample extends Object
| Constructor and Description |
|---|
TFRecordFileMRExample() |
| Modifier and Type | Method and Description |
|---|---|
static boolean |
convert(String jobName,
Class<? extends org.apache.hadoop.mapreduce.Mapper> mapperClass,
Class<? extends org.apache.hadoop.io.Writable> outputKeyClass,
Class<? extends org.apache.hadoop.io.Writable> outputValueClass,
Class<? extends org.apache.hadoop.mapreduce.InputFormat> inFormatClass,
Class<? extends org.apache.hadoop.mapreduce.OutputFormat> outFormatClass,
org.apache.hadoop.fs.Path input,
org.apache.hadoop.fs.Path output) |
static void |
main(String[] args) |
public static boolean convert(String jobName, Class<? extends org.apache.hadoop.mapreduce.Mapper> mapperClass, Class<? extends org.apache.hadoop.io.Writable> outputKeyClass, Class<? extends org.apache.hadoop.io.Writable> outputValueClass, Class<? extends org.apache.hadoop.mapreduce.InputFormat> inFormatClass, Class<? extends org.apache.hadoop.mapreduce.OutputFormat> outFormatClass, org.apache.hadoop.fs.Path input, org.apache.hadoop.fs.Path output) throws InterruptedException, IOException, ClassNotFoundException
Copyright © 2019. All rights reserved.