大数据Kudu（六）：Kudu Java Api操作

<!-- maven 不支持CDH 相关依赖，需要添加Cloudera 仓库，可以使maven下载CDH相关依赖 -->
<repositories>
    <repository>
        <id>cloudera</id>
        <url>https://repository.cloudera.com/artifactory/cloudera-repos/</url>
    </repository>
</repositories>
<!-- 添加kudu-client依赖 -->
<dependency>
    <groupId>org.apache.kudu</groupId>
    <artifactId>kudu-client</artifactId>
    <version>1.10.0-cdh6.3.2</version>
</dependency>

/**
 * 1. 创建KuduClient对象，连接Kudu集群。
 */
KuduClient kuduClient = new KuduClient.KuduClientBuilder("cm1:7051,cm2:7051").build();

/**
 * 2. 准备创建表的Schema信息。
 */
ArrayList<ColumnSchema> schemaList = new ArrayList<>();
//添加列，key是指定当前列是否是主键列
schemaList.add(new ColumnSchema.ColumnSchemaBuilder("id",Type.INT32).key(true).build());
schemaList.add(new ColumnSchema.ColumnSchemaBuilder("name",Type.STRING).build());
schemaList.add(new ColumnSchema.ColumnSchemaBuilder("age",Type.INT32).build());
schemaList.add(new ColumnSchema.ColumnSchemaBuilder("score",Type.DOUBLE).build());
Schema schema = new Schema(schemaList);

/**
 * 3. 指定创建表的分区属性。
 */
CreateTableOptions options = new CreateTableOptions();
//指定按照id进行hash分区到3个分区，默认id.hashcode % 3 ，决定数据进入哪个tablet
options.addHashPartitions(Arrays.asList("id"), 3);

/**
 * 4. 使用KuduClient对象，创建表。
 */
//参数：表名，表的schema信息，表的分区属性
kuduClient.createTable("personInfo",schema , options);

/**
 * 5. 关闭KuduClient对象。
 */
kuduClient.close();

/**
 * 1.创建KuduClient对象，连接Kudu集群。
 */
KuduClient kuduClient = new KuduClient.KuduClientBuilder("cm1:7051,cm2:7051").build();

/**
 * 2.获取插入数据的表。
 */
KuduTable personInfo = kuduClient.openTable("personInfo");

/**
 * 3.准备插入数据对象Insert, 准备插入数据PartialRow对象。
 */
//创建插入操作
Insert insert = personInfo.newInsert();
//创建插入的数据对象PartialRow
PartialRow row = insert.getRow();
row.addInt("id", 1);
row.addString("name","zhangsan" );
row.addInt("age",18 );
row.addDouble("score",100.0 );

/**
 * 4.开启session会话，应用插入操作插入数据。
 */
//创建kuduSession会话
KuduSession kuduSession = kuduClient.newSession();
//设置kudu刷新插入数据策略
kuduSession.setFlushMode(SessionConfiguration.FlushMode.AUTO_FLUSH_SYNC);
//插入数据
kuduSession.apply(insert);

/**
 * 5.关闭KuduClient对象。
 */
kuduSession.close();
kuduClient.close();

/**
 * 1.创建KuduClient对象，连接Kudu集群。
 */
KuduClient kuduClient = new KuduClient.KuduClientBuilder("cm1:7051,cm2:7051").build();

/**
 * 2.获取查询数据的表。
 */
KuduTable personInfo = kuduClient.openTable("personInfo");

/**
 * 3.开启scan扫描器，获取查询数据。
 */
//设置查询的表
KuduScanner scanner = kuduClient.newScannerBuilder(personInfo)
        //设置查询的列
        .setProjectedColumnNames(Arrays.asList("id", "name", "age", "score"))
        .build();
//scanner 中是多个tablet
while(scanner.hasMoreRows()){
    //获取一个tablet 数据
    RowResultIterator rowResults = scanner.nextRows();
    while(rowResults.hasNext()){
        RowResult next = rowResults.next();
        int id = next.getInt("id");
        String name = next.getString("name");
        int age = next.getInt("age");
        double score = next.getDouble("score");
        System.out.println("id = "+id+",name = "+name+",age = "+age+",score = "+score);
    }
}
/**
 * 4.关闭KuduClient对象。
 */
kuduClient.close();

/**
 * 1.创建KuduClient对象，连接Kudu集群。
 */
KuduClient kuduClient = new KuduClient.KuduClientBuilder("cm1:7051,cm2:7051").build();

/**
 * 2.获取更新数据的表。
 */
KuduTable personInfo = kuduClient.openTable("personInfo");

/**
 * 3.准备更新数据对象Update, 准备更新数据PartialRow对象。
 */
Update update = personInfo.newUpdate();
PartialRow row = update.getRow();
row.addInt("id", 1);//主键列
//需要更新什么列就加上什么列，不能修改主键列
row.addString("name","lisi" );

/**
 * 4.开启session会话，应用更新操作，更新数据。
 */
KuduSession kuduSession = kuduClient.newSession();
kuduSession.apply(update);

/**
 * 5.关闭KuduClient对象。
 */
kuduSession.close();
kuduClient.close();

/**
 * 1.创建KuduClient对象，连接Kudu集群。
 */
KuduClient kuduClient = new KuduClient.KuduClientBuilder("cm1:7051,cm2:7051").build();

/**
 * 2.获取删除数据的表。
 */
KuduTable personInfo = kuduClient.openTable("personInfo");

/**
 * 3.准备删除数据对象Delete, 准备删除数据PartialRow对象。
 */
Delete delete = personInfo.newDelete();
PartialRow row = delete.getRow();
//删除数据，只需要指定主键即可
row.addInt("id", 1);

/**
 * 4.开启session会话，应用删除操作，删除数据。
 */
KuduSession kuduSession = kuduClient.newSession();
kuduSession.apply(delete);

/**
 * 5.关闭KuduClient对象。
 */
kuduSession.close();
kuduClient.close();

/**
 * 1.创建KuduClient对象，连接Kudu集群。
 */
KuduClient kuduClient = new KuduClient.KuduClientBuilder("cm1:7051,cm2:7051").build();

/**
 * 2.删除表。
 */
if(kuduClient.tableExists("personInfo")){
    kuduClient.deleteTable("personInfo");
}

/**
 * 3.关闭KuduClient对象。
 */
kuduClient.close();