123456789101112131415161718192021222324252627282930 |
- package com.gyee.impala;
- import com.gyee.impala.common.config.datasource.KuduDataSourceConfig;
- import org.apache.kudu.client.KuduClient;
- import org.apache.kudu.client.KuduException;
- import org.apache.kudu.client.KuduTable;
- import org.junit.jupiter.api.Test;
- import org.springframework.beans.factory.annotation.Autowired;
- import org.springframework.boot.test.context.SpringBootTest;
- @SpringBootTest
- class GyeeSampleImpalaApplicationTests {
- @Autowired
- private KuduDataSourceConfig kuduConfig;
- @Test
- void contextLoads() {
- KuduClient kuduClient = new KuduClient
- .KuduClientBuilder("192.168.1.65:7051")//7051,21050
- .defaultOperationTimeoutMs(6000)
- .build();
- try {
- KuduTable kuduTable = kuduClient.openTable("impala::gyee_sample_kudu.windspeedforecastshortterm");
- } catch (KuduException e) {
- e.printStackTrace();
- }
- }
- }
|