Package com.influxdb.client.flux.internal

Class FluxApiImpl

java.lang.Object

com.influxdb.internal.AbstractRestClient

com.influxdb.internal.AbstractQueryApi

com.influxdb.client.flux.internal.FluxApiImpl

All Implemented Interfaces:

FluxClient

public class FluxApiImpl
extends AbstractQueryApi
implements FluxClient

Author:

Jakub Bednar (bednar@github) (03/10/2018 14:20)

Nested Class Summary

Nested classes/interfaces inherited from class com.influxdb.internal.AbstractQueryApi

AbstractQueryApi.FluxRecordIterator, AbstractQueryApi.RawIterator

Field Summary

Fields inherited from class com.influxdb.internal.AbstractQueryApi

DEFAULT_DIALECT, EMPTY_ACTION, ERROR_CONSUMER, fluxCsvParser, LOG, resultMapper

Constructor Summary

Constructors

Constructor	Description
FluxApiImpl(FluxConnectionOptions options)

Method Summary

Modifier and Type	Method	Description
void	close()	Closes the client, initiates shutdown, no new running calls are accepted during shutdown.
LogLevel	getLogLevel()	Gets the LogLevel that is used for logging requests and responses.
Boolean	ping()	Check the status of InfluxDB Server.
List<FluxTable>	query(String query)	Executes the Flux query against the InfluxDB and synchronously map whole response to List<FluxTable>.
<M> List<M>	query(String query, Class<M> measurementType)	Executes the Flux query against the InfluxDB and synchronously map whole response to list of object with given type.
<M> void	query(String query, Class<M> measurementType, BiConsumer<Cancellable,M> onNext)	Executes the Flux query against the InfluxDB and asynchronously stream POJO classes to onNext consumer.
<M> void	query(String query, Class<M> measurementType, BiConsumer<Cancellable,M> onNext, Consumer<? super Throwable> onError)	Executes the Flux query against the InfluxDB and asynchronously stream POJO classes to onNext consumer.
<M> void	query(String query, Class<M> measurementType, BiConsumer<Cancellable,M> onNext, Consumer<? super Throwable> onError, Runnable onComplete)	Executes the Flux query and asynchronously stream result as POJO.
void	query(String query, BiConsumer<Cancellable,FluxRecord> onNext)	Executes the Flux query against the InfluxDB and asynchronously stream FluxRecords to onNext consumer.
void	query(String query, BiConsumer<Cancellable,FluxRecord> onNext, Consumer<? super Throwable> onError)	Executes the Flux query against the InfluxDB and asynchronously stream FluxRecords to onNext consumer.
void	query(String query, BiConsumer<Cancellable,FluxRecord> onNext, Consumer<? super Throwable> onError, Runnable onComplete)	Executes the Flux query against the InfluxDB and asynchronously stream FluxRecords to onNext consumer.
String	queryRaw(String query)	Executes the Flux query against the InfluxDB and synchronously map whole response to String result.
String	queryRaw(String query, String dialect)	Executes the Flux query against the InfluxDB and synchronously map whole response to String result.
void	queryRaw(String query, String dialect, BiConsumer<Cancellable,String> onNext)	Executes the Flux query against the InfluxDB and asynchronously stream response (line by line) to onResponse.
void	queryRaw(String query, String dialect, BiConsumer<Cancellable,String> onResponse, Consumer<? super Throwable> onError)	Executes the Flux query against the InfluxDB and asynchronously stream response (line by line) to onResponse.
void	queryRaw(String query, String dialect, BiConsumer<Cancellable,String> onResponse, Consumer<? super Throwable> onError, Runnable onComplete)	Executes the Flux query against the InfluxDB and asynchronously stream response (line by line) to onResponse.
void	queryRaw(String query, BiConsumer<Cancellable,String> onResponse)	Executes the Flux query against the InfluxDB and asynchronously stream response (line by line) to onResponse.
void	queryRaw(String query, BiConsumer<Cancellable,String> onResponse, Consumer<? super Throwable> onError)	Executes the Flux query against the InfluxDB and asynchronously stream response (line by line) to onResponse.
void	queryRaw(String query, BiConsumer<Cancellable,String> onResponse, Consumer<? super Throwable> onError, Runnable onComplete)	Executes the Flux query against the InfluxDB and asynchronously stream response (line by line) to onResponse.
FluxClient	setLogLevel(LogLevel logLevel)	Sets the log level for the request and response information.
String	version()	Returns the version of the connected InfluxDB Server.

Methods inherited from class com.influxdb.internal.AbstractQueryApi

createBody, query, query, queryIterator, queryRaw, queryRawIterator

Methods inherited from class com.influxdb.internal.AbstractRestClient

execute, getLogLevel, ping, responseToError, setLogLevel, toInfluxException, version

Methods inherited from class java.lang.Object

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

Constructor Details

FluxApiImpl

public FluxApiImpl(@Nonnull
 FluxConnectionOptions options)

Method Details

query

@Nonnull
public List<FluxTable> query(@Nonnull
 String query)

Description copied from interface: FluxClient

Executes the Flux query against the InfluxDB and synchronously map whole response to List<FluxTable>.

