阅读249 返回首页    go 新东方

简单上传示例__SDK示例_批量数据通道_大数据计算服务-阿里云

  1.  import java.io.IOException;
  2.  import java.util.Date;
  4.  import com.aliyun.odps.Column;
  5.  import com.aliyun.odps.Odps;
  6.  import com.aliyun.odps.PartitionSpec;
  7.  import com.aliyun.odps.TableSchema;
  8.  import com.aliyun.odps.account.Account;
  9.  import com.aliyun.odps.account.AliyunAccount;
  10.  import com.aliyun.odps.data.Record;
  11.  import com.aliyun.odps.data.RecordWriter;
  12.  import com.aliyun.odps.tunnel.TableTunnel;
  13.  import com.aliyun.odps.tunnel.TunnelException;
  14.  import com.aliyun.odps.tunnel.TableTunnel.UploadSession;
  16.  public class UploadSample {
  17.          private static String accessId = "<your access id>";
  18.          private static String accessKey = "<your access Key>";
  19.          private static String odpsUrl = "https://service.odps.aliyun.com/api";
  21.          private static String project = "<your project>";
  22.          private static String table = "<your table name>";
  23.          private static String partition = "<your partition spec>";
  25.          public static void main(String args[]) {
  26.                  Account account = new AliyunAccount(accessId, accessKey);
  27.                  Odps odps = new Odps(account);
  28.                  odps.setEndpoint(odpsUrl);
  29.                  odps.setDefaultProject(project);
  30.                  try {
  31.                          TableTunnel tunnel = new TableTunnel(odps);
  32.                          PartitionSpec partitionSpec = new PartitionSpec(partition);
  33.                          UploadSession uploadSession = tunnel.createUploadSession(project,
  34.                                          table, partitionSpec);
  36.                          System.out.println("Session Status is : "
  37.                                          + uploadSession.getStatus().toString());
  39.                          TableSchema schema = uploadSession.getSchema();
  40.                          RecordWriter recordWriter = uploadSession.openRecordWriter(0);
  41.                          Record record = uploadSession.newRecord();
  42.                          for (int i = 0; i < schema.getColumns().size(); i++) {
  43.                                  Column column = schema.getColumn(i);
  44.                                  switch (column.getType()) {
  45.                                  case BIGINT:
  46.                                          record.setBigint(i, 1L);
  47.                                          break;
  48.                                  case BOOLEAN:
  49.                                          record.setBoolean(i, true);
  50.                                          break;
  51.                                  case DATETIME:
  52.                                          record.setDatetime(i, new Date());
  53.                                          break;
  54.                                  case DOUBLE:
  55.                                          record.setDouble(i, 0.0);
  56.                                          break;
  57.                                  case STRING:
  58.                                          record.setString(i, "sample");
  59.                                          break;
  60.                                  default:
  61.                                          throw new RuntimeException("Unknown column type: "
  62.                                                          + column.getType());
  63.                                  }
  64.                          }
  65.                          for (int i = 0; i < 10; i++) {
  66.                                  recordWriter.write(record);
  67.                          }
  68.                          recordWriter.close();
  69.                          uploadSession.commit(new Long[]{0L});
  70.                          System.out.println("upload success!");
  72.                  } catch (TunnelException e) {
  73.                          e.printStackTrace();
  74.                  } catch (IOException e) {
  75.                          e.printStackTrace();
  76.                  }
  77.          }
  78.  }

构造器举例说明：PartitionSpec(String spec)：通过字符串构造此类对象。参数:spec: 分区定义字符串，比如: pt=’1’,ds=’2’。因此程序中应该这样配置：private static String partition = “pt=’XXX’,ds=’XXX’”;

最后更新：2016-07-12 15:32:02

  上一篇：go 示例概要__SDK示例_批量数据通道_大数据计算服务-阿里云
  下一篇：go 简单下载示例__SDK示例_批量数据通道_大数据计算服务-阿里云