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和时间范围,返回要查询的数据。
|
public DBApiEntry(java.lang.String host, int port, java.lang.String tokenString, java.lang.String org, java.lang.String bucket) throws java.io.IOException
host
- 主机ip,如"127.0.0.1"。port
- 端口,如 8086。tokenString
- influxDB的 api token。org
- Organization Id, 8长度字符串。bucket
- 对应插入数据的bucket名称。java.io.IOException
public void close()
public boolean insertRecords(java.util.List<PointData> pointDataList)
pointDataList
- 待插入的PointData的列表。public PointData queryLast(java.lang.String id)
id
- 要查询的id。public PointData queryLastInTimeRange(java.lang.String id, long beginDate, long endDate)
id
- 要查询的id。beginDate
- 开始时间,UNIX毫秒。endDate
- 结束时间,UNIX毫秒。public java.util.Hashtable<java.lang.String,PointData> queryLast(java.util.List<java.lang.String> ids)
ids
- 要查询的id的列表。public java.util.Hashtable<java.lang.String,PointData> queryLastInTimeRange(java.util.List<java.lang.String> ids, long beginDate, long endDate)
ids
- 要查询的id的列表。beginDate
- 开始时间,UNIX毫秒。endDate
- 结束时间,UNIX毫秒。public java.util.List<PointData> queryTimeRange(java.lang.String id, long beginDate, long endDate)
id
- 待查询的id。beginDate
- 开始时间,UNIX毫秒。endDate
- 结束时间,UNIX毫秒。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)
ids
- 要查询的id的列表。beginDate
- 开始时间,UNIX毫秒。endDate
- 结束时间,UNIX毫秒。public java.util.List<PointDataWithSingleValue> aggTimeRangeByWindow(java.lang.String id, long beginDate, long endDate, long granularityValue, Granularity granularity, AggFunction aggFunction, FieldName fieldName)
id
- 待查询的id。beginDate
- 开始时间,UNIX毫秒。endDate
- 结束时间,UNIX毫秒。granularityValue
- 分组粒度的数值部分。granularity
- 枚举型,分组粒度的单位部分。aggFunction
- 枚举型,聚合运算使用的函数。fieldName
- 枚举型,查询的字段名。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)
ids
- 待查询的id的列表。beginDate
- 开始时间,UNIX毫秒。endDate
- 结束时间,UNIX毫秒。granularityValue
- 枚举型,分组粒度数值部分。granularity
- 枚举型,分组粒度单位部分。aggFunction
- 枚举型,聚合运算的函数。fieldName
- 枚举型,查询的字段名。public PointDataWithSingleValue aggTimeRange(java.lang.String id, long beginDate, long endDate, AggFunction aggFunction, FieldName fieldName)
id
- 待查询的id。beginDate
- 开始时间,UNIX毫秒。endDate
- 结束时间,UNIX毫秒。aggFunction
- 枚举型,聚合运算使用的函数。fieldName
- 枚举型,查询的字段名。public java.util.Hashtable<java.lang.String,PointDataWithSingleValue> aggTimeRange(java.util.List<java.lang.String> ids, long beginDate, long endDate, AggFunction aggFunction, FieldName fieldName)
ids
- 待查询的id的列表。beginDate
- 开始时间,UNIX毫秒。endDate
- 结束时间,UNIX毫秒。aggFunction
- 枚举型,聚合运算的函数。fieldName
- 枚举型,查询的字段名。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)
ids
- 待查询的id的列表。beginDate
- 开始时间,UNIX毫秒。endDate
- 结束时间,UNIX毫秒。aggFunction
- 枚举型,聚合函数。fieldName
- 枚举型,查询的字段名。beginSecondInADay
- 一天内的某个时间窗口的开始时间,单位为秒,如 300 (= 5 * 60) 表示 00:05:00。endSecondInADay
- 一天内的某个时间窗口的结束时间,单位为秒,如 900 (= 15 * 60) 表示 00:15:00。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)
ids
- 待查询的id的列表。beginDate
- 开始时间,UNIX毫秒。endDate
- 结束时间,UNIX毫秒。granularityValue
- 分组粒度数值部分。granularity
- 枚举型,分组粒度单位部分。protected java.util.SortedMap<java.lang.Long,PointDataWithSingleValue> greaterThanTime(java.util.SortedMap<java.lang.Long,PointDataWithSingleValue> timeSery, long compareTime)
public java.util.List<PointDataWithSingleValue> queryFlowByWindow(java.lang.String id, long beginDate, long endDate, long granularityValue, Granularity granularity)
id
- 待查询的id。beginDate
- 开始时间,UNIX毫秒。endDate
- 结束时间,UNIX毫秒。granularityValue
- 分组粒度数值部分。granularity
- 枚举型,分组粒度单位部分。public FlowInfo queryFlowInTimeRange(java.lang.String id, long beginDate, long endDate)
id
- 待查询的id。beginDate
- 开始时间,UNIX毫秒。endDate
- 结束时间,UNIX毫秒。public java.util.Hashtable<java.lang.String,FlowInfo> queryFlowInTimeRange(java.util.List<java.lang.String> ids, long beginDate, long endDate)
ids
- 待查询的id列表。beginDate
- 开始时间,UNIX毫秒。endDate
- 结束时间,UNIX毫秒。public boolean deleteAllDataInTimeRange(long beginDate, long endDate)
public boolean deleteBucket(java.lang.String name)
name
- bucket的名称。public boolean createBucket(java.lang.String name, long retentionPeriod)
name
- 待创建的新的bucket的名称。retentionPeriod
- 保留期,单位为毫秒。