@Override
    public HbaseSink genStreamSink(AbstractTargetTableInfo targetTableInfo) {
        HbaseTableInfo hbaseTableInfo = (HbaseTableInfo) targetTableInfo;
        this.zookeeperQuorum = hbaseTableInfo.getHost();
        this.port = hbaseTableInfo.getPort();
        this.parent = hbaseTableInfo.getParent();
        this.tableName = hbaseTableInfo.getTableName();
        this.rowkey = hbaseTableInfo.getRowkey();
        this.columnNameFamily = hbaseTableInfo.getColumnNameFamily();
        this.registerTabName = hbaseTableInfo.getName();

        this.kerberosAuthEnable = hbaseTableInfo.isKerberosAuthEnable();
        this.regionserverKeytabFile = hbaseTableInfo.getRegionserverKeytabFile();
        this.regionserverPrincipal = hbaseTableInfo.getRegionserverPrincipal();
        this.securityKrb5Conf = hbaseTableInfo.getSecurityKrb5Conf();
        this.zookeeperSaslClient = hbaseTableInfo.getZookeeperSaslClient();

        this.clientKeytabFile = hbaseTableInfo.getClientKeytabFile();
        this.clientPrincipal = hbaseTableInfo.getClientPrincipal();

        this.dirtyProperties = hbaseTableInfo.getDirtyProperties();

        Integer tmpSinkParallelism = hbaseTableInfo.getParallelism();
        if (tmpSinkParallelism != null) {
            this.parallelism = tmpSinkParallelism;
        }

        this.batchSize = hbaseTableInfo.getBatchSize();
        this.batchWaitInterval = hbaseTableInfo.getBatchWaitInterval();
        return this;
    }
Date: 2018/09/14
Company: www.dtstack.com

@author sishu.yss
hbase/hbase-sink/src/main/java/com/dtstack/flink/sql/sink/hbase/HbaseSink.java