db

类 DBApiEntry

java.lang.Object

db.DBApiEntry

public class DBApiEntry
extends java.lang.Object

字段概要

字段

限定符和类型	字段和说明
static java.util.logging.Logger	logger

构造器概要

构造器

构造器和说明
DBApiEntry(java.lang.String host, int port, java.lang.String tokenString, java.lang.String org, java.lang.String bucket) 初始化DBApiEntry。

方法概要

限定符和类型	方法和说明
java.util.Hashtable<java.lang.String,PointDataWithSingleValue>	aggTimeRange(java.util.List<java.lang.String> ids, long beginDate, long endDate, AggFunction aggFunction, FieldName fieldName) 针对一系列id，给定时间范围，对给定字段fieldName值进行aggFunction聚合运算。
PointDataWithSingleValue	aggTimeRange(java.lang.String id, long beginDate, long endDate, AggFunction aggFunction, FieldName fieldName) 针对单个id，给定时间范围，对给定字段fieldName值进行aggFunction聚合运算。
java.util.Hashtable<java.lang.String,java.util.SortedMap<java.lang.Long,PointDataWithSingleValue>>	aggTimeRangeByDayInSecondRange(java.util.List<java.lang.String> ids, long beginDate, long endDate, AggFunction aggFunction, FieldName fieldName, int beginSecondInADay, int endSecondInADay) 针对一系列id，给定时间范围，分组窗口粒度为天，给定分组窗口[beginSecondInADay,endSecondInADay]中的数据。
java.util.Hashtable<java.lang.String,java.util.SortedMap<java.lang.Long,PointDataWithSingleValue>>	aggTimeRangeByWindow(java.util.List<java.lang.String> ids, long beginDate, long endDate, long granularityValue, Granularity granularity, AggFunction aggFunction, FieldName fieldName) 针对一系列id，给定时间范围，给定分组窗口粒度，对每个分组窗口中的给定字段fieldName值进行aggFunction聚合运算。
java.util.List<PointDataWithSingleValue>	aggTimeRangeByWindow(java.lang.String id, long beginDate, long endDate, long granularityValue, Granularity granularity, AggFunction aggFunction, FieldName fieldName) 针对单个id，给定时间范围，给定分组窗口粒度，对每个分组窗口中的给定字段fieldName值进行aggFunction聚合运算。
void	close() 释放influxclient资源
boolean	createBucket(java.lang.String name, long retentionPeriod) 指定名称，创建新的bucket。
boolean	deleteAllDataInTimeRange(long beginDate, long endDate)
boolean	deleteBucket(java.lang.String name) 删除指定名称的bucket。
protected java.util.SortedMap<java.lang.Long,PointDataWithSingleValue>	greaterThanTime(java.util.SortedMap<java.lang.Long,PointDataWithSingleValue> timeSery, long compareTime)
boolean	insertRecords(java.util.List<PointData> pointDataList) 将一系列PointData插入到数据库中。
java.util.Hashtable<java.lang.String,java.util.SortedMap<java.lang.Long,PointDataWithSingleValue>>	queryFlowByWindow(java.util.List<java.lang.String> ids, long beginDate, long endDate, long granularityValue, Granularity granularity) 针对一系列id，给定时间范围和分组粒度，查询对应的流量值。
java.util.List<PointDataWithSingleValue>	queryFlowByWindow(java.lang.String id, long beginDate, long endDate, long granularityValue, Granularity granularity) 针对单个id，给定时间范围和分组粒度，查询对应的流量值。
java.util.Hashtable<java.lang.String,FlowInfo>	queryFlowInTimeRange(java.util.List<java.lang.String> ids, long beginDate, long endDate) 针对一系列id，给定时间范围，查询对应时间范围内使用的流量值。
FlowInfo	queryFlowInTimeRange(java.lang.String id, long beginDate, long endDate) 针对单个id，给定时间范围，查询对应时间范围内使用的流量值。
java.util.Hashtable<java.lang.String,PointData>	queryLast(java.util.List<java.lang.String> ids) 给定一系列id，查询对应最新的PointData。
PointData	queryLast(java.lang.String id) 给定id，查询最新的PointData。
java.util.Hashtable<java.lang.String,PointData>	queryLastInTimeRange(java.util.List<java.lang.String> ids, long beginDate, long endDate) 给定一系列id，查询对应最新的PointData。
PointData	queryLastInTimeRange(java.lang.String id, long beginDate, long endDate) 给定id，查询最新的PointData。
java.util.Hashtable<java.lang.String,java.util.SortedMap<java.lang.Long,PointData>>	queryTimeRange(java.util.List<java.lang.String> ids, long beginDate, long endDate) 给定要查询的一系列id和时间范围，返回各id在各时刻下对应的数据。
java.util.List<PointData>	queryTimeRange(java.lang.String id, long beginDate, long endDate) 给定要查询的id和时间范围，返回要查询的数据。

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

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

