1 元数据 SDK for Java 使用参考

前提条件

已创建访问密钥并开通LAS服务

安装

说明：根据需求选择lf-client-2或者lf-client-3进行接入

lf-client-2

兼容开源hive2协议
添加依赖

<dependency>
    <groupId>org.apache.hive</groupId>
    <artifactId>lf-client-2</artifactId>
    <version>1.0.1-RELEASE</version>
</dependency>

请求示例

String ak = {ak};
String sk = {sk};
HiveConf conf = new HiveConf();
conf.set(HiveConf.ConfVars.METASTOREURIS.varname, {endPoint});
HiveMetaStoreClient hmsClient = new HiveMetaStoreClient(conf);
hmsClient.setRegion("cn-beijing");
hmsClient.setAccessKeyIdAndSecretAccessKey(ak, sk);
List<String> allDatabases = hmsClient.getAllDatabases();
System.out.println(allDatabases);
Table table = hmsClient.getTable("db_test","tbl_test");
System.out.println(table);

lf-client-3

兼容开源hive3协议
添加依赖

<dependency>
    <groupId>org.apache.hive</groupId>
    <artifactId>lf-client-3</artifactId>
    <version>1.0.1-RELEASE</version>
</dependency>

请求示例

public static void main(String[] args) throws Exception {
    String ak = {ak};
    String sk = {sk};
    Configuration conf = new Configuration();
    conf.set(MetastoreConf.ConfVars.THRIFT_URIS.getVarname(), {endPoint});
    HiveMetaStoreClient hmsClient = new HiveMetaStoreClient(conf);
    hmsClient.setRegion("cn-beijing");
    hmsClient.setAccessKeyIdAndSecretAccessKey(ak, sk);
    Database database = hmsClient.getDatabase("xyu_test");
    Table table = hmsClient.getTable("db_test","tbl_test");
    System.out.println(database);
    System.out.println(table);
}

版本发布

hive2.x sdk

hive3.x sdk

连接地址

2 权限 SDK for Java 使用参考

前提条件

已创建访问密钥并开通LAS服务

安装

添加依赖

<dependency>
  <groupId>bytedance.olap</groupId>
  <artifactId>gemini-client-shaded</artifactId>
  <version>1.0.0.3-RELEASE</version>
</dependency>

请求示例

public static void main(String[] args) throws Exception {
    String ak = {ak};
    String sk = {sk};
    String endPoint = {endPoint};
    GeminiClientIface signingClient = GeminiClientFactory.createSigningClient(endpoint, ak, sk, null, null, null);
    List<GeminiPrivilege> privileges = new ArrayList<>();
    GeminiPrivilege privilege = new GeminiPrivilege();
    GeminiResource geminiResource = new GeminiResource();
    geminiResource.setResourceScope(GeminiResourceScope.TABLE);
    geminiResource.setRegion("cn-beijing");
    geminiResource.setTenant("2100000001");
    geminiResource.setSchemaName("@hive#db_test");
    geminiResource.setTableName("tb_test");
    privilege.setResource(geminiResource);
    privilege.setAction(GeminiPrivilegeAction.DESCRIBE);
    privileges.add(privilege);
    GeminiPrincipal principal = new GeminiPrincipal();
    principal.setTenant("2100000001");
    principal.setPrincipalType(GeminiPrincipalType.ACCOUNT);
    principal.setPrincipalName("1008632");
    signingClient.checkPrivilegesForPolicy(principal,privileges,null,null);
}

版本发布

连接地址