通过java代码进行impala和kudu的对接

对于impala而言，开发人员是可以通过JDBC连接impala的，有了JDBC，开发人员可以通过impala来间接操作kudu；

 

maven导包：

<!-- https://mvnrepository.com/artifact/com.cloudera/ImpalaJDBC41 -->
    <dependency>
        <groupId>com.cloudera</groupId>
        <artifactId>ImpalaJDBC41</artifactId>
        <version>2.5.41</version>
    </dependency>

通过JDBC连接impala操作kudu

使用JDBC连接impala操作kudu，与JDBC连接mysql做更重增删改查基本一样

创建实体类

package com.impala;

/**
 * Created by angel；
 */
public class Person {

    private int companyId;
    private int workId ;
    private String name;
    private String gender;
    private String photo;
    public Person(int companyId , int workId , String name , String gender , String photo){
        this.companyId = companyId ;
        this.workId = workId ;
        this.name = name ;
        this.gender = gender ;
        this.photo = photo ;
    }
    public int getCompanyId() {
        return companyId;
    }

    public int getWorkId() {
        return workId;
    }

    public String getGender() {
        return gender;
    }

    public String getName() {
        return name;
    }

    public String getPhoto() {
        return photo;
    }

    public void setCompanyId(int companyId) {
        this.companyId = companyId;
    }

    public void setGender(String gender) {
        this.gender = gender;
    }

    public void setName(String name) {
        this.name = name;
    }

    public void setPhoto(String photo) {
        this.photo = photo;
    }

    public void setWorkId(int workId) {
        this.workId = workId;
    }

    @Override
    public String toString() {
        return super.toString();
    }
}

View Code