com.aliyun.odps.tunnel

Class StreamClient

java.lang.Object

com.aliyun.odps.tunnel.StreamClient

Deprecated.

@Deprecated
public class StreamClient
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	StreamClient.ShardState Deprecated. shard的状态

Constructor Summary

Constructors

Constructor and Description
StreamClient(com.aliyun.odps.tunnel.Configuration conf, String projectName, String tableName) Deprecated.

Method Summary

Methods

Modifier and Type	Method and Description
String	getProjectName() Deprecated.
List<Long>	getShardList() Deprecated.
HashMap<Long,StreamClient.ShardState>	getShardStatus() Deprecated. 查询StreamClinet对应的table拥有的shard在服务端的状态
TableSchema	getStreamSchema() Deprecated.
String	getTableName() Deprecated.
void	loadShard(int shardNumber) Deprecated.
void	loadShard(long shardNumber) Deprecated. 在ODPS hub服务上启用shard
com.aliyun.odps.tunnel.io.PackReader	openPackReader(long shardId) Deprecated.
com.aliyun.odps.tunnel.io.PackReader	openPackReader(long shardId, String packId) Deprecated.
com.aliyun.odps.tunnel.io.StreamReader	openStreamReader(long shardId) Deprecated.
com.aliyun.odps.tunnel.io.StreamReader	openStreamReader(long shardId, String packId) Deprecated.
com.aliyun.odps.tunnel.io.StreamWriter	openStreamWriter() Deprecated.
com.aliyun.odps.tunnel.io.StreamWriter	openStreamWriter(long shardId) Deprecated.
com.aliyun.odps.tunnel.io.StreamWriter	openStreamWriter(String shardId) Deprecated.
com.aliyun.odps.tunnel.io.ReplicatorStatus	QueryReplicatorStatus(long shardId) Deprecated. 在ODPS hub查询非分区表拷贝到离线集群的状态
com.aliyun.odps.tunnel.io.ReplicatorStatus	QueryReplicatorStatus(long shardId, PartitionSpec partitionSpec) Deprecated. 在ODPS hub查询partiton对应的拷贝到离线集群的状态
void	waitForShardLoad() Deprecated. 同步等待 load shard 完成 默认超时时间为 60s
void	waitForShardLoad(long timeout) Deprecated. 同步等待 load shard 完成 最大超时时间为 60000ms

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamClient

public StreamClient(com.aliyun.odps.tunnel.Configuration conf,
            String projectName,
            String tableName)
             throws TunnelException

Deprecated.

Throws:

TunnelException

Method Detail

getProjectName

public String getProjectName()

Deprecated.

getTableName

public String getTableName()

Deprecated.

loadShard

public void loadShard(long shardNumber)
               throws TunnelException

Deprecated.

在ODPS hub服务上启用shard

Parameters:

shardNumber - 需要启用的shard数量

Throws:

TunnelException

loadShard

@Deprecated
public void loadShard(int shardNumber)
               throws TunnelException

Deprecated.

Throws:

TunnelException

waitForShardLoad

public void waitForShardLoad()
                      throws TunnelException

Deprecated.

同步等待 load shard 完成 默认超时时间为 60s

Throws:

TunnelException

waitForShardLoad

public void waitForShardLoad(long timeout)
                      throws TunnelException

Deprecated.

同步等待 load shard 完成 最大超时时间为 60000ms

Parameters:

timeout - 超时时间,单位是毫秒 若该值超过 60000ms,将等待 60000ms

Throws:

TunnelException

getShardStatus

public HashMap<Long,StreamClient.ShardState> getShardStatus()
                                                     throws TunnelException,
                                                            IOException

Deprecated.

查询StreamClinet对应的table拥有的shard在服务端的状态

Returns:

返回key为shardid, value是ShardState的HashMap

Throws:

TunnelException

IOException

QueryReplicatorStatus

public com.aliyun.odps.tunnel.io.ReplicatorStatus QueryReplicatorStatus(long shardId,
                                                               PartitionSpec partitionSpec)
                                                                 throws TunnelException

Deprecated.

在ODPS hub查询partiton对应的拷贝到离线集群的状态

Parameters:

shardId - 需要查询的shardId

partitionSpec - 查询的分区，分区表必选, 非分区表可以为null

Returns:

ReplicatorStatus

Throws:

TunnelException

QueryReplicatorStatus

public com.aliyun.odps.tunnel.io.ReplicatorStatus QueryReplicatorStatus(long shardId)
                                                                 throws TunnelException

Deprecated.

在ODPS hub查询非分区表拷贝到离线集群的状态

Parameters:

shardId - 需要查询的shardId

Returns:

ReplicatorStatus

Throws:

TunnelException

getStreamSchema

public TableSchema getStreamSchema()

Deprecated.

getShardList

public List<Long> getShardList()

Deprecated.

openStreamWriter

@Deprecated
public com.aliyun.odps.tunnel.io.StreamWriter openStreamWriter(String shardId)
                                                        throws TunnelException,
                                                               IOException

Deprecated.

Throws:

TunnelException

IOException

openStreamWriter

public com.aliyun.odps.tunnel.io.StreamWriter openStreamWriter(long shardId)
                                                        throws TunnelException,
                                                               IOException

Deprecated.

Throws:

TunnelException

IOException

openStreamWriter

public com.aliyun.odps.tunnel.io.StreamWriter openStreamWriter()
                                                        throws TunnelException,
                                                               IOException

Deprecated.

Throws:

TunnelException

IOException

openStreamReader

public com.aliyun.odps.tunnel.io.StreamReader openStreamReader(long shardId)
                                                        throws TunnelException,
                                                               IOException

Deprecated.

Throws:

TunnelException

IOException

openStreamReader

public com.aliyun.odps.tunnel.io.StreamReader openStreamReader(long shardId,
                                                      String packId)
                                                        throws TunnelException,
                                                               IOException

Deprecated.

Throws:

TunnelException

IOException

openPackReader

public com.aliyun.odps.tunnel.io.PackReader openPackReader(long shardId)
                                                    throws TunnelException,
                                                           IOException

Deprecated.

Throws:

TunnelException

IOException

openPackReader

public com.aliyun.odps.tunnel.io.PackReader openPackReader(long shardId,
                                                  String packId)
                                                    throws TunnelException,
                                                           IOException

Deprecated.

Throws:

TunnelException

IOException