Revision 28564
Added by Eri Katsari almost 10 years ago
SqoopDriver.java | ||
---|---|---|
1 | 1 |
package eu.dnetlib.data.mapreduce.hbase.statsExport.drivers; |
2 | 2 |
|
3 | 3 |
import java.io.File; |
4 |
import java.io.FileNotFoundException; |
|
5 |
import java.io.IOException; |
|
6 | 4 |
import java.io.InputStream; |
7 | 5 |
import java.util.ArrayList; |
8 | 6 |
import java.util.HashMap; |
... | ... | |
23 | 21 |
private String TABLE_MAP_PATH = "eu/dnetlib/data/mapreduce/hbase/statsExport/exportTables"; |
24 | 22 |
|
25 | 23 |
private Properties tableMappings = new Properties(); |
26 |
|
|
27 |
private String dbName; |
|
24 |
|
|
28 | 25 |
private String outputPath; |
29 | 26 |
private String dbUser; |
30 | 27 |
private String dbPass; |
... | ... | |
61 | 58 |
|
62 | 59 |
"--connect", connectionUrl, "--table", table.getKey(), |
63 | 60 |
|
64 |
"--export-dir", table.getValue(), |
|
61 |
"--export-dir ", table.getValue(),
|
|
65 | 62 |
// TODO : important!! this is necessary since MR multiple |
66 | 63 |
// outputs writer appends a \t char after writing the KEY |
67 | 64 |
// field in HDFS. |
... | ... | |
287 | 284 |
this.tableMappings = tableMappings; |
288 | 285 |
} |
289 | 286 |
|
290 |
public String getDbName() { |
|
291 |
return dbName; |
|
292 |
} |
|
287 |
|
|
293 | 288 |
|
294 |
public void setDbName(String dbName) { |
|
295 |
this.dbName = dbName; |
|
296 |
} |
|
297 |
|
|
298 | 289 |
public String getOutputPath() { |
299 | 290 |
return outputPath; |
300 | 291 |
} |
Also available in: Unified diff