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 QueryResult query(final Query query);

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