Project

General

Profile

« Previous | Next » 

Revision 28564

Added by Eri Katsari almost 10 years ago

View differences:

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