com.aliyun.odps.tunnel

类 StreamClient

java.lang.Object

com.aliyun.odps.tunnel.StreamClient

public class StreamClient
extends Object

嵌套类概要

嵌套类

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

构造器概要

构造器

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

方法概要

方法

限定符和类型	方法和说明
List<Long>	getShardList()
HashMap<Long,StreamClient.ShardState>	getShardStatus() 查询StreamClinet对应的table拥有的shard在服务端的状态
TableSchema	getStreamSchema()
void	loadShard(int 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(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对应的拷贝到离线集群的状态

从类继承的方法 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

方法详细资料

loadShard

public void loadShard(int shardNumber)
               throws TunnelException

在ODPS hub服务上启用shard

参数:

shardNumber - 需要启用的shard数量

抛出:

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

partitionsSpec - 查询的分区，分区表必选, 非分区表可以为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

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