1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18 package org.apache.omid.committable.hbase;
19
20 import com.google.inject.AbstractModule;
21 import com.google.inject.name.Names;
22 import org.apache.omid.HBaseConfigModule;
23
24
25
26
27
28 public class DefaultHBaseCommitTableStorageModule extends AbstractModule {
29
30 private String tableName = HBaseCommitTableConfig.DEFAULT_COMMIT_TABLE_NAME;
31 private String familyName = HBaseCommitTableConfig.DEFAULT_COMMIT_TABLE_CF_NAME;
32 private String lowWatermarkFamily = HBaseCommitTableConfig.DEFAULT_COMMIT_TABLE_LWM_CF_NAME;
33 private String keytab;
34 private String principal;
35
36 @Override
37 protected void configure() {
38 bindConstant().annotatedWith(Names.named(HBaseCommitTableConfig.COMMIT_TABLE_NAME_KEY)).to(tableName);
39 bindConstant().annotatedWith(Names.named(HBaseCommitTableConfig.COMMIT_TABLE_CF_NAME_KEY)).to(familyName);
40 bindConstant().annotatedWith(Names.named(HBaseCommitTableConfig.COMMIT_TABLE_LWM_CF_NAME_KEY)).to(lowWatermarkFamily);
41 install(new HBaseConfigModule(principal, keytab));
42 install(new HBaseCommitTableStorageModule());
43 }
44
45
46
47
48
49 public String getTableName() {
50 return tableName;
51 }
52
53 public void setTableName(String tableName) {
54 this.tableName = tableName;
55 }
56
57 public String getFamilyName() {
58 return familyName;
59 }
60
61 public void setFamilyName(String familyName) {
62 this.familyName = familyName;
63 }
64
65 public String getLowWatermarkFamily() {
66 return lowWatermarkFamily;
67 }
68
69 public void setLowWatermarkFamily(String lowWatermarkFamily) {
70 this.lowWatermarkFamily = lowWatermarkFamily;
71 }
72
73 public String getPrincipal() {
74 return principal;
75 }
76
77 public void setPrincipal(String principal) {
78 this.principal = principal;
79 }
80
81 public String getKeytab() {
82 return keytab;
83 }
84
85 public void setKeytab(String keytab) {
86 this.keytab = keytab;
87 }
88
89 }