com.aliyun.odps.commons

Class GeneralConfiguration

java.lang.Object

com.aliyun.odps.commons.GeneralConfiguration

Direct Known Subclasses:

DatahubConfiguration

public class GeneralConfiguration
extends Object

Created by dongxiao.dx on 2015/9/7.

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_CHUNK_SIZE 上传数据的默认块大小(单位字节)。默认值按照MTU-4设置，MTU值1500。
static int	DEFAULT_SOCKET_CONNECT_TIMEOUT 底层网络链接的默认超时时间,180秒
static int	DEFAULT_SOCKET_TIMEOUT 底层网络默认超时时间, 300秒。

Constructor Summary

Constructors

Constructor and Description
GeneralConfiguration(Odps odps)

Method Summary

Methods

Modifier and Type	Method and Description
Account	getAccount()
int	getChunkSize() 取得当前配置的数据传输块大小
URI	getEndpoint(String projectName)
String	getResource(String projectName, String tableName) 获得RESTful资源标识符
int	getSocketConnectTimeout() 取得当前配置的网络链接超时时间, 单位秒
int	getSocketTimeout() 取得当前配置的网络IO超时时间, 秒
String	getStreamUploadResource(String projectName, String tableName) 获得流式上传的RESTful资源标识符
String	getStreamUploadResource(String projectName, String tableName, long shardId) 获得Stream upload数据的RESTful资源标识符
URI	getURI(String projectName, String tableName) 取得URI
String	getUserAgent() 获取User-Agent信息
void	setChunkSize(int chunkSize) 设置上传数据时HTTP使用的块大小(单位字节)。
void	setEndpoint(URI endpoint) Set endpoint
void	setSocketConnectTimeout(int timeout) 设置网络链接超时时间, 单位秒
void	setSocketTimeout(int timeout) 设置网络IO超时时间, 秒

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_CHUNK_SIZE

public static int DEFAULT_CHUNK_SIZE

上传数据的默认块大小(单位字节)。默认值按照MTU-4设置，MTU值1500。

DEFAULT_SOCKET_CONNECT_TIMEOUT

public static int DEFAULT_SOCKET_CONNECT_TIMEOUT

底层网络链接的默认超时时间,180秒

DEFAULT_SOCKET_TIMEOUT

public static int DEFAULT_SOCKET_TIMEOUT

底层网络默认超时时间, 300秒。

Constructor Detail

GeneralConfiguration

public GeneralConfiguration(Odps odps)

Method Detail

getAccount

public Account getAccount()

getEndpoint

public URI getEndpoint(String projectName)
                throws OdpsException

Throws:

OdpsException

setEndpoint

public void setEndpoint(URI endpoint)

Set endpoint

Parameters:

endpoint -

getURI

public URI getURI(String projectName,
         String tableName)
           throws OdpsException

取得URI

Parameters:

projectName -

tableName -

Returns:

Throws:

OdpsException

getResource

public String getResource(String projectName,
                 String tableName)

获得RESTful资源标识符

Parameters:

projectName -

tableName -

Returns:

getStreamUploadResource

public String getStreamUploadResource(String projectName,
                             String tableName,
                             long shardId)

获得Stream upload数据的RESTful资源标识符

Parameters:

projectName -

tableName -

shardId -

Returns:

getStreamUploadResource

public String getStreamUploadResource(String projectName,
                             String tableName)

获得流式上传的RESTful资源标识符

Parameters:

projectName -

tableName -

Returns:

getChunkSize

public int getChunkSize()

取得当前配置的数据传输块大小

Returns:

当前配置的块大小

See Also:

DEFAULT_CHUNK_SIZE

setChunkSize

public void setChunkSize(int chunkSize)

设置上传数据时HTTP使用的块大小(单位字节)。

通过ProtobufRecordStreamWriter上传的数据会被以chunked方式编码在HTTP通道上传 输。可以通过 getChunkSize()查询当前配置的块大小。

一般情况下不建议修改默认值。

Parameters:

chunkSize - 块大小

See Also:

DEFAULT_CHUNK_SIZE, getChunkSize()

getSocketConnectTimeout

public int getSocketConnectTimeout()

取得当前配置的网络链接超时时间, 单位秒

Returns:

网络链接超时时间

setSocketConnectTimeout

public void setSocketConnectTimeout(int timeout)

设置网络链接超时时间, 单位秒

Parameters:

timeout - 超时时间

getSocketTimeout

public int getSocketTimeout()

取得当前配置的网络IO超时时间, 秒

Returns:

超时时间

setSocketTimeout

public void setSocketTimeout(int timeout)

设置网络IO超时时间, 秒

NOTICE: 此值等于HTTP请求的超时时间。对应不同的API请求，SDK会使用不同的 默认值, 除非必要, 请不要修改默认值。

Parameters:

timeout - 超时时间

See Also:

URLConnection.setReadTimeout(int)

getUserAgent

public String getUserAgent()

获取User-Agent信息

Returns:

User-Agent信息