字段详细资料

logger

public static final java.util.logging.Logger logger

构造器详细资料

DBApiEntry

public DBApiEntry(java.lang.String host,
                  int port,
                  java.lang.String tokenString,
                  java.lang.String org,
                  java.lang.String bucket)
           throws java.io.IOException

初始化DBApiEntry。

参数:

host - 主机ip，如"127.0.0.1"。

port - 端口，如 8086。

tokenString - influxDB的 api token。

org - Organization Id, 8长度字符串。

bucket - 对应插入数据的bucket名称。

抛出:

java.io.IOException

方法详细资料

close

public void close()

释放influxclient资源

insertRecords

public boolean insertRecords(java.util.List<PointData> pointDataList)

将一系列PointData插入到数据库中。

参数:

pointDataList - 待插入的PointData的列表。

返回:

插入成功返回true，出现异常为false。

queryLast

public PointData queryLast(java.lang.String id)

给定id，查询最新的PointData。

参数:

id - 要查询的id。

返回:

id对应的最新的PointData。

queryLastInTimeRange

public PointData queryLastInTimeRange(java.lang.String id,
                                      long beginDate,
                                      long endDate)

给定id，查询最新的PointData。

参数:

id - 要查询的id。

beginDate - 开始时间，UNIX毫秒。

endDate - 结束时间，UNIX毫秒。

返回:

id对应的最新的PointData。

queryLast

public java.util.Hashtable<java.lang.String,PointData> queryLast(java.util.List<java.lang.String> ids)

给定一系列id，查询对应最新的PointData。

参数:

ids - 要查询的id的列表。

返回:

HashTable<id, PointData>
Hashtable，key为id，value为对应最新的PointData。

queryLastInTimeRange

public java.util.Hashtable<java.lang.String,PointData> queryLastInTimeRange(java.util.List<java.lang.String> ids,
                                                                            long beginDate,
                                                                            long endDate)

给定一系列id，查询对应最新的PointData。

参数:

ids - 要查询的id的列表。

beginDate - 开始时间，UNIX毫秒。

endDate - 结束时间，UNIX毫秒。

返回:

HashTable<id, PointData>
Hashtable，key为id，value为对应最新的PointData。

queryTimeRange

public java.util.List<PointData> queryTimeRange(java.lang.String id,
                                                long beginDate,
                                                long endDate)

给定要查询的id和时间范围，返回要查询的数据。

参数:

id - 待查询的id。

beginDate - 开始时间，UNIX毫秒。

endDate - 结束时间，UNIX毫秒。

返回:

id在[beginDate, endDate]对应的PointData列表。

queryTimeRange

public java.util.Hashtable<java.lang.String,java.util.SortedMap<java.lang.Long,PointData>> queryTimeRange(java.util.List<java.lang.String> ids,
                                                                                                          long beginDate,
                                                                                                          long endDate)

给定要查询的一系列id和时间范围，返回各id在各时刻下对应的数据。

参数:

ids - 要查询的id的列表。

beginDate - 开始时间，UNIX毫秒。

endDate - 结束时间，UNIX毫秒。

返回:

HashTabel<id, SortedMap<UNIX毫秒时间戳, 时间戳对应的PointData>>

aggTimeRangeByWindow

