Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

其中已完成个接口,进行中个接口,未开始个接口。

Table of Contents

...

一、已完成

1. write()

write函数有很多接口,主要的适配目标包括:以Point的形式,以String字符串的形式将数据写入数据库中。

...

/**
* Set the database which is used for writing points.
*/
public InfluxDB setDatabase(final String database);

...


二、进行中

1. query()

query函数有很多接口,主要的适配目标包括:支持常规过滤、值过滤和tag过滤。同时支持聚合函数,选择函数等等功能。

...


/**
* Execute a query against a database.
*/
public void query(final Query query, final Consumer<QueryResult> onSuccess, final Consumer<Throwable> onFailure);

/**
* Execute a streaming query against a database.
*/
public void query(Query query, int chunkSize, Consumer<QueryResult> onNext);

/**
* Execute a streaming query against a database.
*/
public void query(Query query, int chunkSize, BiConsumer<Cancellable, QueryResult> onNext);

/**
* Execute a streaming query against a database.
*/
public void query(Query query, int chunkSize, Consumer<QueryResult> onNext, Runnable onComplete);

/**
* Execute a streaming query against a database.
*/
public void query(Query query, int chunkSize, BiConsumer<Cancellable, QueryResult> onNext, Runnable onComplete);

/**
* Execute a streaming query against a database.
*/
public void query(Query query, int chunkSize, BiConsumer<Cancellable, QueryResult> onNext, Runnable onComplete,
Consumer<Throwable> onFailure);

/**
* Execute a query against a database.
*/
public QueryResult query(final Query query, TimeUnit timeUnit);

...


三、未开始

1. write()

write函数绝大多数接口已经实现,目前还有一个写入重试的接口未实现:

...