NOTE: This method is not intended for large query results. Use FluxClient.query(String, BiConsumer, Consumer, Runnable) for large data streaming.

Specified by:

query in interface FluxClient

Parameters:

query - the flux query to execute

Returns:

List<FluxTable> which are matched the query

query

@Nonnull
public <M> List<M> query(@Nonnull
 String query,
 @Nonnull
 Class<M> measurementType)

Description copied from interface: FluxClient

Executes the Flux query against the InfluxDB and synchronously map whole response to list of object with given type.

NOTE: This method is not intended for large query results. Use FluxClient.query(String, Class, BiConsumer, Consumer, Runnable) for large data streaming.

Specified by:

query in interface FluxClient

Parameters:

query - the flux query to execute

measurementType - the type of measurement

Returns:

List<FluxTable> which are matched the query

query

public void query(@Nonnull
 String query,
 @Nonnull
 BiConsumer<Cancellable,FluxRecord> onNext)

Description copied from interface: FluxClient

Executes the Flux query against the InfluxDB and asynchronously stream FluxRecords to onNext consumer.

Specified by:

query in interface FluxClient

Parameters:

query - the flux query to execute

onNext - the callback to consume the FluxRecord result with capability to discontinue a streaming query

query

public <M> void query(@Nonnull
 String query,
 @Nonnull
 Class<M> measurementType,
 @Nonnull
 BiConsumer<Cancellable,M> onNext)

Description copied from interface: FluxClient

Executes the Flux query against the InfluxDB and asynchronously stream POJO classes to onNext consumer.

Specified by:

query in interface FluxClient

Type Parameters:

M - the type of the measurement (POJO)

Parameters:

query - the flux query to execute

measurementType - the measurement type (POJO)

onNext - the callback to consume the FluxRecord result with capability to discontinue a streaming query

query

public void query(@Nonnull
 String query,
 @Nonnull
 BiConsumer<Cancellable,FluxRecord> onNext,
 @Nonnull
 Consumer<? super Throwable> onError)

Description copied from interface: FluxClient

Executes the Flux query against the InfluxDB and asynchronously stream FluxRecords to onNext consumer.

Specified by:

query in interface FluxClient

Parameters:

query - the flux query to execute

onNext - the callback to consume FluxRecord result with capability to discontinue a streaming query

onError - the callback to consume any error notification

query

public <M> void query(@Nonnull
 String query,
 @Nonnull
 Class<M> measurementType,
 @Nonnull
 BiConsumer<Cancellable,M> onNext,
 @Nonnull
 Consumer<? super Throwable> onError)

Description copied from interface: FluxClient

Executes the Flux query against the InfluxDB and asynchronously stream POJO classes to onNext consumer.

Specified by:

query in interface FluxClient

Type Parameters:

M - the type of the measurement (POJO)

Parameters:

query - the flux query to execute

measurementType - the measurement type (POJO)

onNext - the callback to consume POJO record with capability to discontinue a streaming query

onError - the callback to consume any error notification

query

public void query(@Nonnull
 String query,
 @Nonnull
 BiConsumer<Cancellable,FluxRecord> onNext,
 @Nonnull
 Consumer<? super Throwable> onError,
 @Nonnull
 Runnable onComplete)

Description copied from interface: FluxClient

Executes the Flux query against the InfluxDB and asynchronously stream FluxRecords to onNext consumer.

Specified by:

query in interface FluxClient

Parameters:

query - the flux query to execute

onNext - the callback to consume FluxRecord result with capability to discontinue a streaming query

onError - the callback to consume any error notification

onComplete - the callback to consume a notification about successfully end of stream

query

public <M> void query(@Nonnull
 String query,
 @Nonnull
 Class<M> measurementType,
 @Nonnull
 BiConsumer<Cancellable,M> onNext,
 @Nonnull
 Consumer<? super Throwable> onError,
 @Nonnull
 Runnable onComplete)

Description copied from interface: FluxClient

Executes the Flux query and asynchronously stream result as POJO.

Specified by:

query in interface FluxClient

Type Parameters:

M - the type of the measurement (POJO)

Parameters:

query - the flux query to execute

measurementType - the measurement type (POJO)

onNext - the callback to consume POJO record with capability to discontinue a streaming query

onError - the callback to consume any error notification

onComplete - the callback to consume a notification about successfully end of stream

queryRaw

@Nonnull
public String queryRaw(@Nonnull
 String query)

Description copied from interface: FluxClient

Executes the Flux query against the InfluxDB and synchronously map whole response to String result.

NOTE: This method is not intended for large responses, that do not fit into memory. Use FluxClient.queryRaw(String, BiConsumer, Consumer, Runnable) for large data streaming.

Specified by:

queryRaw in interface FluxClient

Parameters:

query - the flux query to execute

Returns:

the raw response that matched the query

queryRaw

@Nonnull
public String queryRaw(@Nonnull
 String query,
 @Nullable
 String dialect)

Description copied from interface: FluxClient

Executes the Flux query against the InfluxDB and synchronously map whole response to String result.

