126.在CDH中用Java API访问Kudu

126.1 准备环境

• Kudu配置修改

# 在KuduMaster服务的高级配置” gflagfile 的 Master 高级配置代码段（安全阀）”增加配置
--trusted_subnets=0.0.0.0/0
# 由于Fayson使用的是AWS环境这里跨了网段需要进行配置，如果局域网可以跳过此步

# 如果未配置在使用Java API访问Kudu时报如下错误
W1128 16:56:55.749083 93981 negotiation.cc:318] Unauthorized connection attempt: Server connection negotiation failed: server connection from 100.73.0.57:42533: unauthenticated connections from publicly routable IPs are prohibited. See --trusted_subnets flag for more information

126.2 Java示例

• Kudu的Maven工程创建
  
• pom.xml文件内容

    
        org.apache.kudu
        kudu-client
        1.6.0
    
    
    
        org.slf4j
        slf4j-simple
        1.7.25
    
    
        com.cloudera
        generate-data
        1.0-SNAPSHOT
    

• KuduExample.java类

package com.cloudera;
import org.apache.kudu.ColumnSchema;
import org.apache.kudu.Schema;
import org.apache.kudu.Type;
import org.apache.kudu.client.*;
import java.util.ArrayList;
import java.util.List;

public class KuduExample {
    /**
     * 使用Kudu API创建一个Kudu表
     * @param client
     * @param tableName
     */
    public static void createTable(KuduClient client, String tableName) {
        List columns = new ArrayList<>();
        //在添加列时可以指定每一列的压缩格式
        columns.add(new ColumnSchema.ColumnSchemaBuilder("id", Type.STRING).key(true).
                compressionAlgorithm(ColumnSchema