com.aliyun.odps.tunnel

类 StreamUploadWriter

java.lang.Object

com.aliyun.odps.tunnel.StreamUploadWriter

public class StreamUploadWriter
extends Object

Created by yinyue on 15-6-10.

构造器概要

构造器

构造器和说明
StreamUploadWriter(com.aliyun.odps.rest.RestClient tunnelServiceClient, String path)
StreamUploadWriter(com.aliyun.odps.rest.RestClient tunnelServiceClient, String path, HashMap<String,String> params, HashMap<String,String> headers, com.aliyun.odps.tunnel.TunnelTableSchema schema)

方法概要

限定符和类型	方法和说明
com.aliyun.odps.tunnel.TunnelTableSchema	getSchema()
void	write(DatahubRecordPack recordPack) 向ODPS非分区表写入数据,第一次写入会自动load shard
void	write(PartitionSpec partitionSpec, DatahubRecordPack recordPack) 向ODPS分区表写入数据,第一次写入会自动load shard

从类继承的方法 java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

StreamUploadWriter

public StreamUploadWriter(com.aliyun.odps.rest.RestClient tunnelServiceClient,
                          String path)
                   throws TunnelException

抛出:

TunnelException

StreamUploadWriter

public StreamUploadWriter(com.aliyun.odps.rest.RestClient tunnelServiceClient,
                          String path,
                          HashMap<String,String> params,
                          HashMap<String,String> headers,
                          com.aliyun.odps.tunnel.TunnelTableSchema schema)

方法详细资料

write

public void write(DatahubRecordPack recordPack)
           throws TunnelException,
                  IOException

向ODPS非分区表写入数据,第一次写入会自动load shard

参数:

recordPack - StreamRecordPack 对象

抛出:

TunnelException, - IOException

TunnelException

IOException

write

public void write(PartitionSpec partitionSpec,
                  DatahubRecordPack recordPack)
           throws TunnelException,
                  IOException

向ODPS分区表写入数据,第一次写入会自动load shard

参数:

partitionSpec - PartitionSpec 对象

recordPack - StreamRecordPack 对象

抛出:

TunnelException, - IOException

TunnelException

IOException

getSchema

public com.aliyun.odps.tunnel.TunnelTableSchema getSchema()