NOTE: This method is not intended for large responses, that do not fit into memory. Use FluxClient.queryRaw(String, String, BiConsumer, Consumer, Runnable) for large data streaming.

Specified by:

queryRaw in interface FluxClient

Parameters:

query - the flux query to execute

dialect - Dialect is an object defining the options to use when encoding the response. See dialect SPEC..

Returns:

the raw response that matched the query

queryRaw

public void queryRaw(@Nonnull
 String query,
 @Nonnull
 BiConsumer<Cancellable,String> onResponse)

Description copied from interface: FluxClient

Executes the Flux query against the InfluxDB and asynchronously stream response (line by line) to onResponse.

Specified by:

queryRaw in interface FluxClient

Parameters:

query - the flux query to execute

onResponse - callback to consume the response line by line with capability to discontinue a streaming query

queryRaw

public void queryRaw(@Nonnull
 String query,
 @Nullable
 String dialect,
 @Nonnull
 BiConsumer<Cancellable,String> onNext)

Description copied from interface: FluxClient

Executes the Flux query against the InfluxDB and asynchronously stream response (line by line) to onResponse.

Specified by:

queryRaw in interface FluxClient

Parameters:

query - the flux query to execute

dialect - Dialect is an object defining the options to use when encoding the response. See dialect SPEC..

onNext - the callback to consume the response line by line with capability to discontinue a streaming query

queryRaw

public void queryRaw(@Nonnull
 String query,
 @Nonnull
 BiConsumer<Cancellable,String> onResponse,
 @Nonnull
 Consumer<? super Throwable> onError)

Description copied from interface: FluxClient

Executes the Flux query against the InfluxDB and asynchronously stream response (line by line) to onResponse.

Specified by:

queryRaw in interface FluxClient

Parameters:

query - the flux query to execute

onResponse - the callback to consume the response line by line with capability to discontinue a streaming query

onError - callback to consume any error notification

queryRaw

public void queryRaw(@Nonnull
 String query,
 @Nullable
 String dialect,
 @Nonnull
 BiConsumer<Cancellable,String> onResponse,
 @Nonnull
 Consumer<? super Throwable> onError)

Description copied from interface: FluxClient

Executes the Flux query against the InfluxDB and asynchronously stream response (line by line) to onResponse.

Specified by:

queryRaw in interface FluxClient

Parameters:

query - the flux query to execute

dialect - Dialect is an object defining the options to use when encoding the response. See dialect SPEC..

onResponse - the callback to consume the response line by line with capability to discontinue a streaming query

onError - callback to consume any error notification

queryRaw

public void queryRaw(@Nonnull
 String query,
 @Nonnull
 BiConsumer<Cancellable,String> onResponse,
 @Nonnull
 Consumer<? super Throwable> onError,
 @Nonnull
 Runnable onComplete)

Description copied from interface: FluxClient

Executes the Flux query against the InfluxDB and asynchronously stream response (line by line) to onResponse.

Specified by:

queryRaw in interface FluxClient

Parameters:

query - the flux query to execute

onResponse - the callback to consume the response line by line with capability to discontinue a streaming query

onError - callback to consume any error notification

onComplete - callback to consume a notification about successfully end of stream

queryRaw

public void queryRaw(@Nonnull
 String query,
 @Nullable
 String dialect,
 @Nonnull
 BiConsumer<Cancellable,String> onResponse,
 @Nonnull
 Consumer<? super Throwable> onError,
 @Nonnull
 Runnable onComplete)

Description copied from interface: FluxClient

Executes the Flux query against the InfluxDB and asynchronously stream response (line by line) to onResponse.

Specified by:

queryRaw in interface FluxClient

Parameters:

query - the flux query to execute

dialect - Dialect is an object defining the options to use when encoding the response. See dialect SPEC..

onResponse - the callback to consume the response line by line with capability to discontinue a streaming query The callback call contains the one line of the response.

onError - callback to consume any error notification

onComplete - callback to consume a notification about successfully end of stream

ping

@Nonnull
public Boolean ping()

Description copied from interface: FluxClient

Check the status of InfluxDB Server.

Specified by:

ping in interface FluxClient

Returns:

Boolean.TRUE if server is healthy otherwise return Boolean.FALSE

version

@Nonnull
public String version()

Description copied from interface: FluxClient

Returns the version of the connected InfluxDB Server.

Specified by:

version in interface FluxClient

Returns:

the version String, otherwise unknown.

getLogLevel

@Nonnull
public LogLevel getLogLevel()

Description copied from interface: FluxClient

Gets the LogLevel that is used for logging requests and responses.

Specified by:

getLogLevel in interface FluxClient

Returns:

the LogLevel that is used for logging requests and responses

setLogLevel

@Nonnull
public FluxClient setLogLevel(@Nonnull
 LogLevel logLevel)

Description copied from interface: FluxClient

Sets the log level for the request and response information.

Specified by:

setLogLevel in interface FluxClient

Parameters:

logLevel - the log level to set.

Returns:

the FluxClient instance to be able to use it in a fluent manner.

close

public void close()

Closes the client, initiates shutdown, no new running calls are accepted during shutdown.

Specified by:

close in interface FluxClient