Revision 29050
Added by Eri Katsari almost 10 years ago
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