MaxCompute用户指南:批量数据通道SDK示例:BufferedWriter多线程上传示例
- class UploadThread extends Thread {
- private UploadSession session;
- private static int RECORD_COUNT = 1200;
- public UploadThread(UploadSession session) {
- this.session = session;
- }
- @Override
- public void run() {
- RecordWriter writer = up.openBufferedWriter();
- Record r = up.newRecord();
- for (int i = 0; i < RECORD_COUNT; i++) {
- r.setBigint(0, i);
- writer.write(r);
- }
- writer.close();
- }
- };
- public class Example {
- public static void main(String args[]) {
- // 初始化 MaxCompute 和 tunnel 的代码
- TableTunnel.UploadSession uploadSession = tunnel.createUploadSession(projectName, tableName);
- UploadThread t1 = new UploadThread(up);
- UploadThread t2 = new UploadThread(up);
- t1.start();
- t2.start();
- t1.join();
- t2.join();
- uploadSession.commit();
- }
展开
收起
问答标签：
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
