Project

General

Profile

« Previous | Next » 

Revision 29050

Added by Eri Katsari almost 10 years ago

View differences:

SqoopDriver.java
3 3
import java.io.File;
4 4
import java.io.InputStream;
5 5
import java.util.ArrayList;
6
import java.util.Arrays;
6 7
import java.util.HashMap;
7 8
import java.util.Map.Entry;
8 9
import java.util.Properties;
......
15 16
import org.apache.log4j.BasicConfigurator;
16 17
import org.apache.log4j.Logger;
17 18
import org.apache.sqoop.Sqoop;
19
import org.apache.sqoop.tool.SqoopTool;
18 20

  
19 21
public class SqoopDriver {
20 22
	private Logger log = Logger.getLogger(this.getClass());
......
73 75
				log.error("Could not run Sqoop Tool " + Integer.toString(ret));
74 76
				throw new RuntimeException("Could not run Sqoop Tool " + Integer.toString(ret));
75 77
			}
78
			SqoopTool tool = SqoopTool.getTool("dnetSqoop");
79
			if (null == tool) {
80
				log.error("No such sqoop tool: " + "dnetSqoop" + ". See 'sqoop help'.");
76 81

  
82
			}
83
			Configuration pluginConf = SqoopTool.loadPlugins(new Configuration());
84

  
85
			Sqoop sqoop = new Sqoop((com.cloudera.sqoop.tool.SqoopTool) tool);
86
			sqoop.run(str);
87
		 
77 88
			cleanUp(table.getKey());
78 89
		}
79 90
	}

Also available in: Unified diff