程序包 xin.manong.weapon.aliyun.datahub

类 DataHubClient

java.lang.Object

xin.manong.weapon.aliyun.datahub.DataHubClient

所有已实现的接口:

xin.manong.weapon.base.rebuild.Rebuildable

public class DataHubClient
extends Object
implements xin.manong.weapon.base.rebuild.Rebuildable

DataHub客户端

作者:

frankcl

构造器概要

构造器

构造器	说明
DataHubClient(DataHubClientConfig config)

方法概要

修饰符和类型	方法	说明
void	close()	关闭客户端实例
com.aliyun.datahub.model.GetTopicResult	getTopicInfo(String project, String topic)	获取专题信息
boolean	putRecords(String project, String topic, List<com.aliyun.datahub.model.RecordEntry> recordEntries)	写入数据
void	rebuild()

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

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

构造器详细资料

DataHubClient

public DataHubClient(DataHubClientConfig config)

方法详细资料

close

public void close()

关闭客户端实例

rebuild

public void rebuild()

指定者:

rebuild 在接口中 xin.manong.weapon.base.rebuild.Rebuildable

putRecords

public boolean putRecords(String project,
                          String topic,
                          List<com.aliyun.datahub.model.RecordEntry> recordEntries)

写入数据

参数:

project - 项目名称

topic - 专题名称

recordEntries - 数据列表

返回:

成功返回true，否则返回false

getTopicInfo

public com.aliyun.datahub.model.GetTopicResult getTopicInfo(String project,
                                                            String topic)
                                                     throws com.aliyun.datahub.exception.DatahubClientException

获取专题信息

参数:

project - 项目名称

topic - 专题名称

返回:

专题信息

抛出:

com.aliyun.datahub.exception.DatahubClientException