com.dtstack.dtcenter.loader.client.tsdb

类 TsdbClientProxy

java.lang.Object

com.dtstack.dtcenter.loader.client.tsdb.TsdbClientProxy

所有已实现的接口:

ITsdb

public class TsdbClientProxy
extends Object
implements ITsdb

OpenTSDB 代理类

作者:

：wangchuan date：Created in 上午10:06 2021/6/23 company: www.dtstack.com

构造器概要

构造器

构造器和说明
TsdbClientProxy(ITsdb tsdb)

方法概要

限定符和类型	方法和说明
Boolean	deleteData(ISourceDTO source, String metric, List<String> fields, long startTime, long endTime) 根据 metric 、字段、开始时间、结束时间删除数据
Boolean	deleteData(ISourceDTO source, String metric, long startTime, long endTime) 根据 metric 、开始时间、结束时间删除数据
Boolean	deleteData(ISourceDTO source, String metric, Map<String,String> tags, List<String> fields, long startTime, long endTime) 根据 metric 、tags、字段、开始时间、结束时间删除数据
Boolean	deleteData(ISourceDTO source, String metric, Map<String,String> tags, long startTime, long endTime) 根据 metric 、tags、开始时间、结束时间删除数据
Boolean	deleteMeta(ISourceDTO source, String metric, List<String> fields, Map<String,String> tags, boolean deleteData, boolean recursive) 根据 metric 、tags 删除数据
Boolean	deleteMeta(ISourceDTO source, String metric, Map<String,String> tags) 根据 metric 、tags删除数据
Boolean	deleteMeta(ISourceDTO source, String metric, Map<String,String> tags, boolean deleteData, boolean recursive) 根据 metric 、tags 删除数据
Boolean	deleteMeta(ISourceDTO source, String metric, Map<String,String> tags, List<String> fields) 根据 metric 、tags、fields删除数据
Map<String,String>	getVersionInfo(ISourceDTO source) 获取详细版本信息
Boolean	putSync(ISourceDTO source, Collection<TsdbPoint> points) 同步插入多个点位
List<QueryResult>	query(ISourceDTO source, TsdbQuery query) 查询
List<String>	suggest(ISourceDTO source, Suggest type, String prefix, int max) suggest method
List<String>	suggest(ISourceDTO source, Suggest type, String metric, String prefix, int max) suggest method
String	version(ISourceDTO source) 获取版本号

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

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

构造器详细资料

TsdbClientProxy

public TsdbClientProxy(ITsdb tsdb)

方法详细资料

putSync

public Boolean putSync(ISourceDTO source,
                       Collection<TsdbPoint> points)

从接口复制的说明: ITsdb

同步插入多个点位

指定者:

putSync 在接口中 ITsdb

参数:

source - 数据源信息

points - 插入点位

返回:

Result 返回结果

query

public List<QueryResult> query(ISourceDTO source,
                               TsdbQuery query)

从接口复制的说明: ITsdb

查询

指定者:

query 在接口中 ITsdb

参数:

source - 数据源信息

query - 查询条件

返回:

result 查询结果

deleteData

public Boolean deleteData(ISourceDTO source,
                          String metric,
                          long startTime,
                          long endTime)

从接口复制的说明: ITsdb

根据 metric 、开始时间、结束时间删除数据

指定者:

deleteData 在接口中 ITsdb

参数:

source - 数据源信息

metric - metric 名称

startTime - 开始时间

endTime - 结束时间

deleteData

public Boolean deleteData(ISourceDTO source,
                          String metric,
                          Map<String,String> tags,
                          long startTime,
                          long endTime)

从接口复制的说明: ITsdb

根据 metric 、tags、开始时间、结束时间删除数据

指定者:

deleteData 在接口中 ITsdb

参数:

source - 数据源信息

metric - metric 名称

tags - tags 集合

startTime - 开始时间

endTime - 结束时间

deleteData

public Boolean deleteData(ISourceDTO source,
                          String metric,
                          List<String> fields,
                          long startTime,
                          long endTime)

从接口复制的说明: ITsdb

根据 metric 、字段、开始时间、结束时间删除数据

指定者:

deleteData 在接口中 ITsdb

参数:

source - 数据源信息

metric - metric 名称

fields - fields 集合

startTime - 开始时间

endTime - 结束时间

deleteData

public Boolean deleteData(ISourceDTO source,
                          String metric,
                          Map<String,String> tags,
                          List<String> fields,
                          long startTime,
                          long endTime)

从接口复制的说明: ITsdb

根据 metric 、tags、字段、开始时间、结束时间删除数据

指定者:

deleteData 在接口中 ITsdb

参数:

source - 数据源信息

metric - metric 名称

tags - tags 集合

fields - fields 结合

startTime - 开始时间

endTime - 结束时间

deleteMeta

public Boolean deleteMeta(ISourceDTO source,
                          String metric,
                          Map<String,String> tags)

从接口复制的说明: ITsdb

根据 metric 、tags删除数据

指定者:

deleteMeta 在接口中 ITsdb

参数:

source - 数据源信息

metric - metric 名称

tags - tags 集合

deleteMeta

public Boolean deleteMeta(ISourceDTO source,
                          String metric,
                          Map<String,String> tags,
                          List<String> fields)

从接口复制的说明: ITsdb

根据 metric 、tags、fields删除数据

指定者:

deleteMeta 在接口中 ITsdb

参数:

source - 数据源信息

metric - metric 名称

tags - tags 集合

fields - fields 集合

deleteMeta

public Boolean deleteMeta(ISourceDTO source,
                          String metric,
                          Map<String,String> tags,
                          boolean deleteData,
                          boolean recursive)

从接口复制的说明: ITsdb

根据 metric 、tags 删除数据

指定者:

deleteMeta 在接口中 ITsdb

参数:

source - 数据源信息

metric - metric 名称

tags - tags 集合

deleteData - 是否删除数据

recursive - 递归删除

deleteMeta

public Boolean deleteMeta(ISourceDTO source,
                          String metric,
                          List<String> fields,
                          Map<String,String> tags,
                          boolean deleteData,
                          boolean recursive)

从接口复制的说明: ITsdb

根据 metric 、tags 删除数据

指定者:

deleteMeta 在接口中 ITsdb

参数:

source - 数据源信息

metric - metric 名称

fields - fields 集合

tags - tags 集合

deleteData - 是否删除数据

recursive - 递归删除

suggest

public List<String> suggest(ISourceDTO source,
                            Suggest type,
                            String prefix,
                            int max)

从接口复制的说明: ITsdb

suggest method

指定者:

suggest 在接口中 ITsdb

参数:

source - 数据源信息

type - suggest 类型

prefix - 前缀匹配

max - 最大返回条数

返回:

result 返回结果

suggest

public List<String> suggest(ISourceDTO source,
                            Suggest type,
                            String metric,
                            String prefix,
                            int max)

从接口复制的说明: ITsdb

suggest method

指定者:

suggest 在接口中 ITsdb

参数:

source - 数据源信息

type - suggest 类型

metric - metric 名称

prefix - 前缀匹配

max - 最大返回条数

返回:

result 返回结果

version

public String version(ISourceDTO source)

从接口复制的说明: ITsdb

获取版本号

指定者:

version 在接口中 ITsdb

参数:

source - 数据源信息

返回:

版本号

getVersionInfo

public Map<String,String> getVersionInfo(ISourceDTO source)

从接口复制的说明: ITsdb

获取详细版本信息

指定者:

getVersionInfo 在接口中 ITsdb

参数:

source - 数据源信息

返回:

详细版本信息