public java.util.List<PointDataWithSingleValue> aggTimeRangeByWindow(java.lang.String id,
                                                                     long beginDate,
                                                                     long endDate,
                                                                     long granularityValue,
                                                                     Granularity granularity,
                                                                     AggFunction aggFunction,
                                                                     FieldName fieldName)

针对单个id，给定时间范围，给定分组窗口粒度，对每个分组窗口中的给定字段fieldName值进行aggFunction聚合运算。

参数:

id - 待查询的id。

beginDate - 开始时间，UNIX毫秒。

endDate - 结束时间，UNIX毫秒。

granularityValue - 分组粒度的数值部分。

granularity - 枚举型，分组粒度的单位部分。

aggFunction - 枚举型，聚合运算使用的函数。

fieldName - 枚举型，查询的字段名。

返回:

id在给定时间范围内的PointData经过分组聚合得到的列表。

aggTimeRangeByWindow

public java.util.Hashtable<java.lang.String,java.util.SortedMap<java.lang.Long,PointDataWithSingleValue>> aggTimeRangeByWindow(java.util.List<java.lang.String> ids,
                                                                                                                               long beginDate,
                                                                                                                               long endDate,
                                                                                                                               long granularityValue,
                                                                                                                               Granularity granularity,
                                                                                                                               AggFunction aggFunction,
                                                                                                                               FieldName fieldName)

针对一系列id，给定时间范围，给定分组窗口粒度，对每个分组窗口中的给定字段fieldName值进行aggFunction聚合运算。

参数:

ids - 待查询的id的列表。

beginDate - 开始时间，UNIX毫秒。

endDate - 结束时间，UNIX毫秒。

granularityValue - 枚举型，分组粒度数值部分。

granularity - 枚举型，分组粒度单位部分。

aggFunction - 枚举型，聚合运算的函数。

fieldName - 枚举型，查询的字段名。

返回:

HashTable<id, SortedMap<UNIX毫秒时间戳, 时间戳对应的PointDataWithSingleValue>>。

aggTimeRange

public PointDataWithSingleValue aggTimeRange(java.lang.String id,
                                             long beginDate,
                                             long endDate,
                                             AggFunction aggFunction,
                                             FieldName fieldName)

针对单个id，给定时间范围，对给定字段fieldName值进行aggFunction聚合运算。

参数:

id - 待查询的id。

beginDate - 开始时间，UNIX毫秒。

endDate - 结束时间，UNIX毫秒。

aggFunction - 枚举型，聚合运算使用的函数。

fieldName - 枚举型，查询的字段名。

返回:

id在给定时间范围内的PointData经过分组聚合得到的列表。

aggTimeRange

public java.util.Hashtable<java.lang.String,PointDataWithSingleValue> aggTimeRange(java.util.List<java.lang.String> ids,
                                                                                   long beginDate,
                                                                                   long endDate,
                                                                                   AggFunction aggFunction,
                                                                                   FieldName fieldName)

针对一系列id，给定时间范围，对给定字段fieldName值进行aggFunction聚合运算。

参数:

ids - 待查询的id的列表。

beginDate - 开始时间，UNIX毫秒。

endDate - 结束时间，UNIX毫秒。

aggFunction - 枚举型，聚合运算的函数。

fieldName - 枚举型，查询的字段名。

返回:

HashTable<id, SortedMap<UNIX毫秒时间戳, 时间戳对应的PointDataWithSingleValue>>。

aggTimeRangeByDayInSecondRange

public java.util.Hashtable<java.lang.String,java.util.SortedMap<java.lang.Long,PointDataWithSingleValue>> aggTimeRangeByDayInSecondRange(java.util.List<java.lang.String> ids,
                                                                                                                                         long beginDate,
                                                                                                                                         long endDate,
                                                                                                                                         AggFunction aggFunction,
                                                                                                                                         FieldName fieldName,
                                                                                                                                         int beginSecondInADay,
                                                                                                                                         int endSecondInADay)

针对一系列id，给定时间范围，分组窗口粒度为天，给定分组窗口[beginSecondInADay,endSecondInADay]中的数据。 对每个分组窗口中的给定字段fieldName值进行aggFunction聚合运算。

