通过SDK加载数据

可以使用Java库上传下载数据、执行SQL查询或计算任务、查询计算状态。请参阅Java SDK。

使用Java SDK上传数据

使用Java库上传下载数据，需要先初始化一个 RainClient 对象:

RainClient client = new RainClient("<accessKey>", "<accessSecret>", "<endpoint>")

这里 "<accessKey>" 和 "<accessSecret>" 可以在工作区 管理 » 用户管理 » 客户端密钥 里创建和管理,
"<endpoint>" 可以在 "......" 在查询。

下面示例将本地csv数据首次导入表中

String db = UUID.randomUUID().toString().replace("-", "").substring(0, 8);
String table = UUID.randomUUID().toString().replace("-", "").substring(0, 8);
RainClient rainClient = new RainClient(ak, sk, endpoint);
String[] sources = {"/data/example.csv"};
rainClient.loadAsTable(sources, db, table, "", false);

示例将本地csv数据导入到已存在的表中

String db = UUID.randomUUID().toString().replace("-", "").substring(0, 8);
String table = UUID.randomUUID().toString().replace("-", "").substring(0, 8);
RainClient rainClient = new RainClient(ak, sk, endpoint);
String[] sources = {"/data/example.csv"};
rainClient.loadIntoTable(sources, db, table);

提交 Commit 和提交 Streaming

sdk中loadintoTable方法

public void loadIntoTable(String[] sources,
                              String databaseName,
                              String tableName)

有一个重载方法

 public void loadIntoTable(String[] sources,
                              String databaseName,
                              String tableName,
                              boolean isStreaming)

其中isStreaming参数控制本次导入的数据是否提交为streaming
示例：

String db = UUID.randomUUID().toString().replace("-", "").substring(0, 8);
String table = UUID.randomUUID().toString().replace("-", "").substring(0, 8);
RainClient rainClient = new RainClient(ak, sk, endpoint);
String[] sources = {"/data/example.csv"};
rainClient.loadIntoTable(sources, db, table); // commit提交 等价 rainClient.loadIntoTable(sources, db, table ,false)
rainClient.loadIntoTable(sources, db, table ,true) //streaming 提交

使用Java SDK下载数据

将表中数据下载到本地示例

// 先导入数据作为测试
String db = UUID.randomUUID().toString().replace("-", "").substring(0, 8);
String table = UUID.randomUUID().toString().replace("-", "").substring(0, 8);
RainClient rainClient = new RainClient(ak, sk, endpoint);
String[] sources = {"/data/example.csv"};
rainClient.loadAsTable(sources, db, table, "", false);
//下载数据到本地 并且下载为json格式
String target = "/data/example_download.json";
rainClient.getFromTable(sources, db, target);