Package com.influxdb.internal

Class AbstractQueryApi

java.lang.Object

com.influxdb.internal.AbstractRestClient

com.influxdb.internal.AbstractQueryApi

Direct Known Subclasses:

FluxApiImpl, InfluxQLQueryApiImpl

public abstract class AbstractQueryApi
extends AbstractRestClient

Author:

Jakub Bednar (bednar@github) (17/10/201AbstractQueryApi8 11:20)

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected final class	AbstractQueryApi.FluxRecordIterator
protected final class	AbstractQueryApi.RawIterator

Field Summary

Fields

Modifier and Type	Field	Description
protected static final String	DEFAULT_DIALECT
protected static final Runnable	EMPTY_ACTION
protected static final Consumer<Throwable>	ERROR_CONSUMER
protected final FluxCsvParser	fluxCsvParser
protected static final Logger	LOG
protected final FluxResultMapper	resultMapper

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractQueryApi()
protected	AbstractQueryApi(FluxCsvParser fluxCsvParser)

Method Summary

Modifier and Type	Method	Description
protected okhttp3.RequestBody	createBody(String dialect, String query)
protected void	query(retrofit2.Call<okhttp3.ResponseBody> queryCall, FluxCsvParser.FluxResponseConsumer responseConsumer, Consumer<? super Throwable> onError, Runnable onComplete, Boolean asynchronously)
protected void	query(retrofit2.Call<okhttp3.ResponseBody> query, BiConsumer<Cancellable,okio.BufferedSource> consumer, Consumer<? super Throwable> onError, Runnable onComplete, Boolean asynchronously)
protected AbstractQueryApi.FluxRecordIterator	queryIterator(retrofit2.Call<okhttp3.ResponseBody> queryCall)
protected void	queryRaw(retrofit2.Call<okhttp3.ResponseBody> queryCall, BiConsumer<Cancellable,String> onResponse, Consumer<? super Throwable> onError, Runnable onComplete, Boolean asynchronously)
protected AbstractQueryApi.RawIterator	queryRawIterator(retrofit2.Call<okhttp3.ResponseBody> queryCall)

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

Field Details

LOG

protected static final Logger LOG

fluxCsvParser

protected final FluxCsvParser fluxCsvParser

resultMapper

protected final FluxResultMapper resultMapper

EMPTY_ACTION

protected static final Runnable EMPTY_ACTION

DEFAULT_DIALECT

protected static final String DEFAULT_DIALECT

ERROR_CONSUMER

protected static final Consumer<Throwable> ERROR_CONSUMER

Constructor Details

AbstractQueryApi

protected AbstractQueryApi()

AbstractQueryApi

protected AbstractQueryApi(@Nonnull
 FluxCsvParser fluxCsvParser)

Method Details

createBody

@Nonnull
protected okhttp3.RequestBody createBody(@Nullable
 String dialect,
 @Nonnull
 String query)

query

protected void query(@Nonnull
 retrofit2.Call<okhttp3.ResponseBody> queryCall,
 @Nonnull
 FluxCsvParser.FluxResponseConsumer responseConsumer,
 @Nonnull
 Consumer<? super Throwable> onError,
 @Nonnull
 Runnable onComplete,
 @Nonnull
 Boolean asynchronously)

queryIterator

protected AbstractQueryApi.FluxRecordIterator queryIterator(@Nonnull
 retrofit2.Call<okhttp3.ResponseBody> queryCall)

queryRaw

protected void queryRaw(@Nonnull
 retrofit2.Call<okhttp3.ResponseBody> queryCall,
 @Nonnull
 BiConsumer<Cancellable,String> onResponse,
 @Nonnull
 Consumer<? super Throwable> onError,
 @Nonnull
 Runnable onComplete,
 @Nonnull
 Boolean asynchronously)

queryRawIterator

protected AbstractQueryApi.RawIterator queryRawIterator(@Nonnull
 retrofit2.Call<okhttp3.ResponseBody> queryCall)

query

protected void query(@Nonnull
 retrofit2.Call<okhttp3.ResponseBody> query,
 @Nonnull
 BiConsumer<Cancellable,okio.BufferedSource> consumer,
 @Nonnull
 Consumer<? super Throwable> onError,
 @Nonnull
 Runnable onComplete,
 @Nonnull
 Boolean asynchronously)