Table of Contents

...

一、已完成（5）

1. write()

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

...

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

...

二、进行中（1）

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);

...

三、未开始（9）

1. write()

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

...