Skip to content

Commit 3a9cb36

Browse files
author
dapeng
committed
fix missing field
1 parent 907aacb commit 3a9cb36

File tree

1 file changed

+63
-0
lines changed

1 file changed

+63
-0
lines changed

hbase/hbase-sink/src/main/java/com/dtstack/flink/sql/sink/hbase/table/HbaseTableInfo.java

Lines changed: 63 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,8 @@
2323

2424
import com.dtstack.flink.sql.table.AbstractTargetTableInfo;
2525
import com.google.common.base.Preconditions;
26+
import com.google.common.collect.Maps;
27+
2628
import java.util.Map;
2729

2830
/**
@@ -54,6 +56,18 @@ public class HbaseTableInfo extends AbstractTargetTableInfo {
5456

5557
private String updateMode;
5658

59+
private boolean kerberosAuthEnable;
60+
61+
private String regionserverKeytabFile;
62+
63+
private String regionserverPrincipal;
64+
65+
private String securityKrb5Conf;
66+
67+
private String zookeeperSaslClient;
68+
69+
private Map<String,Object> hbaseConfig = Maps.newHashMap();
70+
5771
public HbaseTableInfo(){
5872
setType(CURR_TYPE);
5973
}
@@ -149,4 +163,53 @@ public String getType() {
149163
return super.getType().toLowerCase();
150164
}
151165

166+
167+
public Map<String, Object> getHbaseConfig() {
168+
return hbaseConfig;
169+
}
170+
171+
public void setHbaseConfig(Map<String, Object> hbaseConfig) {
172+
this.hbaseConfig = hbaseConfig;
173+
}
174+
175+
public boolean isKerberosAuthEnable() {
176+
return kerberosAuthEnable;
177+
}
178+
179+
public void setKerberosAuthEnable(boolean kerberosAuthEnable) {
180+
this.kerberosAuthEnable = kerberosAuthEnable;
181+
}
182+
183+
public String getRegionserverKeytabFile() {
184+
return regionserverKeytabFile;
185+
}
186+
187+
public void setRegionserverKeytabFile(String regionserverKeytabFile) {
188+
this.regionserverKeytabFile = regionserverKeytabFile;
189+
}
190+
191+
public String getRegionserverPrincipal() {
192+
return regionserverPrincipal;
193+
}
194+
195+
public void setRegionserverPrincipal(String regionserverPrincipal) {
196+
this.regionserverPrincipal = regionserverPrincipal;
197+
}
198+
199+
public String getSecurityKrb5Conf() {
200+
return securityKrb5Conf;
201+
}
202+
203+
public void setSecurityKrb5Conf(String securityKrb5Conf) {
204+
this.securityKrb5Conf = securityKrb5Conf;
205+
}
206+
207+
public String getZookeeperSaslClient() {
208+
return zookeeperSaslClient;
209+
}
210+
211+
public void setZookeeperSaslClient(String zookeeperSaslClient) {
212+
this.zookeeperSaslClient = zookeeperSaslClient;
213+
}
214+
152215
}

0 commit comments

Comments
 (0)