com.aliyun.odps.tunnel

类 StreamClient

java.lang.Object

com.aliyun.odps.tunnel.StreamClient

已过时。

@Deprecated
public class StreamClient
extends Object

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	StreamClient.ShardState 已过时。 shard的状态

构造器概要

构造器

构造器和说明
StreamClient(com.aliyun.odps.tunnel.Configuration conf, String projectName, String tableName) 已过时。

方法概要

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

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

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

构造器详细资料

StreamClient

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

已过时。

抛出:

TunnelException

方法详细资料

getProjectName

public String getProjectName()

已过时。

getTableName

public String getTableName()

已过时。

loadShard

public void loadShard(long shardNumber)
               throws TunnelException

已过时。

在ODPS hub服务上启用shard

参数:

shardNumber - 需要启用的shard数量

抛出:

TunnelException

loadShard

@Deprecated
public void loadShard(int shardNumber)
                           throws TunnelException

已过时。

抛出:

TunnelException

waitForShardLoad

public void waitForShardLoad()
                      throws TunnelException

已过时。

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

抛出:

TunnelException

waitForShardLoad

public void waitForShardLoad(long timeout)
                      throws TunnelException

已过时。

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

参数:

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

抛出:

TunnelException

getShardStatus

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

已过时。

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

返回:

返回key为shardid, value是ShardState的HashMap

抛出:

TunnelException

IOException

QueryReplicatorStatus

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

已过时。

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

参数:

shardId - 需要查询的shardId

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

返回:

ReplicatorStatus

抛出:

TunnelException

QueryReplicatorStatus

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

已过时。

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

参数:

shardId - 需要查询的shardId

返回:

ReplicatorStatus

抛出:

TunnelException

getStreamSchema

public TableSchema getStreamSchema()

已过时。

getShardList

public List<Long> getShardList()

已过时。

openStreamWriter

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

已过时。

抛出:

TunnelException

IOException

openStreamWriter

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

已过时。

抛出:

TunnelException

IOException

openStreamWriter

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

已过时。

抛出:

TunnelException

IOException

openStreamReader

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

已过时。

抛出:

TunnelException

IOException

openStreamReader

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

已过时。

抛出:

TunnelException

IOException

openPackReader

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

已过时。

抛出:

TunnelException

IOException

openPackReader

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

已过时。

抛出:

TunnelException

IOException