Project

General

Profile

1 37825 claudio.at
package eu.dnetlib.msro.workflows.hadoop.hbase;
2
3
import com.googlecode.sarasvati.Arc;
4
import com.googlecode.sarasvati.NodeToken;
5
6
import eu.dnetlib.msro.workflows.nodes.SimpleJobNode;
7
8
public class SetHBaseTableJobNode extends SimpleJobNode {
9
10
	private String tableProperty = "hbaseTable";
11
12
	private String table;
13
14
	@Override
15
	protected String execute(final NodeToken token) throws Exception {
16
		token.getEnv().setAttribute(getTableProperty(), getTable());
17
		return Arc.DEFAULT_ARC;
18
	}
19
20
	public String getTableProperty() {
21
		return tableProperty;
22
	}
23
24
	public void setTableProperty(final String tableProperty) {
25
		this.tableProperty = tableProperty;
26
	}
27
28
	public String getTable() {
29
		return table;
30
	}
31
32
	public void setTable(final String table) {
33
		this.table = table;
34
	}
35
36
}