参数:

ids - 待查询的id的列表。

beginDate - 开始时间，UNIX毫秒。

endDate - 结束时间，UNIX毫秒。

aggFunction - 枚举型，聚合函数。

fieldName - 枚举型，查询的字段名。

beginSecondInADay - 一天内的某个时间窗口的开始时间，单位为秒，如 300 (= 5 * 60) 表示 00:05:00。

endSecondInADay - 一天内的某个时间窗口的结束时间，单位为秒，如 900 (= 15 * 60) 表示 00:15:00。

返回:

HashTable<id, SortedMap<UNIX毫秒时间戳, 时间戳对应的PointDataWithSingleValue>>。

queryFlowByWindow

public java.util.Hashtable<java.lang.String,java.util.SortedMap<java.lang.Long,PointDataWithSingleValue>> queryFlowByWindow(java.util.List<java.lang.String> ids,
                                                                                                                            long beginDate,
                                                                                                                            long endDate,
                                                                                                                            long granularityValue,
                                                                                                                            Granularity granularity)

针对一系列id，给定时间范围和分组粒度，查询对应的流量值。

参数:

ids - 待查询的id的列表。

beginDate - 开始时间，UNIX毫秒。

endDate - 结束时间，UNIX毫秒。

granularityValue - 分组粒度数值部分。

granularity - 枚举型，分组粒度单位部分。

返回:

HashTable<id, SortedMap<UNIX毫秒时间戳, 时间戳对应的PointDataWithSingleValue>>。

greaterThanTime

protected java.util.SortedMap<java.lang.Long,PointDataWithSingleValue> greaterThanTime(java.util.SortedMap<java.lang.Long,PointDataWithSingleValue> timeSery,
                                                                                       long compareTime)

queryFlowByWindow

public java.util.List<PointDataWithSingleValue> queryFlowByWindow(java.lang.String id,
                                                                  long beginDate,
                                                                  long endDate,
                                                                  long granularityValue,
                                                                  Granularity granularity)

针对单个id，给定时间范围和分组粒度，查询对应的流量值。

参数:

id - 待查询的id。

beginDate - 开始时间，UNIX毫秒。

endDate - 结束时间，UNIX毫秒。

granularityValue - 分组粒度数值部分。

granularity - 枚举型，分组粒度单位部分。

返回:

List<UNIX毫秒时间戳，对应的PointDataWithSingleValue>。
PointDataWithSingleValue类有四个public属性：id、pointName、time、value。

queryFlowInTimeRange

public FlowInfo queryFlowInTimeRange(java.lang.String id,
                                     long beginDate,
                                     long endDate)

针对单个id，给定时间范围，查询对应时间范围内使用的流量值。

参数:

id - 待查询的id。

beginDate - 开始时间，UNIX毫秒。

endDate - 结束时间，UNIX毫秒。

返回:

FlowInfo。
PointDataWithSingleValue类有四个public属性：id、pointName、time、value。

queryFlowInTimeRange

public java.util.Hashtable<java.lang.String,FlowInfo> queryFlowInTimeRange(java.util.List<java.lang.String> ids,
                                                                           long beginDate,
                                                                           long endDate)

针对一系列id，给定时间范围，查询对应时间范围内使用的流量值。

参数:

ids - 待查询的id列表。

beginDate - 开始时间，UNIX毫秒。

endDate - 结束时间，UNIX毫秒。

返回:

FlowInfo。
PointDataWithSingleValue类有四个public属性：id、pointName、time、value。

deleteAllDataInTimeRange

public boolean deleteAllDataInTimeRange(long beginDate,
                                        long endDate)

deleteBucket

public boolean deleteBucket(java.lang.String name)

删除指定名称的bucket。

参数:

name - bucket的名称。

返回:

删除成功返回true，出现异常返回false。

createBucket

public boolean createBucket(java.lang.String name,
                            long retentionPeriod)

指定名称，创建新的bucket。

参数:

name - 待创建的新的bucket的名称。

retentionPeriod - 保留期，单位为毫秒。

返回:

成功返回true，出现异常则为false。